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

Interface AsyncResult

All Known Subinterfaces:

AsyncCollectionResult<T>, AsyncWatermarkResult

All Known Implementing Classes:

StreamElementQueueEntry, StreamRecordQueueEntry, WatermarkQueueEntry

@Internal
public interface AsyncResult

Asynchronous result returned by the StreamElementQueue. The asynchronous result can either be a Watermark or a collection of new output elements produced by the AsyncFunction.

Method Summary

Modifier and Type	Method and Description
<T> AsyncCollectionResult<T>	asResultCollection() Return this async result as a async result collection.
AsyncWatermarkResult	asWatermark() Return this async result as a async watermark result.
boolean	isResultCollection() True fi the async result is a collection of output elements; otherwise false.
boolean	isWatermark() True if the async result is a Watermark; otherwise false.

Method Detail

isWatermark

boolean isWatermark()

True if the async result is a Watermark; otherwise false.

Returns:

True if the async result is a Watermark; otherwise false.

isResultCollection

boolean isResultCollection()

True fi the async result is a collection of output elements; otherwise false.

Returns:

True if the async reuslt is a collection of output elements; otherwise false

asWatermark

AsyncWatermarkResult asWatermark()

Return this async result as a async watermark result.

Returns:

this result as a AsyncWatermarkResult.

asResultCollection

<T> AsyncCollectionResult<T> asResultCollection()

Return this async result as a async result collection.

Type Parameters:

T - Type of the result collection's elements

Returns:

this result as a AsyncCollectionResult.