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

Class Summary

Class	Description
AsyncLookupJoinRunner	The async join runner to lookup the dimension table.
AsyncLookupJoinWithCalcRunner	The async join runner with an additional calculate function on the dimension table.
CalcCollectionCollector	A Collector used to store data after calc function.
KeyedLookupJoinWrapper	The lookup join handler which holds a LookupJoinRunner to process lookup for insert or update_after record and directly process delete and update_before record via local state.
LookupJoinRunner	The join runner to lookup the dimension table.
LookupJoinWithCalcRunner	The join runner with an additional calculate function on the dimension table.
ResultRetryStrategy	A utility class to wrap the data stream api AsyncRetryStrategy to support both sync and async retry in table module.
RetryableAsyncLookupFunctionDelegator	A delegator holds user's AsyncLookupFunction to handle retries.
RetryableLookupFunctionDelegator	A delegator holds user's LookupFunction to handle retries.