public class HadoopTupleInputStream extends TupleInputStream
TupleInputStream.ElementReader, TupleInputStream.TupleElementReader<T extends TupleInputStream>
elementReader, inputStream
in
Constructor and Description |
---|
HadoopTupleInputStream(InputStream inputStream,
TupleInputStream.ElementReader elementReader) |
Modifier and Type | Method and Description |
---|---|
Object |
getNextElement() |
int |
getNumElements() |
static TupleInputStream.TupleElementReader[] |
getReadersFor(TupleInputStream.ElementReader elementReader,
Class[] classes) |
IndexTuple |
readIndexTuple(IndexTuple tuple) |
Integer |
readNullVInt() |
Long |
readNullVLong() |
String |
readString() |
int |
readToken() |
Object |
readType(Class type) |
protected Object |
readType(int type) |
int |
readVInt() |
long |
readVLong() |
close, getComparatorFor, getInputStream, readIndexTuple, readTuple, readTuple, readTuplePair, readTuplePair, readTyped, readUnTyped, readWith
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 static TupleInputStream.TupleElementReader[] getReadersFor(TupleInputStream.ElementReader elementReader, Class[] classes)
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 tuple) throws IOException
readIndexTuple
in class TupleInputStream
IOException
public Long readNullVLong() throws IOException
IOException
public long readVLong() throws IOException
IOException
public Integer readNullVInt() 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
public final Object readType(Class type) throws IOException
readType
in class TupleInputStream
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.