Package 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

Description

TimerRegistration(org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.types.Row> keyedStateBackend, org.apache.flink.streaming.api.operators.InternalTimerService internalTimerService, org.apache.flink.streaming.api.operators.KeyContext keyContext, org.apache.flink.api.common.typeutils.TypeSerializer namespaceSerializer, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> timerDataSerializer)

Method Summary

Modifier and Type	Method	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(org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.types.Row> keyedStateBackend,
                         org.apache.flink.streaming.api.operators.InternalTimerService internalTimerService,
                         org.apache.flink.streaming.api.operators.KeyContext keyContext,
                         org.apache.flink.api.common.typeutils.TypeSerializer namespaceSerializer,
                         org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> timerDataSerializer)
                  throws Exception

Throws:

Exception

Method Detail

setTimer

public void setTimer(byte[] serializedTimerData)