public interface JoinRecordStateView
JoinRecordStateView
is a view to the join state. It encapsulates the join state and
provides some APIs facing the input records. The join state is used to store
input records. The structure of the join state is vary depending on the JoinInputSideSpec
.
For example: when the JoinInputSideSpec
is JoinKeyContainsUniqueKey, we will use
ValueState
to store records which has better performance.
Modifier and Type | Method and Description |
---|---|
void |
addRecord(BaseRow record)
Add a new record to the state view.
|
Iterable<BaseRow> |
getRecords()
Gets all the records under the current context (i.e.
|
void |
retractRecord(BaseRow record)
Retract the record from the state view.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.