Class AbstractStreamingJoinOperator.OuterRecord
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.join.stream.AbstractStreamingJoinOperator.OuterRecord
-
- Enclosing class:
- AbstractStreamingJoinOperator
protected static final class AbstractStreamingJoinOperator.OuterRecord extends Object
AnAbstractStreamingJoinOperator.OuterRecordis a composite of record andnumOfAssociations. ThenumOfAssociationsrepresents the number of associated records in the other side. It is used when the record is from outer side (e.g. left side in LEFT OUTER JOIN). When thenumOfAssociationsis ZERO, we need to send a null padding row. This is useful to avoid recompute the associated numbers every time.When the record is from inner side (e.g. right side in LEFT OUTER JOIN), the
numOfAssociationswill always be-1.