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

Class JoinRecordStateViews

java.lang.Object

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

public final class JoinRecordStateViews
extends Object

Utility to create a JoinRecordStateView depends on JoinInputSideSpec.

Constructor Summary

Constructors

Constructor and Description
JoinRecordStateViews()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinRecordStateViews

public JoinRecordStateViews()

Method Detail

create

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

Creates a JoinRecordStateView depends on JoinInputSideSpec.