@PublicEvolving public class CompositeSerializerSnapshot extends Object
The CompositeSerializerSnapshot does not implement the TypeSerializerSnapshot
interface.
It is not meant to be inherited from, but to be composed with a serializer snapshot implementation.
The CompositeSerializerSnapshot has its own versioning internally, it does not couple its versioning to the versioning of the TypeSerializerSnapshot that builds on top of this class. That way, the CompositeSerializerSnapshot and enclosing TypeSerializerSnapshot the can evolve their formats independently.
Constructor and Description |
---|
CompositeSerializerSnapshot(TypeSerializer<?>... serializers)
Constructor to create a snapshot for writing.
|
Modifier and Type | Method and Description |
---|---|
<T> TypeSerializer<T> |
getRestoreSerializer(int pos)
Creates the restore serializer from the pos-th config snapshot.
|
TypeSerializer<?>[] |
getRestoreSerializers()
Produces a restore serializer from each contained serializer configuration snapshot.
|
static CompositeSerializerSnapshot |
legacyReadProductSnapshots(DataInputView in,
ClassLoader cl)
Reads the composite snapshot of all the contained serializers in a way that is compatible
with Version 1 of the deprecated
CompositeTypeSerializerConfigSnapshot . |
static CompositeSerializerSnapshot |
readCompositeSnapshot(DataInputView in,
ClassLoader cl)
Reads the composite snapshot of all the contained serializers.
|
<T> TypeSerializerSchemaCompatibility<T> |
resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?> outerCompatibility,
TypeSerializer<?>... newNestedSerializers)
Resolves the compatibility of the nested serializer snapshots with the nested
serializers of the new outer serializer.
|
void |
writeCompositeSnapshot(DataOutputView out)
Writes the composite snapshot of all the contained serializers.
|
public CompositeSerializerSnapshot(TypeSerializer<?>... serializers)
public TypeSerializer<?>[] getRestoreSerializers()
public <T> TypeSerializer<T> getRestoreSerializer(int pos)
public <T> TypeSerializerSchemaCompatibility<T> resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?> outerCompatibility, TypeSerializer<?>... newNestedSerializers)
public final void writeCompositeSnapshot(DataOutputView out) throws IOException
IOException
public static CompositeSerializerSnapshot readCompositeSnapshot(DataInputView in, ClassLoader cl) throws IOException
IOException
public static CompositeSerializerSnapshot legacyReadProductSnapshots(DataInputView in, ClassLoader cl) throws IOException
CompositeTypeSerializerConfigSnapshot
.IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.