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

Class Summary

Class	Description
AecRecord<IN,OUT>	The record used in TableAsyncExecutionController to contain info about Epoch.
Epoch<OUT>	All inputs are segment into distinct epochs, marked by the arrival of non-record inputs.
EpochManager<OUT>	Epoch manager segments inputs into distinct epochs, marked by the arrival of non-records(e.g.
KeyAccountingUnit<K>	Key accounting unit holds the current in-flight key and tracks the corresponding ongoing records.
RecordsBuffer<ELEMENT,KEY>	The RecordsBuffer is used to store the element that need to be processed in TableAsyncExecutionController.
TableAsyncExecutionController<IN,OUT,KEY>	The TableAsyncExecutionController is used to keep key ordered process mode for async operator.