public abstract class WindowTimerServiceBase<W> extends Object implements WindowTimerService<W>
WindowTimerService
.Modifier and Type | Field and Description |
---|---|
protected InternalTimerService<W> |
internalTimerService |
protected java.time.ZoneId |
shiftTimeZone |
Constructor and Description |
---|
WindowTimerServiceBase(InternalTimerService<W> 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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
registerEventTimeWindowTimer, registerProcessingTimeWindowTimer
protected final InternalTimerService<W> internalTimerService
protected final java.time.ZoneId shiftTimeZone
public WindowTimerServiceBase(InternalTimerService<W> internalTimerService, java.time.ZoneId shiftTimeZone)
public java.time.ZoneId getShiftTimeZone()
WindowTimerService
getShiftTimeZone
in interface WindowTimerService<W>
public long currentProcessingTime()
WindowTimerService
currentProcessingTime
in interface WindowTimerService<W>
public long currentWatermark()
WindowTimerService
currentWatermark
in interface WindowTimerService<W>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.