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
