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

Class TimerRegistration

java.lang.Object

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

@Internal
public final class TimerRegistration
extends Object

Handles the interaction with the Python worker for registering and deleting timers.

Constructor Summary

Constructors

Constructor and Description
TimerRegistration(KeyedStateBackend<Row> keyedStateBackend, InternalTimerService internalTimerService, KeyContext keyContext, TypeSerializer namespaceSerializer, TypeSerializer<Row> timerDataSerializer)

Method Summary

Modifier and Type	Method and Description
void	setTimer(byte[] serializedTimerData)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerRegistration

public TimerRegistration(KeyedStateBackend<Row> keyedStateBackend,
                         InternalTimerService internalTimerService,
                         KeyContext keyContext,
                         TypeSerializer namespaceSerializer,
                         TypeSerializer<Row> timerDataSerializer)
                  throws Exception

Throws:

Exception

Method Detail

setTimer

public void setTimer(byte[] serializedTimerData)