Hi Davood,
right now, you can only inspect the timestamps by writing a custom operator
that you would use with DataStream.transform(). Measuring latency this way
has some pitfalls, though. The timestamp might be assigned on a different
machine than the machine that will process the tuple at the sin
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(TimeCharact
