Package | Description |
---|---|
org.apache.flink.table.runtime.operators.wmassigners | |
org.apache.flink.table.sources.wmstrategies |
Constructor and Description |
---|
PeriodicWatermarkAssignerWrapper(PeriodicWatermarkAssigner assigner,
int timeFieldIdx) |
Modifier and Type | Class and Description |
---|---|
class |
AscendingTimestamps
A watermark strategy for ascending rowtime attributes.
|
class |
BoundedOutOfOrderTimestamps
A watermark strategy for rowtime attributes which are out-of-order by a bounded time interval.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.