Package org.apache.flink.runtime.state

Class RegisteredPriorityQueueStateBackendMetaInfo<T>

java.lang.Object

org.apache.flink.runtime.state.RegisteredStateMetaInfoBase

org.apache.flink.runtime.state.RegisteredPriorityQueueStateBackendMetaInfo<T>

public class RegisteredPriorityQueueStateBackendMetaInfo<T>
extends RegisteredStateMetaInfoBase

Meta information about a priority queue state in a backend.

Field Summary

Fields inherited from class org.apache.flink.runtime.state.RegisteredStateMetaInfoBase

name

Constructor Summary

Constructors

Constructor	Description
RegisteredPriorityQueueStateBackendMetaInfo(String name, org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer)
RegisteredPriorityQueueStateBackendMetaInfo(StateMetaInfoSnapshot snapshot)

Method Summary

Modifier and Type	Method	Description
RegisteredPriorityQueueStateBackendMetaInfo	deepCopy()
org.apache.flink.api.common.typeutils.TypeSerializer<T>	getElementSerializer()
org.apache.flink.api.common.typeutils.TypeSerializer<T>	getPreviousElementSerializer()
StateMetaInfoSnapshot	snapshot()
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<T>	updateElementSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<T> newElementSerializer)
RegisteredPriorityQueueStateBackendMetaInfo<T>	withSerializerUpgradesAllowed()	create a new metadata object with Lazy serializer provider using existing one as a snapshot.

Methods inherited from class org.apache.flink.runtime.state.RegisteredStateMetaInfoBase

fromMetaInfoSnapshot, getName

Methods inherited from class java.lang.Object

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

Constructor Detail

RegisteredPriorityQueueStateBackendMetaInfo

public RegisteredPriorityQueueStateBackendMetaInfo(@Nonnull
                                                   String name,
                                                   @Nonnull
                                                   org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer)

RegisteredPriorityQueueStateBackendMetaInfo

public RegisteredPriorityQueueStateBackendMetaInfo(StateMetaInfoSnapshot snapshot)

Method Detail

snapshot

@Nonnull
public StateMetaInfoSnapshot snapshot()

Specified by:

snapshot in class RegisteredStateMetaInfoBase

withSerializerUpgradesAllowed

@Nonnull
public RegisteredPriorityQueueStateBackendMetaInfo<T> withSerializerUpgradesAllowed()

Description copied from class: RegisteredStateMetaInfoBase

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.

Specified by:

withSerializerUpgradesAllowed in class RegisteredStateMetaInfoBase

getElementSerializer

@Nonnull
public org.apache.flink.api.common.typeutils.TypeSerializer<T> getElementSerializer()

updateElementSerializer

@Nonnull
public org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<T> updateElementSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<T> newElementSerializer)

getPreviousElementSerializer

@Nullable
public org.apache.flink.api.common.typeutils.TypeSerializer<T> getPreviousElementSerializer()

deepCopy

public RegisteredPriorityQueueStateBackendMetaInfo deepCopy()