org.apache.flink.runtime.state.metainfo

Class StateMetaInfoSnapshot

java.lang.Object

org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot

public class StateMetaInfoSnapshot
extends Object

Generalized snapshot for meta information about one state in a state backend (e.g. RegisteredKeyValueStateBackendMetaInfo).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StateMetaInfoSnapshot.BackendStateType Enum that defines the different types of state that live in Flink backends.
static class	StateMetaInfoSnapshot.CommonOptionsKeys Predefined keys for the most common options in the meta info.
static class	StateMetaInfoSnapshot.CommonSerializerKeys Predefined keys for the most common serializer types in the meta info.

Constructor Summary

Constructors

Constructor and Description
StateMetaInfoSnapshot(String name, StateMetaInfoSnapshot.BackendStateType backendStateType, Map<String,String> options, Map<String,org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot> serializerConfigSnapshots, Map<String,org.apache.flink.api.common.typeutils.TypeSerializer<?>> serializers)

Method Summary

Modifier and Type	Method and Description
StateMetaInfoSnapshot.BackendStateType	getBackendStateType()
String	getName()
String	getOption(StateMetaInfoSnapshot.CommonOptionsKeys key)
String	getOption(String key)
Map<String,String>	getOptionsImmutable()
Map<String,org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot>	getSerializerConfigSnapshotsImmutable()
Map<String,org.apache.flink.api.common.typeutils.TypeSerializer<?>>	getSerializersImmutable()
org.apache.flink.api.common.typeutils.TypeSerializer<?>	getTypeSerializer(StateMetaInfoSnapshot.CommonSerializerKeys key)
org.apache.flink.api.common.typeutils.TypeSerializer<?>	getTypeSerializer(String key)
org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot	getTypeSerializerConfigSnapshot(StateMetaInfoSnapshot.CommonSerializerKeys key)
org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot	getTypeSerializerConfigSnapshot(String key)

Methods inherited from class java.lang.Object

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

Constructor Detail

StateMetaInfoSnapshot

public StateMetaInfoSnapshot(@Nonnull
                             String name,
                             @Nonnull
                             StateMetaInfoSnapshot.BackendStateType backendStateType,
                             @Nonnull
                             Map<String,String> options,
                             @Nonnull
                             Map<String,org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot> serializerConfigSnapshots,
                             @Nonnull
                             Map<String,org.apache.flink.api.common.typeutils.TypeSerializer<?>> serializers)

Method Detail

getBackendStateType

@Nonnull
public StateMetaInfoSnapshot.BackendStateType getBackendStateType()

getTypeSerializerConfigSnapshot

@Nullable
public org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot getTypeSerializerConfigSnapshot(@Nonnull
                                                                                                                    String key)

getTypeSerializerConfigSnapshot

@Nullable
public org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot getTypeSerializerConfigSnapshot(@Nonnull
                                                                                                                    StateMetaInfoSnapshot.CommonSerializerKeys key)

getOption

@Nullable
public String getOption(@Nonnull
                                  String key)

getOption

@Nullable
public String getOption(@Nonnull
                                  StateMetaInfoSnapshot.CommonOptionsKeys key)

getOptionsImmutable

@Nonnull
public Map<String,String> getOptionsImmutable()

getName

@Nonnull
public String getName()

getTypeSerializer

@Nullable
public org.apache.flink.api.common.typeutils.TypeSerializer<?> getTypeSerializer(@Nonnull
                                                                                           String key)

getTypeSerializer

@Nullable
public org.apache.flink.api.common.typeutils.TypeSerializer<?> getTypeSerializer(@Nonnull
                                                                                           StateMetaInfoSnapshot.CommonSerializerKeys key)

getSerializerConfigSnapshotsImmutable

@Nonnull
public Map<String,org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot> getSerializerConfigSnapshotsImmutable()

getSerializersImmutable

@Nonnull
public Map<String,org.apache.flink.api.common.typeutils.TypeSerializer<?>> getSerializersImmutable()