TwoPhaseCommitSinkFunction.StateSerializerSnapshot
.@Internal @Deprecated public static final class TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT> extends CompositeTypeSerializerConfigSnapshot<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>>
TypeSerializerConfigSnapshot
for sink state. This has to be public so that it can be
deserialized/instantiated, should not be used anywhere outside TwoPhaseCommitSinkFunction
.TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>
Constructor and Description |
---|
StateSerializerConfigSnapshot()
Deprecated.
This empty nullary constructor is required for deserializing the configuration.
|
StateSerializerConfigSnapshot(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
int |
getVersion()
Deprecated.
Returns the version number of the object.
|
TypeSerializerSchemaCompatibility<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> |
resolveSchemaCompatibility(TypeSerializer<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> newSerializer)
Deprecated.
Checks a new serializer's compatibility to read data written by the prior serializer.
|
equals, getNestedSerializersAndConfigs, getNestedSerializerSnapshots, getSingleNestedSerializerAndConfig, hashCode, read, write
getCurrentVersion, getUserCodeClassLoader, readSnapshot, restoreSerializer, setPriorSerializer, setUserCodeClassLoader, writeSnapshot
getCompatibleVersions, getReadVersion
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
readVersionedSnapshot, writeVersionedSnapshot
public StateSerializerConfigSnapshot()
public StateSerializerConfigSnapshot(TypeSerializer<TXN> transactionSerializer, TypeSerializer<CONTEXT> contextSerializer)
public int getVersion()
Versioned
public TypeSerializerSchemaCompatibility<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> resolveSchemaCompatibility(TypeSerializer<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> newSerializer)
TypeSerializerSnapshot
When a checkpoint/savepoint is restored, this method checks whether the serialization format of the data in the checkpoint/savepoint is compatible for the format of the serializer used by the program that restores the checkpoint/savepoint. The outcome can be that the serialization format is compatible, that the program's serializer needs to reconfigure itself (meaning to incorporate some information from the TypeSerializerSnapshot to be compatible), that the format is outright incompatible, or that a migration needed. In the latter case, the TypeSerializerSnapshot produces a serializer to deserialize the data, and the restoring program's serializer re-serializes the data, thus converting the format during the restore operation.
resolveSchemaCompatibility
in interface TypeSerializerSnapshot<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>>
resolveSchemaCompatibility
in class TypeSerializerConfigSnapshot<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>>
newSerializer
- the new serializer to check.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.