org.apache.flink.runtime.state

Class RegisteredStateMetaInfoBase

java.lang.Object

org.apache.flink.runtime.state.RegisteredStateMetaInfoBase

Direct Known Subclasses:

RegisteredBroadcastStateBackendMetaInfo, RegisteredKeyValueStateBackendMetaInfo, RegisteredOperatorStateBackendMetaInfo, RegisteredPriorityQueueStateBackendMetaInfo

public abstract class RegisteredStateMetaInfoBase
extends Object

Base class for all registered state in state backends.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	name The name of the state

Constructor Summary

Constructors

Constructor and Description
RegisteredStateMetaInfoBase(String name)

Method Summary

Modifier and Type	Method and Description
static RegisteredStateMetaInfoBase	fromMetaInfoSnapshot(StateMetaInfoSnapshot snapshot)
String	getName()
abstract StateMetaInfoSnapshot	snapshot()
abstract RegisteredStateMetaInfoBase	withSerializerUpgradesAllowed() create a new metadata object with Lazy serializer provider using existing one as a snapshot.

Methods inherited from class java.lang.Object

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

Field Detail

name

@Nonnull
protected final String name

The name of the state

Constructor Detail

RegisteredStateMetaInfoBase

public RegisteredStateMetaInfoBase(@Nonnull
                                   String name)

Method Detail

getName

@Nonnull
public String getName()

snapshot

@Nonnull
public abstract StateMetaInfoSnapshot snapshot()

withSerializerUpgradesAllowed

@Nonnull
public abstract RegisteredStateMetaInfoBase withSerializerUpgradesAllowed()

create a new metadata object with Lazy serializer provider using existing one as a snapshot. Sometimes metadata was just created or updated, but its StateSerializerProvider will not allow further updates. So this method could replace it with a new one that contains a fresh LazilyRegisteredStateSerializerProvider.

fromMetaInfoSnapshot

public static RegisteredStateMetaInfoBase fromMetaInfoSnapshot(@Nonnull
                                                               StateMetaInfoSnapshot snapshot)