Uses of Interface
org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state.JoinRecordAsyncStateView
-
Packages that use JoinRecordAsyncStateView Package Description org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state org.apache.flink.table.runtime.operators.join.stream.utils -
-
Uses of JoinRecordAsyncStateView in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state
Subinterfaces of JoinRecordAsyncStateView in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state Modifier and Type Interface Description interfaceOuterJoinRecordAsyncStateViewAOuterJoinRecordAsyncStateViewis an extension toJoinRecordAsyncStateView.Methods in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state that return JoinRecordAsyncStateView Modifier and Type Method Description static JoinRecordAsyncStateViewJoinRecordAsyncStateViews. create(org.apache.flink.streaming.api.operators.StreamingRuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, InternalTypeInfo<org.apache.flink.table.data.RowData> recordType, long retentionTime)Creates aJoinRecordAsyncStateViewdepends onJoinInputSideSpec. -
Uses of JoinRecordAsyncStateView in org.apache.flink.table.runtime.operators.join.stream.utils
Methods in org.apache.flink.table.runtime.operators.join.stream.utils with parameters of type JoinRecordAsyncStateView Modifier and Type Method Description static org.apache.flink.api.common.state.v2.StateFuture<AssociatedRecords>AssociatedRecords. fromAsyncStateView(org.apache.flink.table.data.RowData input, boolean inputIsLeft, JoinRecordAsyncStateView otherSideAsyncStateView, JoinCondition joinCondition)Creates anAssociatedRecordswhich represents the records associated to the input row.
-