Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
From: Davood Rafiei <rafieidavood9@gmail.com>
Date: Sat, 6 Aug 2016 13:47:26 +0200
Message-ID: <CA+iVLodx4_8Wd+2aMFHBPvfA8AGgfKHfvAxLaaZmmhxBD_ZC8A@mail.gmail.com>
Subject: Flink timestamps
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=94eb2c0d0676479a96053965bf58
archived-at: Sat, 06 Aug 2016 11:47:36 -0000

--94eb2c0d0676479a96053965bf58
Content-Type: text/plain; charset=UTF-8

Hi,

I want to assign timestamps to tuples when they enter source operator ,
get those timestamps in sink operator and extract them from current time
and output.

Basically my goal is to measure latency.

To set timestamps in source operator I used:


*  env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);*
However, I don't know how to get the tuple's previously assigned (in source
operator) timestamp in sink operator. Is it possible? Or should I insert a
separate field to tuple for keeping the timestamp?

Cheers
Davood

--94eb2c0d0676479a96053965bf58
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div>Hi,<br><br></div>I want to assign timestamps to =
tuples when they enter source operator ,=C2=A0 get those timestamps in sink=
 operator and extract them from current time and output. <br><br>Basically =
my goal is to measure latency. <br><br></div><div>To set timestamps in sour=
ce operator I used:<br>=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 <br><i>=C2=A0 env.set=
StreamTimeCharacteristic(TimeCharacteristic.IngestionTime);<br><br></i></di=
v><div>However, I don&#39;t know how to get the tuple&#39;s previously assi=
gned (in source operator) timestamp in sink operator. Is it possible? Or sh=
ould I insert a separate field to tuple for keeping the timestamp?<br><br><=
/div><div>Cheers<br></div><div>Davood<br></div><div><br></div><div><br><br>=
</div></div>

--94eb2c0d0676479a96053965bf58--