org.apache.flink.python.api.streaming.util

Class SerializationUtils.Serializer<IN>

java.lang.Object

org.apache.flink.python.api.streaming.util.SerializationUtils.Serializer<IN>

Type Parameters:

IN - input type

Direct Known Subclasses:

SerializationUtils.BooleanSerializer, SerializationUtils.ByteSerializer, SerializationUtils.BytesSerializer, SerializationUtils.CustomTypeWrapperSerializer, SerializationUtils.DoubleSerializer, SerializationUtils.FloatSerializer, SerializationUtils.IntSerializer, SerializationUtils.LongSerializer, SerializationUtils.NullSerializer, SerializationUtils.StringSerializer, SerializationUtils.TupleSerializer

Enclosing class:

SerializationUtils

public abstract static class SerializationUtils.Serializer<IN>
extends Object

Super class for all serializers used to serialize data. These serializers are used to serialize values emitted from java input formats.

These serializer smut be kept in sync with the python counterparts.

Constructor Summary

Constructors

Constructor and Description
Serializer()

Method Summary

Modifier and Type	Method and Description
protected int	getTypeInfoSize()
protected abstract void	putTypeInfo(ByteBuffer buffer)
byte[]	serialize(IN value)
abstract byte[]	serializeWithoutTypeInfo(IN value)

Methods inherited from class java.lang.Object

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

Constructor Detail

Serializer

public Serializer()

Method Detail

serialize

public byte[] serialize(IN value)

serializeWithoutTypeInfo

public abstract byte[] serializeWithoutTypeInfo(IN value)

putTypeInfo

protected abstract void putTypeInfo(ByteBuffer buffer)

getTypeInfoSize

protected int getTypeInfoSize()