Package org.apache.flink.table.runtime.operators.correlate.async

Class DelegatingAsyncTableResultFuture

java.lang.Object

org.apache.flink.table.runtime.operators.correlate.async.DelegatingAsyncTableResultFuture

All Implemented Interfaces:

BiConsumer<Collection<Object>,Throwable>

public class DelegatingAsyncTableResultFuture
extends Object
implements BiConsumer<Collection<Object>,Throwable>

Delegates actions of CompletableFuture to ResultFuture. This is used as a bridge between AsyncTableFunction and AsyncFunction.

Constructor Summary

Constructors

Constructor	Description
DelegatingAsyncTableResultFuture(org.apache.flink.streaming.api.functions.async.ResultFuture<Object> delegatedResultFuture, boolean needsWrapping, boolean isInternalResultType)

Method Summary

Modifier and Type	Method	Description
void	accept(Collection<Object> outs, Throwable throwable)
CompletableFuture<Collection<Object>>	getCompletableFuture()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.BiConsumer

andThen

Constructor Detail

DelegatingAsyncTableResultFuture

public DelegatingAsyncTableResultFuture(org.apache.flink.streaming.api.functions.async.ResultFuture<Object> delegatedResultFuture,
                                        boolean needsWrapping,
                                        boolean isInternalResultType)

Method Detail

accept

public void accept(Collection<Object> outs,
                   Throwable throwable)

Specified by:

accept in interface BiConsumer<Collection<Object>,Throwable>

getCompletableFuture

public CompletableFuture<Collection<Object>> getCompletableFuture()