public abstract class TupleInputStream extends DataInputStream
Modifier and Type | Class and Description |
---|---|
static interface |
TupleInputStream.ElementReader |
Modifier and Type | Field and Description |
---|---|
protected TupleInputStream.ElementReader |
elementReader
Field elementReader
|
protected InputStream |
inputStream
Field inputStream
|
in
Constructor and Description |
---|
TupleInputStream(InputStream inputStream,
TupleInputStream.ElementReader elementReader) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Comparator |
getComparatorFor(int type) |
InputStream |
getInputStream() |
abstract Object |
getNextElement() |
abstract int |
getNumElements() |
IndexTuple |
readIndexTuple() |
abstract IndexTuple |
readIndexTuple(IndexTuple indexTuple) |
abstract int |
readToken() |
Tuple |
readTuple() |
Tuple |
readTuple(Tuple tuple) |
TuplePair |
readTuplePair() |
TuplePair |
readTuplePair(TuplePair tuplePair) |
protected abstract Object |
readType(int type) |
read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes
available, mark, markSupported, read, reset, skip
protected final InputStream inputStream
protected final TupleInputStream.ElementReader elementReader
public TupleInputStream(InputStream inputStream, TupleInputStream.ElementReader elementReader)
public InputStream getInputStream()
public Tuple readTuple() throws IOException
IOException
public Tuple readTuple(Tuple tuple) throws IOException
IOException
public abstract int getNumElements() throws IOException
IOException
public abstract int readToken() throws IOException
IOException
public abstract Object getNextElement() throws IOException
IOException
public TuplePair readTuplePair() throws IOException
IOException
public TuplePair readTuplePair(TuplePair tuplePair) throws IOException
IOException
public IndexTuple readIndexTuple() throws IOException
IOException
public abstract IndexTuple readIndexTuple(IndexTuple indexTuple) throws IOException
IOException
protected abstract Object readType(int type) throws IOException
IOException
public Comparator getComparatorFor(int type) throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class FilterInputStream
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.