public interface OuterJoinRecordStateView extends JoinRecordStateView
OuterJoinRecordStateViewis an extension to
OuterJoinRecordStateViewis used to store records for the outer input side of the Join, e.g. the left side of left join, the both side of full join.
The additional information we should store with the record is the number of associations which is the number of records associated this record with other side. This is an important information when to send/retract a null padding row, to avoid recompute the associated numbers every time.
|Modifier and Type||Method and Description|
Adds a new record with the number of associations to the state view.
Gets all the records and number of associations under the current context (i.e.
Updates the number of associations belongs to the record.
addRecord, getRecords, retractRecord
void addRecord(RowData record, int numOfAssociations) throws Exception
record- the added record
numOfAssociations- the number of records associated with other side
void updateNumOfAssociations(RowData record, int numOfAssociations) throws Exception
record- the record to update
numOfAssociations- the new number of records associated with other side
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.