
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
ByteBufferSerializerfromByteBuffer 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
ByteBufferSerializertoByteBuffer 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
ByteBufferSerializergetByteSize in interface ByteBufferSerializer<TypeInformation>object - Object to serializeIOException - on IO errorsUnsupportedOperationException - When functionality not implemented or
available