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

Class DelegatingAsyncResultFuture

java.lang.Object

org.apache.flink.table.runtime.operators.calc.async.DelegatingAsyncResultFuture

All Implemented Interfaces:

BiConsumer<Object,Throwable>

public class DelegatingAsyncResultFuture
extends Object
implements BiConsumer<Object,Throwable>

Inspired by DelegatingResultFuture for AsyncScalarFunction.

Constructor Summary

Constructors

Constructor	Description
DelegatingAsyncResultFuture(org.apache.flink.streaming.api.functions.async.ResultFuture<Object> delegatedResultFuture, int totalResultSize)

Method Summary

Modifier and Type	Method	Description
void	accept(Object o, Throwable throwable)
void	addAsyncIndex(int resultIndex)
void	addSynchronousResult(int resultIndex, Object object)
CompletableFuture<?>	createAsyncFuture(DataStructureConverter<Object,Object> converter)
void	setRowKind(org.apache.flink.types.RowKind rowKind)

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

DelegatingAsyncResultFuture

public DelegatingAsyncResultFuture(org.apache.flink.streaming.api.functions.async.ResultFuture<Object> delegatedResultFuture,
                                   int totalResultSize)

Method Detail

setRowKind

public void setRowKind(org.apache.flink.types.RowKind rowKind)

addSynchronousResult

public void addSynchronousResult(int resultIndex,
                                 Object object)

addAsyncIndex

public void addAsyncIndex(int resultIndex)

createAsyncFuture

public CompletableFuture<?> createAsyncFuture(DataStructureConverter<Object,Object> converter)

accept

public void accept(Object o,
                   Throwable throwable)

Specified by:

accept in interface BiConsumer<Object,Throwable>