Class 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>
    The AsyncDeltaJoinRunner.JoinedRowResultFuture is used to combine left RowData and right RowData into JoinedRowData.

    There are 3 phases in this collector similar with {@see AsyncLookupJoinRunner#JoinedRowResultFuture}. Furthermore, this AsyncDeltaJoinRunner.JoinedRowResultFuture also handles logic about bidirectional lookup join processing.

    • 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:
        complete in interface org.apache.flink.streaming.api.functions.async.ResultFuture<Object>
      • completeExceptionally

        public void completeExceptionally​(Throwable error)
        Specified by:
        completeExceptionally in interface org.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:
        complete in interface org.apache.flink.streaming.api.functions.async.ResultFuture<Object>