Interface JoinRecordAsyncStateView
-
- All Known Subinterfaces:
OuterJoinRecordAsyncStateView
public interface JoinRecordAsyncStateView
AJoinRecordAsyncStateView
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 theJoinInputSideSpec
.For example: when the
JoinInputSideSpec
is JoinKeyContainsUniqueKey, we will useValueState
to store records which has better performance.Different with
JoinRecordStateView
, this interface is based on async state api.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StateFuture<Void>
addRecord(RowData record)
Add a new record to the state view.StateFuture<List<OuterRecord>>
findMatchedRecords(Function<RowData,Boolean> condition)
Find all the records matched the condition under the current context (i.e. join key).StateFuture<Void>
retractRecord(RowData record)
Retract the record from the state view.
-
-
-
Method Detail
-
addRecord
StateFuture<Void> addRecord(RowData record)
Add a new record to the state view.
-
retractRecord
StateFuture<Void> retractRecord(RowData record)
Retract the record from the state view.
-
findMatchedRecords
StateFuture<List<OuterRecord>> findMatchedRecords(Function<RowData,Boolean> condition)
Find all the records matched the condition under the current context (i.e. join key).
-
-