org.apache.reef.io.storage

Class FramingTupleSerializer<K,V>

java.lang.Object

org.apache.reef.io.storage.FramingTupleSerializer<K,V>

All Implemented Interfaces:

Serializer<Tuple<K,V>,OutputStream>

public class FramingTupleSerializer<K,V>
extends Object
implements Serializer<Tuple<K,V>,OutputStream>

Constructor Summary

Constructors

Constructor and Description
FramingTupleSerializer(Serializer<K,OutputStream> keySerializer, Serializer<V,OutputStream> valSerializer)

Method Summary

Modifier and Type	Method and Description
Accumulable<Tuple<K,V>>	create(OutputStream os) Serialize a stream of objects.

Methods inherited from class java.lang.Object

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

Constructor Detail

FramingTupleSerializer

public FramingTupleSerializer(Serializer<K,OutputStream> keySerializer,
                              Serializer<V,OutputStream> valSerializer)

Method Detail

create

public Accumulable<Tuple<K,V>> create(OutputStream os)

Description copied from interface: Serializer

Serialize a stream of objects.

Specified by:

create in interface Serializer<Tuple<K,V>,OutputStream>

Returns: