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

Class OuterJoinRecordStateViews

java.lang.Object

org.apache.flink.table.runtime.operators.join.stream.state.OuterJoinRecordStateViews

public final class OuterJoinRecordStateViews
extends Object

Utility to create a OuterJoinRecordStateViews depends on JoinInputSideSpec.

Constructor Summary

Constructors

Constructor and Description
OuterJoinRecordStateViews()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OuterJoinRecordStateViews

public OuterJoinRecordStateViews()

Method Detail

create

public static OuterJoinRecordStateView create(RuntimeContext ctx,
                                              String stateName,
                                              JoinInputSideSpec inputSideSpec,
                                              BaseRowTypeInfo recordType,
                                              long retentionTime,
                                              boolean stateCleaningEnabled)

Creates a OuterJoinRecordStateView depends on JoinInputSideSpec.