Uses of Class
org.apache.flink.table.runtime.collector.TableFunctionResultFuture

Packages that use TableFunctionResultFuture

Package	Description
org.apache.flink.table.runtime.operators.join.deltajoin
org.apache.flink.table.runtime.operators.join.lookup

Uses of TableFunctionResultFuture in org.apache.flink.table.runtime.operators.join.deltajoin

Methods in org.apache.flink.table.runtime.operators.join.deltajoin that return TableFunctionResultFuture

Modifier and Type	Method	Description
TableFunctionResultFuture<org.apache.flink.table.data.RowData>	AsyncDeltaJoinRunner.createFetcherResultFuture(org.apache.flink.api.common.functions.OpenContext openContext)

Constructor parameters in org.apache.flink.table.runtime.operators.join.deltajoin with type arguments of type TableFunctionResultFuture

Constructor

Description

AsyncDeltaJoinRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, RowDataSerializer lookupSideRowSerializer, int asyncBufferCapacity, boolean treatRightAsLookupTable)

Uses of TableFunctionResultFuture in org.apache.flink.table.runtime.operators.join.lookup

Methods in org.apache.flink.table.runtime.operators.join.lookup that return TableFunctionResultFuture

Modifier and Type	Method	Description
TableFunctionResultFuture<org.apache.flink.table.data.RowData>	AsyncLookupJoinRunner.createFetcherResultFuture(org.apache.flink.configuration.Configuration parameters)
TableFunctionResultFuture<org.apache.flink.table.data.RowData>	AsyncLookupJoinWithCalcRunner.createFetcherResultFuture(org.apache.flink.configuration.Configuration parameters)

Constructor parameters in org.apache.flink.table.runtime.operators.join.lookup with type arguments of type TableFunctionResultFuture

Constructor	Description
AsyncLookupJoinRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)