protected static final class AbstractStreamingJoinOperator.OuterRecord extends Object
AbstractStreamingJoinOperator.OuterRecord
is a composite of record and numOfAssociations
. The
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 -1
.
public final BaseRow record
public final int numOfAssociations
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.