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