N
- Type of namespaceS
- Type of state valuepublic class RegisteredKeyedBackendStateMetaInfo<N,S> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S>
A consistent snapshot of a
RegisteredKeyedBackendStateMetaInfo . |
Constructor and Description |
---|
RegisteredKeyedBackendStateMetaInfo(StateDescriptor.Type stateType,
String name,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
String |
getName() |
TypeSerializer<N> |
getNamespaceSerializer() |
TypeSerializer<S> |
getStateSerializer() |
StateDescriptor.Type |
getStateType() |
int |
hashCode() |
static <N,S> RegisteredKeyedBackendStateMetaInfo<N,S> |
resolveKvStateCompatibility(RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> restoredStateMetaInfoSnapshot,
TypeSerializer<N> newNamespaceSerializer,
StateDescriptor<?,S> newStateDescriptor)
Checks compatibility of a restored k/v state, with the new
StateDescriptor provided to it. |
RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> |
snapshot() |
String |
toString() |
public RegisteredKeyedBackendStateMetaInfo(StateDescriptor.Type stateType, String name, TypeSerializer<N> namespaceSerializer, TypeSerializer<S> stateSerializer)
public StateDescriptor.Type getStateType()
public String getName()
public TypeSerializer<N> getNamespaceSerializer()
public TypeSerializer<S> getStateSerializer()
public RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> snapshot()
public static <N,S> RegisteredKeyedBackendStateMetaInfo<N,S> resolveKvStateCompatibility(RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> restoredStateMetaInfoSnapshot, TypeSerializer<N> newNamespaceSerializer, StateDescriptor<?,S> newStateDescriptor) throws StateMigrationException
StateDescriptor
provided to it.
This checks that the descriptor specifies identical names and state types, as well as
serializers that are compatible for the restored k/v state bytes.StateMigrationException
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.