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

Interface AsyncCollectionResult<T>

Type Parameters:

T - Type of the collection elements.

All Superinterfaces:

AsyncResult

All Known Implementing Classes:

StreamRecordQueueEntry

@Internal
public interface AsyncCollectionResult<T>
extends AsyncResult

AsyncResult sub class for asynchronous result collections.

Method Summary

Modifier and Type	Method and Description
Collection<T>	get() Return the asynchronous result collection.
long	getTimestamp()
boolean	hasTimestamp()

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

asResultCollection, asWatermark, isResultCollection, isWatermark

Method Detail

hasTimestamp

boolean hasTimestamp()

getTimestamp

long getTimestamp()

get

Collection<T> get()
           throws Exception

Return the asynchronous result collection.

Returns:

the asynchronous result collection

Throws:

Exception - if the asynchronous result collection could not be completed