public class WindowTimerServiceImpl extends Object implements WindowTimerService<Long>
WindowTimerService
.Constructor and Description |
---|
WindowTimerServiceImpl(InternalTimerService<Long> internalTimerService,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Method and 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.
|
public WindowTimerServiceImpl(InternalTimerService<Long> internalTimerService, java.time.ZoneId shiftTimeZone)
public java.time.ZoneId getShiftTimeZone()
WindowTimerService
getShiftTimeZone
in interface WindowTimerService<Long>
public long currentProcessingTime()
WindowTimerService
currentProcessingTime
in interface WindowTimerService<Long>
public long currentWatermark()
WindowTimerService
currentWatermark
in interface WindowTimerService<Long>
public void registerProcessingTimeWindowTimer(Long window)
WindowTimerService
registerProcessingTimeWindowTimer
in interface WindowTimerService<Long>
public void registerEventTimeWindowTimer(Long window)
WindowTimerService
registerEventTimeWindowTimer
in interface WindowTimerService<Long>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.