Package org.apache.flink.table.runtime.operators.window.slicing

Class WindowTimerServiceImpl

java.lang.Object

org.apache.flink.table.runtime.operators.window.slicing.WindowTimerServiceImpl

All Implemented Interfaces:

WindowTimerService<Long>

public class WindowTimerServiceImpl
extends Object
implements WindowTimerService<Long>

Simple Implements of WindowTimerService.

Constructor Summary

Constructors

Constructor	Description
WindowTimerServiceImpl(org.apache.flink.streaming.api.operators.InternalTimerService<Long> internalTimerService, java.time.ZoneId shiftTimeZone)

Method Summary

Modifier and Type	Method	Description
long	currentProcessingTime()	Returns the current processing time.
long	currentWatermark()	Returns the current event-time watermark.
java.time.ZoneId	getShiftTimeZone()	The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift timezone is the timezone user configured in TableConfig, other cases the timezone is UTC which means never shift when assigning windows.
void	registerEventTimeWindowTimer(Long window)	Registers a window timer to be fired when event time watermark passes the window.
void	registerProcessingTimeWindowTimer(Long window)	Registers a window timer to be fired when processing time passes the window.

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowTimerServiceImpl

public WindowTimerServiceImpl(org.apache.flink.streaming.api.operators.InternalTimerService<Long> internalTimerService,
                              java.time.ZoneId shiftTimeZone)

Method Detail

getShiftTimeZone

public java.time.ZoneId getShiftTimeZone()

Description copied from interface: WindowTimerService

The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift timezone is the timezone user configured in TableConfig, other cases the timezone is UTC which means never shift when assigning windows.

Specified by:

getShiftTimeZone in interface WindowTimerService<Long>

currentProcessingTime

public long currentProcessingTime()

Description copied from interface: WindowTimerService

Returns the current processing time.

Specified by:

currentProcessingTime in interface WindowTimerService<Long>

currentWatermark

public long currentWatermark()

Description copied from interface: WindowTimerService

Returns the current event-time watermark.

Specified by:

currentWatermark in interface WindowTimerService<Long>

registerProcessingTimeWindowTimer

public void registerProcessingTimeWindowTimer(Long window)

Description copied from interface: WindowTimerService

Registers a window timer to be fired when processing time passes the window. The window you pass here will be provided when the timer fires.

Specified by:

registerProcessingTimeWindowTimer in interface WindowTimerService<Long>

registerEventTimeWindowTimer

public void registerEventTimeWindowTimer(Long window)

Description copied from interface: WindowTimerService

Registers a window timer to be fired when event time watermark passes the window. The window you pass here will be provided when the timer fires.

Specified by:

registerEventTimeWindowTimer in interface WindowTimerService<Long>