Uses of Interface org.apache.flink.api.common.eventtime.WatermarkStrategy (Flink : Core 1.18.1-cp1 API)

Packages that use WatermarkStrategy
Package Description

org.apache.flink.api.common.eventtime

Uses of WatermarkStrategy in org.apache.flink.api.common.eventtime

Methods in org.apache.flink.api.common.eventtime that return WatermarkStrategy
Modifier and Type	Method	Description
`static <T> WatermarkStrategy<T>`	WatermarkStrategy.`forBoundedOutOfOrderness(java.time.Duration maxOutOfOrderness)`	Creates a watermark strategy for situations where records are out of order, but you can place an upper bound on how far the events are out of order.
`static <T> WatermarkStrategy<T>`	WatermarkStrategy.`forGenerator(WatermarkGeneratorSupplier<T> generatorSupplier)`	Creates a watermark strategy based on an existing `WatermarkGeneratorSupplier`.
`static <T> WatermarkStrategy<T>`	WatermarkStrategy.`forMonotonousTimestamps()`	Creates a watermark strategy for situations with monotonously ascending timestamps.
`static <T> WatermarkStrategy<T>`	WatermarkStrategy.`noWatermarks()`	Creates a watermark strategy that generates no watermarks at all.
`default WatermarkStrategy<T>`	WatermarkStrategy.`withIdleness(java.time.Duration idleTimeout)`	Creates a new enriched `WatermarkStrategy` that also does idleness detection in the created `WatermarkGenerator`.
`default WatermarkStrategy<T>`	WatermarkStrategy.`withTimestampAssigner(SerializableTimestampAssigner<T> timestampAssigner)`	Creates a new `WatermarkStrategy` that wraps this strategy but instead uses the given `SerializableTimestampAssigner`.
`default WatermarkStrategy<T>`	WatermarkStrategy.`withTimestampAssigner(TimestampAssignerSupplier<T> timestampAssigner)`	Creates a new `WatermarkStrategy` that wraps this strategy but instead uses the given `TimestampAssigner` (via a `TimestampAssignerSupplier`).
`default WatermarkStrategy<T>`	WatermarkStrategy.`withWatermarkAlignment(String watermarkGroup, java.time.Duration maxAllowedWatermarkDrift)`	Creates a new `WatermarkStrategy` that configures the maximum watermark drift from other sources/tasks/partitions in the same watermark group.
`default WatermarkStrategy<T>`	WatermarkStrategy.`withWatermarkAlignment(String watermarkGroup, java.time.Duration maxAllowedWatermarkDrift, java.time.Duration updateInterval)`	Creates a new `WatermarkStrategy` that configures the maximum watermark drift from other sources/tasks/partitions in the same watermark group.