org.apache.flink.runtime.akka.serialization

Class IOReadableWritableSerializer

java.lang.Object

akka.serialization.JSerializer

org.apache.flink.runtime.akka.serialization.IOReadableWritableSerializer

All Implemented Interfaces:

akka.serialization.Serializer

public class IOReadableWritableSerializer
extends akka.serialization.JSerializer

Constructor Summary

Constructors

Constructor and Description
IOReadableWritableSerializer()

Method Summary

Modifier and Type	Method and Description
protected Object	fromBinaryJava(byte[] bytes, Class<?> manifest)
int	identifier()
boolean	includeManifest()
int	INITIAL_BUFFER_SIZE()
byte[]	toBinary(Object o)

Methods inherited from class akka.serialization.JSerializer

fromBinary, fromBinary, fromBinary

Methods inherited from class java.lang.Object

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

Constructor Detail

IOReadableWritableSerializer

public IOReadableWritableSerializer()

Method Detail

INITIAL_BUFFER_SIZE

public int INITIAL_BUFFER_SIZE()

fromBinaryJava

protected Object fromBinaryJava(byte[] bytes,
                                Class<?> manifest)

Specified by:

fromBinaryJava in class akka.serialization.JSerializer

includeManifest

public boolean includeManifest()

toBinary

public byte[] toBinary(Object o)

identifier

public int identifier()