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

Class Summary

Class	Description
AbstractStreamingJoinOperator	Abstract implementation for streaming unbounded Join operator which defines some member fields can be shared between different implementations.
AbstractStreamingJoinOperator.AssociatedRecords	The AbstractStreamingJoinOperator.AssociatedRecords is the records associated to the input row.
AbstractStreamingJoinOperator.OuterRecord	An AbstractStreamingJoinOperator.OuterRecord is a composite of record and numOfAssociations.
MiniBatchStreamingJoinOperator	Streaming unbounded Join base operator which support mini-batch join.
StreamingJoinOperator	Streaming unbounded Join operator which supports INNER/LEFT/RIGHT/FULL JOIN.
StreamingSemiAntiJoinOperator	Streaming unbounded Join operator which supports SEMI/ANTI JOIN.