io.pravega.common.io.serialization

Class VersionedSerializer.MultiType<BaseType>

java.lang.Object

io.pravega.common.io.serialization.VersionedSerializer<BaseType>

io.pravega.common.io.serialization.VersionedSerializer.MultiType<BaseType>

Type Parameters:

BaseType - The base type that all other types will derive from.

Enclosing class:

VersionedSerializer<T>

public abstract static class VersionedSerializer.MultiType<BaseType>
extends VersionedSerializer<BaseType>

A VersionedDeserializer that serializes deserializes objects instantiating different types that inherit from a single base type. This is a meta-serializer in itself, as it composes various other Single-Type serializers into it. This should be used in those cases when we have a base (maybe abstract) type and multiple types inheriting from it that need serialization. A Serializer needs to be implemented for each sub-type and registered into this instance. Currently only VersionedSerializer.WithBuilder sub-serializers are supported. Example:

 
 class BaseType { ... }

 class SubType1 extends BaseType {
     static class SubType1Builder implements ObjectBuilder { ... }
     static class SubType1Serializer extends VersionedSerializer.WithBuilder { ... }
 }

 class SubType11 extends SubType1 {
     static class SubType11Builder implements ObjectBuilder { ... }
     static class SubType11Serializer extends VersionedSerializer.WithBuilder { ... }
 }

 class SubType2 extends BaseType {
     static class SubType2Builder implements ObjectBuilder { ... }
     static class SubType2Serializer extends VersionedSerializer.WithBuilder { ... }
 }

 class BaseTypeSerializer extends VersionedSerializer.MultiType {

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	VersionedSerializer.MultiType.Builder

Nested classes/interfaces inherited from class io.pravega.common.io.serialization.VersionedSerializer

VersionedSerializer.Direct<TargetType>, VersionedSerializer.FormatVersion<TargetType,ReaderType>, VersionedSerializer.MultiType<BaseType>, VersionedSerializer.StreamReader<ReaderType>, VersionedSerializer.StreamWriter<TargetType>, VersionedSerializer.WithBuilder<TargetType,ReaderType extends ObjectBuilder<TargetType>>

Constructor Summary

Constructors

Constructor and Description
MultiType() Creates a new instance of the MultiType class.

Method Summary

Modifier and Type	Method and Description
protected abstract void	declareSerializers(VersionedSerializer.MultiType.Builder builder) When implemented in a derived class, this method will declare all supported serializers of subtypes of BaseType by using the serializer() method.
BaseType	deserialize(ArrayView data) Deserializes data from the given ArrayView and creates a new object with the result.
BaseType	deserialize(java.io.InputStream stream) Deserializes data from the given InputStream into an object of type BaseType.
void	serialize(java.io.OutputStream stream, BaseType o) Serializes the given object to the given OutputStream.

Methods inherited from class io.pravega.common.io.serialization.VersionedSerializer

serialize, serialize

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiType

public MultiType()

Creates a new instance of the MultiType class.

Method Detail

declareSerializers

protected abstract void declareSerializers(VersionedSerializer.MultiType.Builder builder)

When implemented in a derived class, this method will declare all supported serializers of subtypes of BaseType by using the serializer() method.

Parameters:

builder - A MultiType.Builder that can be used to declare serializers.

serialize

public void serialize(java.io.OutputStream stream,
                      BaseType o)
               throws java.io.IOException

Description copied from class: VersionedSerializer

Serializes the given object to the given OutputStream.

Specified by:

serialize in class VersionedSerializer<BaseType>

Parameters:

stream - The OutputStream to serialize to.

o - The object to serialize.

Throws:

java.io.IOException - If an IO Exception occurred.

deserialize

public BaseType deserialize(java.io.InputStream stream)
                     throws java.io.IOException

Deserializes data from the given InputStream into an object of type BaseType. This will use one of the registered serializers to instantiate an instance of the correct type (derived from BaseType), as specified in declareSerializers().

Parameters:

stream - The InputStream to deserialize from.

Returns:

The deserialized instance.

Throws:

java.io.IOException - If an IO Exception occurred.

deserialize

public BaseType deserialize(ArrayView data)
                     throws java.io.IOException

Deserializes data from the given ArrayView and creates a new object with the result.

Parameters:

data - The ArrayView to deserialize from.

Returns:

A new instance of TargetType with the deserialized data.

Throws:

java.io.IOException - If an IO Exception occurred.