DelegatingResultFuture (Flink : Table : Runtime 1.19.2-cp2 API)

java.lang.Object
- org.apache.flink.table.runtime.operators.join.lookup.DelegatingResultFuture<OUT>

All Implemented Interfaces:

java.util.function.BiConsumer<Collection<OUT>,Throwable>
```
public class DelegatingResultFuture<OUT>
extends Object
implements java.util.function.BiConsumer<Collection<OUT>,Throwable>
```
Delegates actions of CompletableFuture to ResultFuture. This is used as a bridge between AsyncTableFunction and AsyncFunction.

Constructor Summary

Constructors
Constructor Description

DelegatingResultFuture(org.apache.flink.streaming.api.functions.async.ResultFuture<OUT> delegatedResultFuture)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`accept(Collection<OUT> outs, Throwable throwable)`
`CompletableFuture<Collection<OUT>>`	`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

DelegatingResultFuture

public DelegatingResultFuture(org.apache.flink.streaming.api.functions.async.ResultFuture<OUT> delegatedResultFuture)

Method Detail

accept

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

Specified by:: accept in interface java.util.function.BiConsumer<Collection<OUT>,Throwable>

getCompletableFuture

public CompletableFuture<Collection<OUT>> getCompletableFuture()