HI Folks, Was following the documentation for
https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.Context.html long currentProcessingTime <https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.Context.html#currentProcessingTime--> () Returns the current processing time. long currentWatermark <https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.Context.html#currentWatermark--> () Returns the current event-time watermark. Long <http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true> timestamp <https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.Context.html#timestamp--> () Returns the timestamp of the current input record or null if the element does not have an assigned timestamp. - CurrentProcessing time - is this is the Event Time ? i.e the time when the Event Occured ? (or) when the flink window got the message ?. - timeStamp - is this the time the record is persisted in to the sync ?. (or) the aggregated data timestamp ?. Say if I have 100 records in my time window - which time comes in to affect. - CurrentWaterMark - which time is this - the time the even occured - what will this value be - when there are 1000 records in my time window PS - We want to use some ID ( timestamp ) and associate with all the records that are persisted (aggregated) in a given time window - i.e if there are 1000 records aggregated - and they resulted in 10 aggregated records - we want to give these 10 aggregated records the same ID and we want to use one of the above time stamp Thanks much.
