Uses of Class
org.apache.flink.table.runtime.operators.join.stream.utils.OuterRecord
-
Packages that use OuterRecord Package Description org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state org.apache.flink.table.runtime.operators.join.stream.utils -
-
Uses of OuterRecord in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state
Methods in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state that return types with arguments of type OuterRecord Modifier and Type Method Description org.apache.flink.api.common.state.v2.StateFuture<List<OuterRecord>>JoinRecordAsyncStateView. findMatchedRecords(Function<org.apache.flink.table.data.RowData,Boolean> condition)Find all the records matched the condition under the current context (i.e. join key).default org.apache.flink.api.common.state.v2.StateFuture<List<OuterRecord>>OuterJoinRecordAsyncStateView. findMatchedRecords(Function<org.apache.flink.table.data.RowData,Boolean> condition)org.apache.flink.api.common.state.v2.StateFuture<List<OuterRecord>>OuterJoinRecordAsyncStateView. findMatchedRecordsAndNumOfAssociations(Function<org.apache.flink.table.data.RowData,Boolean> condition)Find all the records matched the condition and the corresponding number of associations under the current context (i.e. join key). -
Uses of OuterRecord in org.apache.flink.table.runtime.operators.join.stream.utils
Methods in org.apache.flink.table.runtime.operators.join.stream.utils that return types with arguments of type OuterRecord Modifier and Type Method Description Iterable<OuterRecord>AssociatedRecords. getOuterRecords()Gets the iterable ofOuterRecordwhich composites record and numOfAssociations.
-