Uses of Class
org.apache.flink.table.sources.wmstrategies.WatermarkStrategy
-
-
Uses of WatermarkStrategy in org.apache.flink.legacy.table.descriptors
Methods in org.apache.flink.legacy.table.descriptors that return types with arguments of type WatermarkStrategy Modifier and Type Method Description static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>>
RowtimeValidator. getRowtimeComponents(DescriptorProperties properties, String prefix)
Deprecated. -
Uses of WatermarkStrategy in org.apache.flink.table.legacy.descriptors
Methods in org.apache.flink.table.legacy.descriptors with parameters of type WatermarkStrategy Modifier and Type Method Description Rowtime
Rowtime. watermarksFromStrategy(WatermarkStrategy strategy)
Deprecated.Sets a custom watermark strategy to be used for the rowtime attribute. -
Uses of WatermarkStrategy in org.apache.flink.table.legacy.sources
Methods in org.apache.flink.table.legacy.sources that return WatermarkStrategy Modifier and Type Method Description WatermarkStrategy
RowtimeAttributeDescriptor. getWatermarkStrategy()
Deprecated.Returns the [[WatermarkStrategy]] for the attribute.Constructors in org.apache.flink.table.legacy.sources with parameters of type WatermarkStrategy Constructor Description RowtimeAttributeDescriptor(String attributeName, TimestampExtractor timestampExtractor, WatermarkStrategy watermarkStrategy)
Deprecated. -
Uses of WatermarkStrategy in org.apache.flink.table.sources.wmstrategies
Subclasses of WatermarkStrategy in org.apache.flink.table.sources.wmstrategies Modifier and Type Class 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.
-