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

Class Summary

Class	Description
AsyncDeltaJoinRunner	The async join runner to look up the dimension table in delta join.
AsyncDeltaJoinRunner.JoinedRowResultFuture	The AsyncDeltaJoinRunner.JoinedRowResultFuture is used to combine left RowData and right RowData into JoinedRowData.
StreamingDeltaJoinOperator	This operator supports delta join in table layer.
StreamingDeltaJoinOperator.InputIndexAwareStreamRecordQueueEntry	A StreamElementQueueEntry with the input index.