public abstract class TupleInputStream extends DataInputStream
Modifier and Type | Class and Description |
---|---|
static interface |
TupleInputStream.ElementReader |
static interface |
TupleInputStream.TupleElementReader<T extends TupleInputStream> |
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 tuple) |
abstract int |
readToken() |
Tuple |
readTuple() |
<T extends Tuple> |
readTuple(T tuple) |
TuplePair |
readTuplePair() |
TuplePair |
readTuplePair(TuplePair tuplePair) |
abstract Object |
readType(Class type) |
protected abstract Object |
readType(int type) |
<T extends Tuple> |
readTyped(Class[] classes,
T tuple) |
<T extends Tuple> |
readUnTyped(T tuple) |
<T extends Tuple> |
readWith(TupleInputStream.TupleElementReader[] readers,
T tuple) |
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 <T extends Tuple> T readWith(TupleInputStream.TupleElementReader[] readers, T tuple) throws IOException
IOException
public <T extends Tuple> T readTuple(T tuple) throws IOException
IOException
public <T extends Tuple> T readTyped(Class[] classes, T tuple) throws IOException
IOException
public <T extends Tuple> T readUnTyped(T 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 tuple) throws IOException
IOException
protected abstract Object readType(int type) throws IOException
IOException
public abstract Object readType(Class 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.