Uses of Interface
org.apache.flink.api.common.eventtime.WatermarkGenerator

Packages that use WatermarkGenerator

Package	Description
org.apache.flink.api.common.eventtime
org.apache.flink.streaming.api.operators.source
org.apache.flink.streaming.connectors.kafka.internals
org.apache.flink.streaming.runtime.operators.util
org.apache.flink.table.runtime.generated

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

Classes in org.apache.flink.api.common.eventtime that implement WatermarkGenerator

Modifier and Type	Class and Description
class	AscendingTimestampsWatermarks<T> A watermark generator that assumes monotonically ascending timestamps within the stream split and periodically generates watermarks based on that assumption.
class	BoundedOutOfOrdernessWatermarks<T> A WatermarkGenerator for situations where records are out of order, but you can place an upper bound on how far the events are out of order.
class	NoWatermarksGenerator<E> An implementation of a WatermarkGenerator that generates no Watermarks.
class	WatermarksWithIdleness<T> A WatermarkGenerator that adds idleness detection to another WatermarkGenerator.

Methods in org.apache.flink.api.common.eventtime that return WatermarkGenerator

Modifier and Type	Method and Description
WatermarkGenerator<T>	WatermarkStrategy.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) Instantiates a WatermarkGenerator that generates watermarks according to this strategy.
WatermarkGenerator<T>	WatermarkGeneratorSupplier.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) Instantiates a WatermarkGenerator.

Constructors in org.apache.flink.api.common.eventtime with parameters of type WatermarkGenerator

Constructor and Description
WatermarksWithIdleness(WatermarkGenerator<T> watermarks, java.time.Duration idleTimeout) Creates a new WatermarksWithIdleness generator to the given generator idleness detection with the given timeout.

Uses of WatermarkGenerator in org.apache.flink.streaming.api.operators.source

Methods in org.apache.flink.streaming.api.operators.source with parameters of type WatermarkGenerator

Modifier and Type

Method and Description

static <E> SourceOutputWithWatermarks<E>

SourceOutputWithWatermarks.createWithSeparateOutputs(PushingAsyncDataInput.DataOutput<E> recordsOutput, WatermarkOutput onEventWatermarkOutput, WatermarkOutput periodicWatermarkOutput, TimestampAssigner<E> timestampAssigner, WatermarkGenerator<E> watermarkGenerator) Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and watermarks to the different WatermarkOutputs.

Constructors in org.apache.flink.streaming.api.operators.source with parameters of type WatermarkGenerator

Constructor and Description
SourceOutputWithWatermarks(PushingAsyncDataInput.DataOutput<T> recordsOutput, WatermarkOutput onEventWatermarkOutput, WatermarkOutput periodicWatermarkOutput, TimestampAssigner<T> timestampAssigner, WatermarkGenerator<T> watermarkGenerator) Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and watermarks to the (possibly different) WatermarkOutput.

Uses of WatermarkGenerator in org.apache.flink.streaming.connectors.kafka.internals

Constructors in org.apache.flink.streaming.connectors.kafka.internals with parameters of type WatermarkGenerator

Constructor and Description
KafkaTopicPartitionStateWithWatermarkGenerator(KafkaTopicPartition partition, KPH kafkaPartitionHandle, TimestampAssigner<T> timestampAssigner, WatermarkGenerator<T> watermarkGenerator, WatermarkOutput immediateOutput, WatermarkOutput deferredOutput)

Uses of WatermarkGenerator in org.apache.flink.streaming.runtime.operators.util

Classes in org.apache.flink.streaming.runtime.operators.util that implement WatermarkGenerator

Modifier and Type	Class and Description
class	AssignerWithPeriodicWatermarksAdapter<T> An adapter that wraps a AssignerWithPeriodicWatermarks into a WatermarkGenerator.
class	AssignerWithPunctuatedWatermarksAdapter<T> An adapter that wraps a AssignerWithPunctuatedWatermarks into a WatermarkGenerator.

Methods in org.apache.flink.streaming.runtime.operators.util that return WatermarkGenerator

Modifier and Type	Method and Description
WatermarkGenerator<T>	AssignerWithPunctuatedWatermarksAdapter.Strategy.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)
WatermarkGenerator<T>	AssignerWithPeriodicWatermarksAdapter.Strategy.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)

Uses of WatermarkGenerator in org.apache.flink.table.runtime.generated

Classes in org.apache.flink.table.runtime.generated that implement WatermarkGenerator

Modifier and Type	Class and Description
static class	GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator Wrapper of the code-generated WatermarkGenerator.

Methods in org.apache.flink.table.runtime.generated that return WatermarkGenerator

Modifier and Type	Method and Description
WatermarkGenerator<RowData>	GeneratedWatermarkGeneratorSupplier.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)