org.apache.flink.api.common.eventtime

Class NoWatermarksGenerator<E>

java.lang.Object

org.apache.flink.api.common.eventtime.NoWatermarksGenerator<E>

All Implemented Interfaces:

WatermarkGenerator<E>

@Public
public final class NoWatermarksGenerator<E>
extends Object
implements WatermarkGenerator<E>

An implementation of a WatermarkGenerator that generates no Watermarks.

Constructor Summary

Constructors

Constructor and Description
NoWatermarksGenerator()

Method Summary

Modifier and Type	Method and Description
void	onEvent(E 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

NoWatermarksGenerator

public NoWatermarksGenerator()

Method Detail

onEvent

public void onEvent(E 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<E>

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<E>