org.apache.flink.migration.runtime.state.memory

Class AbstractMemStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>

java.lang.Object

org.apache.flink.migration.runtime.state.memory.AbstractMemStateSnapshot<K,N,SV,S,SD>

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, KvStateSnapshot<K,N,S,SD>, MigrationRestoreSnapshot<K,N,SV>, StateObject, Migration

Direct Known Subclasses:

MemFoldingState.Snapshot, MemListState.Snapshot, MemReducingState.Snapshot, MemValueState.Snapshot

Deprecated.

Internal class for savepoint backwards compatibility. Don't use for other purposes.

@Deprecated
public abstract class AbstractMemStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>
extends Object
implements KvStateSnapshot<K,N,S,SD>, MigrationRestoreSnapshot<K,N,SV>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected TypeSerializer<K>	keySerializer Deprecated. Key Serializer
protected TypeSerializer<N>	namespaceSerializer Deprecated. Namespace Serializer
protected SD	stateDesc Deprecated. StateDescriptor, for sanity checks
protected TypeSerializer<SV>	stateSerializer Deprecated. Serializer for the state value

Constructor Summary

Constructors

Constructor and Description
AbstractMemStateSnapshot(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, TypeSerializer<SV> stateSerializer, SD stateDesc, byte[] data) Deprecated. Creates a new heap memory state snapshot.

Method Summary

Modifier and Type	Method and Description
void	close() Deprecated.
StateTable<K,N,SV>	deserialize(String stateName, HeapKeyedStateBackend<K> stateBackend) Deprecated.
void	discardState() Deprecated. Discarding the heap state is a no-op.
byte[]	getData() Deprecated.
TypeSerializer<K>	getKeySerializer() Deprecated.
TypeSerializer<N>	getNamespaceSerializer() Deprecated.
TypeSerializer<SV>	getStateSerializer() Deprecated.
long	getStateSize() Deprecated. Returns the size of the state in bytes.
String	toString() Deprecated.

Methods inherited from class java.lang.Object

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

Field Detail

keySerializer

protected final TypeSerializer<K> keySerializer

Deprecated.

Key Serializer

namespaceSerializer

protected final TypeSerializer<N> namespaceSerializer

Deprecated.

Namespace Serializer

stateSerializer

protected final TypeSerializer<SV> stateSerializer

Deprecated.

Serializer for the state value

stateDesc

protected final SD extends StateDescriptor<S,?> stateDesc

Deprecated.

StateDescriptor, for sanity checks

Constructor Detail

AbstractMemStateSnapshot

public AbstractMemStateSnapshot(TypeSerializer<K> keySerializer,
                                TypeSerializer<N> namespaceSerializer,
                                TypeSerializer<SV> stateSerializer,
                                SD stateDesc,
                                byte[] data)

Deprecated.

Creates a new heap memory state snapshot.

Parameters:

keySerializer - The serializer for the keys.

namespaceSerializer - The serializer for the namespace.

stateSerializer - The serializer for the elements in the state HashMap

stateDesc - The state identifier

data - The serialized data of the state key/value pairs

Method Detail

deserialize

public StateTable<K,N,SV> deserialize(String stateName,
                                      HeapKeyedStateBackend<K> stateBackend)
                               throws IOException

Deprecated.

Specified by:

deserialize in interface MigrationRestoreSnapshot<K,N,SV>

Throws:

IOException

discardState

public void discardState()

Deprecated.

Discarding the heap state is a no-op.

Specified by:

discardState in interface StateObject

getStateSize

public long getStateSize()

Deprecated.

Description copied from interface: StateObject

Returns the size of the state in bytes.

If the the size is not known, return 0.

Specified by:

getStateSize in interface StateObject

Returns:

Size of the state in bytes.

close

public void close()

Deprecated.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getKeySerializer

public TypeSerializer<K> getKeySerializer()

Deprecated.

getNamespaceSerializer

public TypeSerializer<N> getNamespaceSerializer()

Deprecated.

getStateSerializer

public TypeSerializer<SV> getStateSerializer()

Deprecated.

getData

public byte[] getData()

Deprecated.

toString

public String toString()

Deprecated.

Overrides:

toString in class Object