org.apache.flink.streaming.api.operators.python.process.timer

Class TimerHandler

java.lang.Object

org.apache.flink.streaming.api.operators.python.process.timer.TimerHandler

@Internal
public final class TimerHandler
extends Object

Utilities to handle triggered timer.

Constructor Summary

Constructors

Constructor and Description
TimerHandler()

Method Summary

Modifier and Type	Method and Description
Row	buildTimerData(TimeDomain timeDomain, long watermark, long timestamp, Row key, byte[] encodedNamespace)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimerHandler

public TimerHandler()

Method Detail

buildTimerData

public Row buildTimerData(TimeDomain timeDomain,
                          long watermark,
                          long timestamp,
                          Row key,
                          byte[] encodedNamespace)