public interface OuterJoinRecordStateView extends JoinRecordStateView
OuterJoinRecordStateView
is an extension to JoinRecordStateView
.
The OuterJoinRecordStateView
is 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.
JoinRecordStateView
Modifier and Type | Method and Description |
---|---|
void |
addRecord(BaseRow record,
int numOfAssociations)
Adds a new record with the number of associations to the state view.
|
Iterable<Tuple2<BaseRow,Integer>> |
getRecordsAndNumOfAssociations()
Gets all the records and number of associations under the current context (i.e.
|
void |
updateNumOfAssociations(BaseRow record,
int numOfAssociations)
Updates the number of associations belongs to the record.
|
addRecord, getRecords, retractRecord
void addRecord(BaseRow record, int numOfAssociations) throws Exception
record
- the added recordnumOfAssociations
- the number of records associated with other sideException
void updateNumOfAssociations(BaseRow record, int numOfAssociations) throws Exception
record
- the record to updatenumOfAssociations
- the new number of records associated with other sideException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.