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

Class SerializationUtils.Serializer<IN>

java.lang.Object

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

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

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()