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

Class SlicingWindowTimerServiceImpl

java.lang.Object

org.apache.flink.table.runtime.operators.window.tvf.common.WindowTimerServiceBase<Long>

org.apache.flink.table.runtime.operators.window.tvf.slicing.SlicingWindowTimerServiceImpl

All Implemented Interfaces:

WindowTimerService<Long>

public class SlicingWindowTimerServiceImpl
extends WindowTimerServiceBase<Long>

A WindowTimerService for slicing window.

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.window.tvf.common.WindowTimerServiceBase

internalTimerService, shiftTimeZone

Constructor Summary

Constructors

Constructor	Description
SlicingWindowTimerServiceImpl(InternalTimerService<Long> internalTimerService, ZoneId shiftTimeZone)

Method Summary

Modifier and Type	Method	Description
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 org.apache.flink.table.runtime.operators.window.tvf.common.WindowTimerServiceBase

currentProcessingTime, currentWatermark, getShiftTimeZone

Methods inherited from class java.lang.Object

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

Constructor Detail

SlicingWindowTimerServiceImpl

public SlicingWindowTimerServiceImpl(InternalTimerService<Long> internalTimerService,
                                     ZoneId shiftTimeZone)

Method Detail

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.

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.