org.apache.reef.io.storage

Class FramingTupleDeserializer<K,V>

java.lang.Object

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

All Implemented Interfaces:

Deserializer<Tuple<K,V>,InputStream>

public class FramingTupleDeserializer<K,V>
extends Object
implements Deserializer<Tuple<K,V>,InputStream>

Constructor Summary

Constructors

Constructor and Description
FramingTupleDeserializer(Deserializer<K,InputStream> keyDeserializer, Deserializer<V,InputStream> valDeserializer)

Method Summary

Methods

Modifier and Type	Method and Description
Iterable<Tuple<K,V>>	create(InputStream ins) Deserialize a stream of input.

Methods inherited from class java.lang.Object

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

Constructor Detail

FramingTupleDeserializer

public FramingTupleDeserializer(Deserializer<K,InputStream> keyDeserializer,
                        Deserializer<V,InputStream> valDeserializer)

Method Detail

create

public Iterable<Tuple<K,V>> create(InputStream ins)

Description copied from interface: Deserializer

Deserialize a stream of input.

Specified by:

create in interface Deserializer<Tuple<K,V>,InputStream>

Returns: