public static class TupleSerialization.SerializationElementReader extends Object implements TupleInputStream.ElementReader
Constructor and Description |
---|
TupleSerialization.SerializationElementReader(TupleSerialization tupleSerialization)
Constructor SerializationElementReader creates a new SerializationElementReader instance.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
String |
getClassNameFor(int token,
DataInputStream inputStream) |
Comparator |
getComparatorFor(int token,
DataInputStream inputStream) |
Object |
read(int token,
DataInputStream inputStream) |
public TupleSerialization.SerializationElementReader(TupleSerialization tupleSerialization)
tupleSerialization
- of type TupleSerializationpublic Object read(int token, DataInputStream inputStream) throws IOException
read
in interface TupleInputStream.ElementReader
IOException
public Comparator getComparatorFor(int token, DataInputStream inputStream) throws IOException
getComparatorFor
in interface TupleInputStream.ElementReader
IOException
public String getClassNameFor(int token, DataInputStream inputStream) throws IOException
IOException
public void close()
close
in interface TupleInputStream.ElementReader
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.