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