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

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?


View raw message