Uses of Interface
org.apache.flink.table.runtime.operators.join.stream.state.JoinRecordStateView

Packages that use JoinRecordStateView

Package	Description
org.apache.flink.table.runtime.operators.join.stream
org.apache.flink.table.runtime.operators.join.stream.state

Uses of JoinRecordStateView in org.apache.flink.table.runtime.operators.join.stream

Methods in org.apache.flink.table.runtime.operators.join.stream with parameters of type JoinRecordStateView

Modifier and Type	Method and Description
static AbstractStreamingJoinOperator.AssociatedRecords	AbstractStreamingJoinOperator.AssociatedRecords.of(BaseRow input, boolean inputIsLeft, JoinRecordStateView otherSideStateView, JoinCondition condition) Creates an AbstractStreamingJoinOperator.AssociatedRecords which represents the records associated to the input row.

Uses of JoinRecordStateView in org.apache.flink.table.runtime.operators.join.stream.state

Subinterfaces of JoinRecordStateView in org.apache.flink.table.runtime.operators.join.stream.state

Modifier and Type	Interface and Description
interface	OuterJoinRecordStateView A OuterJoinRecordStateView is an extension to JoinRecordStateView.

Methods in org.apache.flink.table.runtime.operators.join.stream.state that return JoinRecordStateView

Modifier and Type	Method and Description
static JoinRecordStateView	JoinRecordStateViews.create(RuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, BaseRowTypeInfo recordType, long retentionTime, boolean stateCleaningEnabled) Creates a JoinRecordStateView depends on JoinInputSideSpec.