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.
DeltaJoinCache	Cache for both sides in delta join.
StreamingDeltaJoinOperator	This operator supports delta join in table layer.
StreamingDeltaJoinOperator.InputIndexAwareStreamRecordQueueEntry	A StreamElementQueueEntry with the input index.