TimestampsAndWatermarksOperator.WatermarkEmitter (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.streaming.runtime.operators.TimestampsAndWatermarksOperator.WatermarkEmitter

All Implemented Interfaces:

WatermarkOutput

Enclosing class:

TimestampsAndWatermarksOperator<T>
```
public static final class TimestampsAndWatermarksOperator.WatermarkEmitter
extends Object
implements WatermarkOutput
```
Implementation of the WatermarkEmitter, based on the components that are available inside a stream operator.

Constructor Summary

Constructors
Constructor Description

WatermarkEmitter(Output<?> output)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`emitWatermark(Watermark watermark)`	Emits the given watermark.
`void`	`markActive()`	Marks this output as active, meaning that downstream operations should wait for watermarks from this output.
`void`	`markIdle()`	Marks this output as idle, meaning that downstream operations do not wait for watermarks from this output.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - WatermarkEmitter
```
public WatermarkEmitter(Output<?> output)
```
- Method Detail
  - emitWatermark
```
public void emitWatermark(Watermark watermark)
```
    Description copied from interface: WatermarkOutput
    
    Emits the given watermark.
    Emitting a watermark also implicitly marks the stream as active, ending previously marked idleness.
    
    Specified by:
    
    emitWatermark in interface WatermarkOutput
  - markIdle
```
public void markIdle()
```
    Description copied from interface: WatermarkOutput
    
    Marks this output as idle, meaning that downstream operations do not wait for watermarks from this output.
    An output becomes active again as soon as the next watermark is emitted or WatermarkOutput.markActive() is explicitly called.
    
    Specified by:
    
    markIdle in interface WatermarkOutput
  - markActive
```
public void markActive()
```
    Description copied from interface: WatermarkOutput
    
    Marks this output as active, meaning that downstream operations should wait for watermarks from this output.
    
    Specified by:
    
    markActive in interface WatermarkOutput