Package org.apache.flink.table.runtime.sequencedmultisetstate

Class SequencedMultiSetStateContext

java.lang.Object

org.apache.flink.table.runtime.sequencedmultisetstate.SequencedMultiSetStateContext

All Implemented Interfaces:

Serializable

public class SequencedMultiSetStateContext
extends Object
implements Serializable

SequencedMultiSetState (creation) context.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SequencedMultiSetStateContext.KeyExtractor

Field Summary

Fields

Modifier and Type	Field	Description
SequencedMultiSetStateConfig	config
GeneratedRecordEqualiser	generatedKeyEqualiser
GeneratedHashFunction	generatedKeyHashFunction
SequencedMultiSetStateContext.KeyExtractor	keyExtractor
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData>	keySerializer
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData>	recordSerializer

Constructor Summary

Constructors

Constructor

Description

SequencedMultiSetStateContext(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer, GeneratedRecordEqualiser generatedKeyEqualiser, GeneratedHashFunction generatedKeyHashFunction, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer, SequencedMultiSetStateContext.KeyExtractor keyExtractor, SequencedMultiSetStateConfig config)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

config

public final SequencedMultiSetStateConfig config

keySerializer

public final org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer

generatedKeyEqualiser

public final GeneratedRecordEqualiser generatedKeyEqualiser

generatedKeyHashFunction

public final GeneratedHashFunction generatedKeyHashFunction

recordSerializer

public final org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer

keyExtractor

public final SequencedMultiSetStateContext.KeyExtractor keyExtractor

Constructor Detail

SequencedMultiSetStateContext

public SequencedMultiSetStateContext(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer,
                                     GeneratedRecordEqualiser generatedKeyEqualiser,
                                     GeneratedHashFunction generatedKeyHashFunction,
                                     org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer,
                                     SequencedMultiSetStateContext.KeyExtractor keyExtractor,
                                     SequencedMultiSetStateConfig config)