NoWatermarksGenerator (Flink : Core 1.20.2-cp1 API)

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 Description

NoWatermarksGenerator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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>