Package | Description |
---|---|
org.apache.flink.api.common.eventtime | |
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 | Class and Description |
---|---|
static class |
TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T>
We need an actual class.
|
Modifier and Type | Method and Description |
---|---|
static <T> TimestampAssignerSupplier<T> |
TimestampAssignerSupplier.of(SerializableTimestampAssigner<T> assigner) |
Modifier and Type | Method and Description |
---|---|
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 ). |
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–2023 The Apache Software Foundation. All rights reserved.