Re: SinkFunction.Context

Excellent ! Thanks Rong.. On Thu, Feb 21, 2019 at 7:26 PM Rong Rong wrote: > Hi Durga, > > 1. currentProcessingTime: refers to this operator(SinkFunction)'s system > time at the moment of invoke > 1a. the time you are referring to as "flink window got the message" is the > currentProcessingTime

Re: SinkFunction.Context

Hi Durga, 1. currentProcessingTime: refers to this operator(SinkFunction)'s system time at the moment of invoke 1a. the time you are referring to as "flink window got the message" is the currentProcessingTime() invoked at the window operator (which provided by the WindowContext similar to this one

SinkFunction.Context

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