Uses of Interface
org.apache.flink.streaming.api.functions.async.ResultFuture

Packages that use ResultFuture

Package	Description
org.apache.flink.streaming.api.functions.async
org.apache.flink.streaming.api.operators.async.queue

Uses of ResultFuture in org.apache.flink.streaming.api.functions.async

Methods in org.apache.flink.streaming.api.functions.async with parameters of type ResultFuture

Modifier and Type	Method	Description
void	AsyncFunction.asyncInvoke(IN input, ResultFuture<OUT> resultFuture)	Trigger async operation for each stream input.
abstract void	RichAsyncFunction.asyncInvoke(IN input, ResultFuture<OUT> resultFuture)
default void	AsyncFunction.timeout(IN input, ResultFuture<OUT> resultFuture)	AsyncFunction.asyncInvoke(IN, org.apache.flink.streaming.api.functions.async.ResultFuture<OUT>) timeout occurred.

Uses of ResultFuture in org.apache.flink.streaming.api.operators.async.queue

Subinterfaces of ResultFuture in org.apache.flink.streaming.api.operators.async.queue

Modifier and Type	Interface	Description
interface	StreamElementQueueEntry<OUT>	An entry for the StreamElementQueue.

Classes in org.apache.flink.streaming.api.operators.async.queue that implement ResultFuture

Modifier and Type	Class	Description
class	StreamRecordQueueEntry<OUT>	StreamElementQueueEntry implementation for StreamRecord.

Methods in org.apache.flink.streaming.api.operators.async.queue that return types with arguments of type ResultFuture

Modifier and Type	Method	Description
Optional<ResultFuture<OUT>>	OrderedStreamElementQueue.tryPut(org.apache.flink.streaming.runtime.streamrecord.StreamElement streamElement)
Optional<ResultFuture<OUT>>	StreamElementQueue.tryPut(org.apache.flink.streaming.runtime.streamrecord.StreamElement streamElement)	Tries to put the given element in the queue.
Optional<ResultFuture<OUT>>	UnorderedStreamElementQueue.tryPut(org.apache.flink.streaming.runtime.streamrecord.StreamElement streamElement)