org.apache.flink.streaming.runtime.operators.util

Class AssignerWithPeriodicWatermarksAdapter<T>

java.lang.Object

org.apache.flink.streaming.runtime.operators.util.AssignerWithPeriodicWatermarksAdapter<T>

All Implemented Interfaces:

WatermarkGenerator<T>

@Internal
public final class AssignerWithPeriodicWatermarksAdapter<T>
extends Object
implements WatermarkGenerator<T>

An adapter that wraps a AssignerWithPeriodicWatermarks into a WatermarkGenerator.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AssignerWithPeriodicWatermarksAdapter.Strategy<T> A WatermarkStrategy that returns an AssignerWithPeriodicWatermarks wrapped as a WatermarkGenerator.

Constructor Summary

Constructors

Constructor and Description
AssignerWithPeriodicWatermarksAdapter(AssignerWithPeriodicWatermarks<T> wms)

Method Summary

Modifier and Type	Method and Description
void	onEvent(T event, long eventTimestamp, WatermarkOutput output) Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.
void	onPeriodicEmit(WatermarkOutput output) Called periodically, and might emit a new watermark, or not.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AssignerWithPeriodicWatermarksAdapter

public AssignerWithPeriodicWatermarksAdapter(AssignerWithPeriodicWatermarks<T> wms)

Method Detail

onEvent

public void onEvent(T event,
                    long eventTimestamp,
                    WatermarkOutput output)

Description copied from interface: WatermarkGenerator

Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.

Specified by:

onEvent in interface WatermarkGenerator<T>

onPeriodicEmit

public void onPeriodicEmit(WatermarkOutput output)

Description copied from interface: WatermarkGenerator

Called periodically, and might emit a new watermark, or not.

The interval in which this method is called and Watermarks are generated depends on ExecutionConfig.getAutoWatermarkInterval().

Specified by:

onPeriodicEmit in interface WatermarkGenerator<T>