Package | Description |
---|---|
org.apache.flink.table.descriptors | |
org.apache.flink.table.sources | |
org.apache.flink.table.sources.wmstrategies |
Class and Description |
---|
WatermarkStrategy
Provides a strategy to generate watermarks for a rowtime attribute.
|
Class and Description |
---|
WatermarkStrategy
Provides a strategy to generate watermarks for a rowtime attribute.
|
Class and Description |
---|
PeriodicWatermarkAssigner
A periodic watermark assigner.
|
PreserveWatermarks
A strategy which indicates the watermarks should be preserved from the underlying datastream.
|
WatermarkStrategy
Provides a strategy to generate watermarks for a rowtime attribute.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.