WindowTimerServiceBase (Flink : Table : Runtime 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.table.runtime.operators.window.tvf.common.WindowTimerServiceBase<W>

All Implemented Interfaces:

WindowTimerService<W>

Direct Known Subclasses:

SlicingWindowTimerServiceImpl, UnslicingWindowTimerServiceImpl
```
public abstract class WindowTimerServiceBase<W>
extends Object
implements WindowTimerService<W>
```
A base implement of WindowTimerService.

Field Summary

Fields
Modifier and Type Field Description

protected org.apache.flink.streaming.api.operators.InternalTimerService<W> internalTimerService

protected java.time.ZoneId shiftTimeZone

Constructor Summary

Constructors
Constructor	Description
`WindowTimerServiceBase(org.apache.flink.streaming.api.operators.InternalTimerService<W> internalTimerService, java.time.ZoneId shiftTimeZone)`

Method Summary

All Methods Instance Methods Concrete Methods
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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.WindowTimerService
registerEventTimeWindowTimer, registerProcessingTimeWindowTimer

- Field Detail
  - internalTimerService
```
protected final org.apache.flink.streaming.api.operators.InternalTimerService<W> internalTimerService
```
  - shiftTimeZone
```
protected final java.time.ZoneId shiftTimeZone
```
- Constructor Detail
  - WindowTimerServiceBase
```
public WindowTimerServiceBase(org.apache.flink.streaming.api.operators.InternalTimerService<W> 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<W>
  - currentProcessingTime
```
public long currentProcessingTime()
```
    Description copied from interface: WindowTimerService
    
    Returns the current processing time.
    
    Specified by:
    
    currentProcessingTime in interface WindowTimerService<W>
  - currentWatermark
```
public long currentWatermark()
```
    Description copied from interface: WindowTimerService
    
    Returns the current event-time watermark.
    
    Specified by:
    
    currentWatermark in interface WindowTimerService<W>