public class TypeInformationSerializer extends Object implements ByteBufferSerializer<TypeInformation>
Modifier and Type | Class and Description |
---|---|
(package private) static class |
TypeInformationSerializer.SimpleTypeSerializer
Serialization class for pure simple types.
|
(package private) static class |
TypeInformationSerializer.VectorFieldTypeSerializer
Serialization class for field vector types.
|
(package private) static class |
TypeInformationSerializer.VectorTypeSerializer
Serialization class for non-field vector types.
|
Modifier and Type | Field and Description |
---|---|
(package private) static ByteBufferSerializer<SimpleTypeInformation<?>> |
SIMPLE_TYPE_SERIALIZER
Serializer for simple types only.
|
static TypeInformationSerializer |
STATIC
Static instance.
|
private static byte |
TAG_SIMPLE
Tag for simple type.
|
private static byte |
TAG_VECTOR
Tag for non-field vector type.
|
private static byte |
TAG_VECTOR_FIELD
Tag for vector field type.
|
(package private) static ByteBufferSerializer<VectorFieldTypeInformation<?>> |
VECTOR_FIELD_TYPE_SERIALIZER
Serializer for vector fields.
|
(package private) static ByteBufferSerializer<VectorTypeInformation<?>> |
VECTOR_TYPE_SERIALIZER
Serializer for non-field vectors.
|
Constructor and Description |
---|
TypeInformationSerializer() |
Modifier and Type | Method and Description |
---|---|
TypeInformation |
fromByteBuffer(ByteBuffer buffer)
Deserialize an object from a byte buffer (e.g. disk)
|
int |
getByteSize(TypeInformation object)
Get the size of the object in bytes.
|
void |
toByteBuffer(ByteBuffer buffer,
TypeInformation object)
Serialize the object to a byte array (e.g. disk)
|
public static final TypeInformationSerializer STATIC
private static final byte TAG_SIMPLE
private static final byte TAG_VECTOR
private static final byte TAG_VECTOR_FIELD
static final ByteBufferSerializer<SimpleTypeInformation<?>> SIMPLE_TYPE_SERIALIZER
static final ByteBufferSerializer<VectorTypeInformation<?>> VECTOR_TYPE_SERIALIZER
static final ByteBufferSerializer<VectorFieldTypeInformation<?>> VECTOR_FIELD_TYPE_SERIALIZER
public TypeInformation fromByteBuffer(ByteBuffer buffer) throws IOException, UnsupportedOperationException
ByteBufferSerializer
fromByteBuffer
in interface ByteBufferSerializer<TypeInformation>
buffer
- Data array to processIOException
- on IO errorsUnsupportedOperationException
- When functionality not implemented or
availablepublic void toByteBuffer(ByteBuffer buffer, TypeInformation object) throws IOException, UnsupportedOperationException
ByteBufferSerializer
toByteBuffer
in interface ByteBufferSerializer<TypeInformation>
buffer
- Buffer to serialize toobject
- Object to serializeIOException
- on IO errorsUnsupportedOperationException
- When functionality not implemented or
availablepublic int getByteSize(TypeInformation object) throws IOException, UnsupportedOperationException
ByteBufferSerializer
getByteSize
in interface ByteBufferSerializer<TypeInformation>
object
- Object to serializeIOException
- on IO errorsUnsupportedOperationException
- When functionality not implemented or
available