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

Class AsyncDeltaJoinRunner

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.async.RichAsyncFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

org.apache.flink.table.runtime.operators.join.deltajoin.AsyncDeltaJoinRunner

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

public class AsyncDeltaJoinRunner
extends org.apache.flink.streaming.api.functions.async.RichAsyncFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

The async join runner to look up the dimension table in delta join.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncDeltaJoinRunner.JoinedRowResultFuture	The AsyncDeltaJoinRunner.JoinedRowResultFuture is used to combine left RowData and right RowData into JoinedRowData.

Field Summary

Fields

Modifier and Type	Field	Description
protected RowDataSerializer	lookupSideRowSerializer

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method	Description
void	asyncInvoke(org.apache.flink.table.data.RowData input, org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData> resultFuture)
void	close()
TableFunctionResultFuture<org.apache.flink.table.data.RowData>	createFetcherResultFuture(org.apache.flink.api.common.functions.OpenContext openContext)
org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>	getFetcher()
void	open(org.apache.flink.api.common.functions.OpenContext openContext)

Methods inherited from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction

setRuntimeContext

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.functions.async.AsyncFunction

timeout

Field Detail

lookupSideRowSerializer

protected final RowDataSerializer lookupSideRowSerializer

Constructor Detail

AsyncDeltaJoinRunner

public 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)

Method Detail

open

public void open(org.apache.flink.api.common.functions.OpenContext openContext)
          throws Exception

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception

asyncInvoke

public void asyncInvoke(org.apache.flink.table.data.RowData input,
                        org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData> resultFuture)
                 throws Exception

Specified by:

asyncInvoke in interface org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

Specified by:

asyncInvoke in class org.apache.flink.streaming.api.functions.async.RichAsyncFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

Throws:

Exception

createFetcherResultFuture

public TableFunctionResultFuture<org.apache.flink.table.data.RowData> createFetcherResultFuture(org.apache.flink.api.common.functions.OpenContext openContext)
                                                                                         throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

close in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception

getFetcher

@VisibleForTesting
public org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object> getFetcher()