Package | Description |
---|---|
org.apache.flink.api.common.eventtime | |
org.apache.flink.streaming.api.operators.source | |
org.apache.flink.streaming.runtime.operators.util |
Modifier and Type | Interface and Description |
---|---|
interface |
WatermarkStrategy<T>
The WatermarkStrategy defines how to generate
Watermark s in the stream sources. |
Modifier and Type | Method and Description |
---|---|
static <T> WatermarkStrategy<T> |
WatermarkStrategy.forGenerator(WatermarkGeneratorSupplier<T> generatorSupplier)
Creates a watermark strategy based on an existing
WatermarkGeneratorSupplier . |
Constructor and Description |
---|
ProgressiveTimestampsAndWatermarks(TimestampAssigner<T> timestampAssigner,
WatermarkGeneratorSupplier<T> watermarksFactory,
WatermarkGeneratorSupplier.Context watermarksContext,
ProcessingTimeService timeService,
java.time.Duration periodicWatermarkInterval) |
Modifier and Type | Class and Description |
---|---|
static class |
AssignerWithPeriodicWatermarksAdapter.Strategy<T>
A WatermarkStrategy that returns an
AssignerWithPeriodicWatermarks wrapped as a
WatermarkGenerator . |
static class |
AssignerWithPunctuatedWatermarksAdapter.Strategy<T>
A WatermarkStrategy that returns an
AssignerWithPunctuatedWatermarks wrapped as a
WatermarkGenerator . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.