out: Collector[OUT]) is invoked when a previously registered timer triggers. The timestamp argument gives the timestamp of the firing timer and the Collector allows emitting records. The OnTimerContext processElement() method and also returns the time domain (processing time or event time) of the firing timer. 29 KeyedProcessFunction Vasiliki Kalavri | Boston University 2020 val warnings = readings temperature of last sensor reading val lastTemp: Double // stores timestamp of currently active timer val currentTimer: Long override def processElement(r: SensorReading, ctx:Context, out: Collector[String]):

Collector out) { /* add/sort this event into the queue */ /* set an event-time timer for when the stream is complete up to the event-time of this event */ } @Override public void

building robust, stateful streaming applications. It provides fine-grained control over state and timer, which allows for the implementation of advanced event-driven systems. You can run the latest version

building robust, stateful streaming applications. It provides fine-grained control over state and timer, which allows for the implementation of advanced event-driven systems. You can run the latest version