public class StateMetaInfoSnapshot extends Object
RegisteredKeyValueStateBackendMetaInfo
).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 and Description |
---|
StateMetaInfoSnapshot(String name,
StateMetaInfoSnapshot.BackendStateType backendStateType,
Map<String,String> options,
Map<String,TypeSerializerConfigSnapshot> serializerConfigSnapshots,
Map<String,TypeSerializer<?>> serializers) |
public StateMetaInfoSnapshot(@Nonnull String name, @Nonnull StateMetaInfoSnapshot.BackendStateType backendStateType, @Nonnull Map<String,String> options, @Nonnull Map<String,TypeSerializerConfigSnapshot> serializerConfigSnapshots, @Nonnull Map<String,TypeSerializer<?>> serializers)
@Nonnull public StateMetaInfoSnapshot.BackendStateType getBackendStateType()
@Nullable public TypeSerializerConfigSnapshot getTypeSerializerConfigSnapshot(@Nonnull String key)
@Nullable public TypeSerializerConfigSnapshot getTypeSerializerConfigSnapshot(@Nonnull StateMetaInfoSnapshot.CommonSerializerKeys key)
@Nullable public String getOption(@Nonnull StateMetaInfoSnapshot.CommonOptionsKeys key)
@Nullable public TypeSerializer<?> getTypeSerializer(@Nonnull String key)
@Nullable public TypeSerializer<?> getTypeSerializer(@Nonnull StateMetaInfoSnapshot.CommonSerializerKeys key)
@Nonnull public Map<String,TypeSerializerConfigSnapshot> getSerializerConfigSnapshotsImmutable()
@Nonnull public Map<String,TypeSerializer<?>> getSerializersImmutable()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.