org.apache.flink.streaming.api.operators.async.queue

Class WatermarkQueueEntry

java.lang.Object

org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<Watermark>

org.apache.flink.streaming.api.operators.async.queue.WatermarkQueueEntry

All Implemented Interfaces:

AsyncResult, AsyncWatermarkResult

@Internal
public class WatermarkQueueEntry
extends StreamElementQueueEntry<Watermark>
implements AsyncWatermarkResult

StreamElementQueueEntry implementation for the Watermark.

Constructor Summary

Constructors

Constructor and Description
WatermarkQueueEntry(Watermark watermark)

Method Summary

Modifier and Type	Method and Description
protected CompletableFuture<Watermark>	getFuture()
Watermark	getWatermark() Get the resulting watermark.

Methods inherited from class org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry

asResultCollection, asWatermark, getStreamElement, isDone, isResultCollection, isWatermark, onComplete

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.operators.async.queue.AsyncResult

asResultCollection, asWatermark, isResultCollection, isWatermark

Constructor Detail

WatermarkQueueEntry

public WatermarkQueueEntry(Watermark watermark)

Method Detail

getWatermark

public Watermark getWatermark()

Description copied from interface: AsyncWatermarkResult

Get the resulting watermark.

Specified by:

getWatermark in interface AsyncWatermarkResult

Returns:

the asynchronous result watermark

getFuture

protected CompletableFuture<Watermark> getFuture()

Specified by:

getFuture in class StreamElementQueueEntry<Watermark>