Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id AF887200CD1 for ; Wed, 26 Jul 2017 21:37:53 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id ADEE3169735; Wed, 26 Jul 2017 19:37:53 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 01434169734 for ; Wed, 26 Jul 2017 21:37:52 +0200 (CEST) Received: (qmail 54440 invoked by uid 500); 26 Jul 2017 19:37:51 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 54430 invoked by uid 99); 26 Jul 2017 19:37:51 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 26 Jul 2017 19:37:51 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 441061807C9 for ; Wed, 26 Jul 2017 19:37:51 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.379 X-Spam-Level: ** X-Spam-Status: No, score=2.379 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 0QQsNlu5WoaC for ; Wed, 26 Jul 2017 19:37:50 +0000 (UTC) Received: from mail-qt0-f169.google.com (mail-qt0-f169.google.com [209.85.216.169]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 3B02660D17 for ; Wed, 26 Jul 2017 19:37:50 +0000 (UTC) Received: by mail-qt0-f169.google.com with SMTP id 16so12293061qtz.4 for ; Wed, 26 Jul 2017 12:37:50 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=s5LTH/Kxp810qKe6H5Go1u7JFmNSvk7BwAAwzR7SR+8=; b=RCZOsjWMEQjzj516IQBynVx2nV/xkJ1EaYyWsoJIRQdRkri2k/nfuveoGbfhM6sACt 05CALCj31JrUu6WAk0phBTSeIMe7mfeekLzCYJMlGtgt5hdksAmodnU9W0pCrCC4tWOe y21qhBT64MLdlAP2ImDd7f8KF1HphDTtf4bRJarjkou9T0lg6Bm9Ohfo7T45jbYd6z5P uwYYUwNM4zsBJRYlnO4EnKMD/fZKFaR2mBDv2W1tQRK49+AN9bacOuzrIVFbd059nFFX Tqsmtz8DmgiU+XxwsxlrWzROw3RuO29BqMjpiqRwaAOrddDs734JLlps9/dkBNfqAW5n NP6A== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=s5LTH/Kxp810qKe6H5Go1u7JFmNSvk7BwAAwzR7SR+8=; b=juUbP+QZBvstALqoMnf76zeNLW1VKgTxTBoae0YcyUSJe9BsQbbqMZw2dBHq2qWqyP vu3VKNFYTpoWYV3OuYZWp2swaQNlIs4bzwDr/TZRrBaXAcMG1RTVre4oECcaqUt224Ry rthdrJpTZs3yiadtLDpUwwURTiEjJVY0FDnafd/O85QAdgz32q2UsifBdW5Vh3jTmOo3 QskNwbHqFYO8FBlfvvWqihZh/U5MrVk/4MGcsQ/m4+4FbkJYQZ16aT2FoIGnmxWJUQ4Z q94FDqGJ0oQcdD16bjLwt0RpuSp3SRQRWgo40yjjCG/lQRbmw/e1rpFahpgSXDYHjWlA wc6A== X-Gm-Message-State: AIVw111YYiWOX2AbNH63/1fflxHqmBscC22Y+T9L3YjS4z8tVfhp2L/A 8PuHSbTwzpgAUCkpTT9LaGJhgzSwwA== X-Received: by 10.237.36.215 with SMTP id u23mr3095837qtc.40.1501097868561; Wed, 26 Jul 2017 12:37:48 -0700 (PDT) MIME-Version: 1.0 Received: by 10.140.85.148 with HTTP; Wed, 26 Jul 2017 12:37:27 -0700 (PDT) From: "G.S.Vijay Raajaa" Date: Thu, 27 Jul 2017 01:07:27 +0530 Message-ID: Subject: Watermarking and Timestamp on Kafka stream union To: user Content-Type: multipart/alternative; boundary="001a113f47f83a92c305553d9543" archived-at: Wed, 26 Jul 2017 19:37:53 -0000 --001a113f47f83a92c305553d9543 Content-Type: text/plain; charset="UTF-8" HI, I am having a union of 3 kafka topic stream, i am joining them by a timestamp field. I would like to order the join by timestamp. How do I assign a watermark and extract timestamp from a union stream? Regards, Vijay Raajaa GS --001a113f47f83a92c305553d9543 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
HI,

I am having a union of 3 kafka topi= c stream, i am joining them by a timestamp field. I would like to order the= join by timestamp. How do I assign a watermark and extract timestamp from = a union stream?

Regards,
Vijay Raajaa GS= =C2=A0
--001a113f47f83a92c305553d9543--