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

Interface AsyncWatermarkResult

All Superinterfaces:

AsyncResult

All Known Implementing Classes:

WatermarkQueueEntry

@Internal
public interface AsyncWatermarkResult
extends AsyncResult

AsyncResult subclass for asynchronous result Watermark.

Method Summary

Modifier and Type	Method and Description
Watermark	getWatermark() Get the resulting watermark.

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

asResultCollection, asWatermark, isResultCollection, isWatermark

Method Detail

getWatermark

Watermark getWatermark()

Get the resulting watermark.

Returns:

the asynchronous result watermark