Package | Description |
---|---|
org.apache.flink.streaming.api.operators.source |
Modifier and Type | Class and Description |
---|---|
class |
NoOpTimestampsAndWatermarks<T>
An implementation of
TimestampsAndWatermarks where all watermarking/event-time operations
are no-ops. |
class |
ProgressiveTimestampsAndWatermarks<T>
An implementation of
TimestampsAndWatermarks that does periodic watermark emission and
keeps track of watermarks on a per-split basis. |
Modifier and Type | Method and Description |
---|---|
static <E> TimestampsAndWatermarks<E> |
TimestampsAndWatermarks.createNoOpEventTimeLogic(WatermarkStrategy<E> watermarkStrategy,
MetricGroup metrics) |
static <E> TimestampsAndWatermarks<E> |
TimestampsAndWatermarks.createProgressiveEventTimeLogic(WatermarkStrategy<E> watermarkStrategy,
MetricGroup metrics,
ProcessingTimeService timeService,
long periodicWatermarkIntervalMillis) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.