Class AsyncDeltaJoinRunner.JoinedRowResultFuture
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.join.deltajoin.AsyncDeltaJoinRunner.JoinedRowResultFuture
-
- All Implemented Interfaces:
org.apache.flink.streaming.api.functions.async.ResultFuture<Object>
- Enclosing class:
- AsyncDeltaJoinRunner
@VisibleForTesting public static final class AsyncDeltaJoinRunner.JoinedRowResultFuture extends Object implements org.apache.flink.streaming.api.functions.async.ResultFuture<Object>
TheAsyncDeltaJoinRunner.JoinedRowResultFutureis used to combine leftRowDataand rightRowDataintoJoinedRowData.There are 3 phases in this collector similar with {@see AsyncLookupJoinRunner#JoinedRowResultFuture}. Furthermore, this
AsyncDeltaJoinRunner.JoinedRowResultFuturealso handles logic about bidirectional lookup join processing.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidcomplete(Collection<Object> result)voidcomplete(org.apache.flink.streaming.api.functions.async.CollectionSupplier<Object> supplier)Unsupported, because the containing classes are AsyncFunctions which don't have access to the mailbox to invoke from the caller thread.voidcompleteExceptionally(Throwable error)voidreset(org.apache.flink.table.data.RowData row, org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData> realOutput)
-
-
-
Method Detail
-
reset
public void reset(org.apache.flink.table.data.RowData row, org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData> realOutput)
-
complete
public void complete(Collection<Object> result)
- Specified by:
completein interfaceorg.apache.flink.streaming.api.functions.async.ResultFuture<Object>
-
completeExceptionally
public void completeExceptionally(Throwable error)
- Specified by:
completeExceptionallyin interfaceorg.apache.flink.streaming.api.functions.async.ResultFuture<Object>
-
complete
public void complete(org.apache.flink.streaming.api.functions.async.CollectionSupplier<Object> supplier)
Unsupported, because the containing classes are AsyncFunctions which don't have access to the mailbox to invoke from the caller thread.- Specified by:
completein interfaceorg.apache.flink.streaming.api.functions.async.ResultFuture<Object>
-
-