@Internal public abstract class CompositeTypeSerializerConfigSnapshot<T> extends TypeSerializerConfigSnapshot<T>
TypeSerializerConfigSnapshot
for serializers that has multiple nested serializers. The
configuration snapshot consists of the configuration snapshots of all nested serializers, and
also the nested serializers themselves.
Both the nested serializers and the configuration snapshots are written as configuration of composite serializers, so that on restore, the previous serializer may be used in case migration is required.
TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>
Constructor and Description |
---|
CompositeTypeSerializerConfigSnapshot()
This empty nullary constructor is required for deserializing the configuration.
|
CompositeTypeSerializerConfigSnapshot(TypeSerializer<?>... nestedSerializers) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
getNestedSerializersAndConfigs() |
TypeSerializerSnapshot<?>[] |
getNestedSerializerSnapshots() |
Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> |
getSingleNestedSerializerAndConfig() |
int |
hashCode() |
void |
read(DataInputView in)
Reads the object's internal data from the given data input view.
|
void |
write(DataOutputView out)
Writes the object's internal data to the given data output view.
|
getCurrentVersion, getUserCodeClassLoader, readSnapshot, resolveSchemaCompatibility, restoreSerializer, setPriorSerializer, setUserCodeClassLoader, writeSnapshot
getCompatibleVersions, getReadVersion
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
readVersionedSnapshot, writeVersionedSnapshot
getVersion
public CompositeTypeSerializerConfigSnapshot()
public CompositeTypeSerializerConfigSnapshot(TypeSerializer<?>... nestedSerializers)
public void write(DataOutputView out) throws IOException
IOReadableWritable
write
in interface IOReadableWritable
write
in class VersionedIOReadableWritable
out
- the output view to receive the data.IOException
- thrown if any error occurs while writing to the output streampublic void read(DataInputView in) throws IOException
IOReadableWritable
read
in interface IOReadableWritable
read
in class VersionedIOReadableWritable
in
- the input view to read the data fromIOException
- thrown if any error occurs while reading from the input streampublic List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> getNestedSerializersAndConfigs()
public Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> getSingleNestedSerializerAndConfig()
public TypeSerializerSnapshot<?>[] getNestedSerializerSnapshots()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.