org.apache.flink.table.runtime.operators

Class TableStreamOperator.ContextImpl

java.lang.Object

org.apache.flink.table.runtime.operators.TableStreamOperator.ContextImpl

All Implemented Interfaces:

TimerService

Enclosing class:

TableStreamOperator<OUT>

protected class TableStreamOperator.ContextImpl
extends Object
implements TimerService

Information available in an invocation of processElement.

Field Summary

Fields

Modifier and Type	Field and Description
StreamRecord<?>	element
protected ProcessingTimeService	timerService

Fields inherited from interface org.apache.flink.streaming.api.TimerService

UNSUPPORTED_DELETE_TIMER_MSG, UNSUPPORTED_REGISTER_TIMER_MSG

Method Summary

Modifier and Type	Method and Description
long	currentProcessingTime() Returns the current processing time.
long	currentWatermark() Returns the current event-time watermark.
void	deleteEventTimeTimer(long time) Deletes the event-time timer with the given trigger time.
void	deleteProcessingTimeTimer(long time) Deletes the processing-time timer with the given trigger time.
void	registerEventTimeTimer(long time) Registers a timer to be fired when the event time watermark passes the given time.
void	registerProcessingTimeTimer(long time) Registers a timer to be fired when processing time passes the given time.
TimerService	timerService()
Long	timestamp()

Methods inherited from class java.lang.Object

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

Field Detail

timerService

protected final ProcessingTimeService timerService

element

public StreamRecord<?> element

Method Detail

timestamp

public Long timestamp()

currentProcessingTime

public long currentProcessingTime()

Description copied from interface: TimerService

Returns the current processing time.

Specified by:

currentProcessingTime in interface TimerService

currentWatermark

public long currentWatermark()

Description copied from interface: TimerService

Returns the current event-time watermark.

Specified by:

currentWatermark in interface TimerService

registerProcessingTimeTimer

public void registerProcessingTimeTimer(long time)

Description copied from interface: TimerService

Registers a timer to be fired when processing time passes the given time.

Timers can internally be scoped to keys and/or windows. When you set a timer in a keyed context, such as in an operation on KeyedStream then that context will also be active when you receive the timer notification.

Specified by:

registerProcessingTimeTimer in interface TimerService

registerEventTimeTimer

public void registerEventTimeTimer(long time)

Description copied from interface: TimerService

Registers a timer to be fired when the event time watermark passes the given time.

Timers can internally be scoped to keys and/or windows. When you set a timer in a keyed context, such as in an operation on KeyedStream then that context will also be active when you receive the timer notification.

Specified by:

registerEventTimeTimer in interface TimerService

deleteProcessingTimeTimer

public void deleteProcessingTimeTimer(long time)

Description copied from interface: TimerService

Deletes the processing-time timer with the given trigger time. This method has only an effect if such a timer was previously registered and did not already expire.

Timers can internally be scoped to keys and/or windows. When you delete a timer, it is removed from the current keyed context.

Specified by:

deleteProcessingTimeTimer in interface TimerService

deleteEventTimeTimer

public void deleteEventTimeTimer(long time)

Description copied from interface: TimerService

Deletes the event-time timer with the given trigger time. This method has only an effect if such a timer was previously registered and did not already expire.

Timers can internally be scoped to keys and/or windows. When you delete a timer, it is removed from the current keyed context.

Specified by:

deleteEventTimeTimer in interface TimerService

timerService

public TimerService timerService()