cascading.tuple.hadoop
Class SerializationElementReader

java.lang.Object
  cascading.tuple.hadoop.SerializationElementReader

All Implemented Interfaces:

TupleInputStream.ElementReader

public class SerializationElementReader
extends Object
implements TupleInputStream.ElementReader

Constructor Summary

SerializationElementReader(TupleSerialization tupleSerialization)

Method Summary

void	close()
Comparable	read(int token, DataInputStream inputStream)

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializationElementReader

public SerializationElementReader(TupleSerialization tupleSerialization)

Method Detail

read

public Comparable read(int token,
                       DataInputStream inputStream)
                throws IOException

Specified by:

read in interface TupleInputStream.ElementReader

Throws:

IOException

close

public void close()

Specified by:

close in interface TupleInputStream.ElementReader