cascading.tuple.hadoop
Class TupleSerialization.SerializationElementReader
java.lang.Object
cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
- All Implemented Interfaces:
- cascading.tuple.io.TupleInputStream.ElementReader
- Enclosing class:
- TupleSerialization
public static class TupleSerialization.SerializationElementReader
- extends Object
- implements cascading.tuple.io.TupleInputStream.ElementReader
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TupleSerialization.SerializationElementReader
public TupleSerialization.SerializationElementReader(TupleSerialization tupleSerialization)
- Constructor SerializationElementReader creates a new SerializationElementReader instance.
- Parameters:
tupleSerialization
- of type TupleSerialization
read
public Object read(int token,
DataInputStream inputStream)
throws IOException
- Specified by:
read
in interface cascading.tuple.io.TupleInputStream.ElementReader
- Throws:
IOException
getComparatorFor
public Comparator getComparatorFor(int token,
DataInputStream inputStream)
throws IOException
- Specified by:
getComparatorFor
in interface cascading.tuple.io.TupleInputStream.ElementReader
- Throws:
IOException
getClassNameFor
public String getClassNameFor(int token,
DataInputStream inputStream)
throws IOException
- Throws:
IOException
close
public void close()
- Specified by:
close
in interface cascading.tuple.io.TupleInputStream.ElementReader
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.