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

Class TimerRegistrationAction

java.lang.Object

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

public class TimerRegistrationAction
extends Object

TimerRegistrationAction used to register Timer.

Constructor Summary

Constructors

Constructor	Description
TimerRegistrationAction(TimerRegistration timerRegistration, byte[] serializedTimerData, List<TimerRegistrationAction> containingList)

Method Summary

Modifier and Type	Method	Description
void	registerTimer()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerRegistrationAction

public TimerRegistrationAction(TimerRegistration timerRegistration,
                               byte[] serializedTimerData,
                               List<TimerRegistrationAction> containingList)

Method Detail

run

public void run()

registerTimer

public void registerTimer()