public class HadoopTupleInputStream extends TupleInputStream
TupleInputStream.ElementReader
elementReader, inputStream
in
Constructor and Description |
---|
HadoopTupleInputStream(InputStream inputStream,
TupleInputStream.ElementReader elementReader) |
Modifier and Type | Method and Description |
---|---|
Object |
getNextElement() |
int |
getNumElements() |
IndexTuple |
readIndexTuple(IndexTuple indexTuple) |
String |
readString() |
int |
readToken() |
protected Object |
readType(int type) |
int |
readVInt() |
long |
readVLong() |
close, getComparatorFor, getInputStream, readIndexTuple, readTuple, readTuple, readTuplePair, readTuplePair
read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes
available, mark, markSupported, read, reset, skip
public HadoopTupleInputStream(InputStream inputStream, TupleInputStream.ElementReader elementReader)
public int getNumElements() throws IOException
getNumElements
in class TupleInputStream
IOException
public int readToken() throws IOException
readToken
in class TupleInputStream
IOException
public Object getNextElement() throws IOException
getNextElement
in class TupleInputStream
IOException
public IndexTuple readIndexTuple(IndexTuple indexTuple) throws IOException
readIndexTuple
in class TupleInputStream
IOException
public long readVLong() throws IOException
IOException
public int readVInt() throws IOException
IOException
public String readString() throws IOException
IOException
protected final Object readType(int type) throws IOException
readType
in class TupleInputStream
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.