public abstract class TupleInputStream extends java.io.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 java.io.InputStream |
inputStream
Field inputStream
|
Constructor and Description |
---|
TupleInputStream(java.io.InputStream inputStream,
TupleInputStream.ElementReader elementReader) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.util.Comparator |
getComparatorFor(int type) |
java.io.InputStream |
getInputStream() |
abstract java.lang.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 java.lang.Object |
readType(java.lang.Class type) |
protected abstract java.lang.Object |
readType(int type) |
<T extends Tuple> |
readTyped(java.lang.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
protected final java.io.InputStream inputStream
protected final TupleInputStream.ElementReader elementReader
public TupleInputStream(java.io.InputStream inputStream, TupleInputStream.ElementReader elementReader)
public java.io.InputStream getInputStream()
public <T extends Tuple> T readWith(TupleInputStream.TupleElementReader[] readers, T tuple) throws java.io.IOException
java.io.IOException
public <T extends Tuple> T readTuple(T tuple) throws java.io.IOException
java.io.IOException
public <T extends Tuple> T readTyped(java.lang.Class[] classes, T tuple) throws java.io.IOException
java.io.IOException
public <T extends Tuple> T readUnTyped(T tuple) throws java.io.IOException
java.io.IOException
public abstract int getNumElements() throws java.io.IOException
java.io.IOException
public abstract int readToken() throws java.io.IOException
java.io.IOException
public abstract java.lang.Object getNextElement() throws java.io.IOException
java.io.IOException
public TuplePair readTuplePair() throws java.io.IOException
java.io.IOException
public TuplePair readTuplePair(TuplePair tuplePair) throws java.io.IOException
java.io.IOException
public IndexTuple readIndexTuple() throws java.io.IOException
java.io.IOException
public abstract IndexTuple readIndexTuple(IndexTuple tuple) throws java.io.IOException
java.io.IOException
protected abstract java.lang.Object readType(int type) throws java.io.IOException
java.io.IOException
public abstract java.lang.Object readType(java.lang.Class type) throws java.io.IOException
java.io.IOException
public java.util.Comparator getComparatorFor(int type) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class java.io.FilterInputStream
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.