@Internal 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
.Constructor and Description |
---|
StateSerializerConfigSnapshot()
This empty nullary constructor is required for deserializing the configuration.
|
StateSerializerConfigSnapshot(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer) |
Modifier and Type | Method and Description |
---|---|
int |
getVersion()
Returns the version number of the object.
|
equals, getNestedSerializersAndConfigs, getSingleNestedSerializerAndConfig, hashCode, read, write
getCurrentVersion, getUserCodeClassLoader, readSnapshot, resolveSchemaCompatibility, 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
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.