protected static final class AbstractStreamingJoinOperator.OuterRecord extends Object
AbstractStreamingJoinOperator.OuterRecord is a composite of record and
numOfAssociations represents 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 the
numOfAssociations is 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
numOfAssociations will always be
public final RowData record
public final int numOfAssociations
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.