Package | Description |
---|---|
org.apache.flink.table.descriptors | |
org.apache.flink.table.sources | |
org.apache.flink.table.sources.wmstrategies |
Modifier and Type | Method and Description |
---|---|
static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>> |
RowtimeValidator.getRowtimeComponents(DescriptorProperties properties,
String prefix)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Rowtime |
Rowtime.watermarksFromStrategy(WatermarkStrategy strategy)
Deprecated.
Sets a custom watermark strategy to be used for the rowtime attribute.
|
Modifier and Type | Method and Description |
---|---|
WatermarkStrategy |
RowtimeAttributeDescriptor.getWatermarkStrategy()
Deprecated.
Returns the [[WatermarkStrategy]] for the attribute.
|
Constructor and Description |
---|
RowtimeAttributeDescriptor(String attributeName,
TimestampExtractor timestampExtractor,
WatermarkStrategy watermarkStrategy)
Deprecated.
|
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.
|
class |
PeriodicWatermarkAssigner
A periodic watermark assigner.
|
class |
PreserveWatermarks
A strategy which indicates the watermarks should be preserved from the underlying datastream.
|
class |
PunctuatedWatermarkAssigner
A punctuated watermark assigner.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.