flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Davood Rafiei <rafieidavo...@gmail.com>
Subject Flink timestamps
Date Sat, 06 Aug 2016 11:47:26 GMT
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

Mime
View raw message