public static class ConvertTreeReaderFactory.ConvertTreeReader extends TreeReaderFactory.TreeReader
columnId, present, valuePresent, vectorColumnCount
Modifier and Type | Method and Description |
---|---|
protected void |
assignStringGroupVectorEntry(BytesColumnVector bytesColVector,
int elementNum,
TypeDescription readerType,
byte[] bytes) |
protected void |
assignStringGroupVectorEntry(BytesColumnVector bytesColVector,
int elementNum,
TypeDescription readerType,
byte[] bytes,
int start,
int length) |
protected void |
convertStringGroupVectorElement(BytesColumnVector bytesColVector,
int elementNum,
TypeDescription readerType) |
void |
convertVector(ColumnVector fromColVector,
ColumnVector resultColVector,
int batchSize) |
boolean |
doubleCanFitInLong(double doubleValue) |
void |
downCastAnyInteger(LongColumnVector longColVector,
int elementNum,
long inputLong,
TypeDescription readerType) |
void |
downCastAnyInteger(LongColumnVector longColVector,
int elementNum,
TypeDescription readerType) |
protected boolean |
getIsParseError() |
protected TreeReaderFactory.TreeReader |
getStringGroupTreeReader(int columnId,
TypeDescription fileType) |
protected boolean |
integerDownCastNeeded(TypeDescription fileType,
TypeDescription readerType) |
protected Date |
parseDateFromString(String string) |
protected HiveDecimal |
parseDecimalFromString(String string) |
protected double |
parseDoubleFromString(String string) |
protected float |
parseFloatFromString(String string) |
protected long |
parseLongFromString(String string) |
protected Timestamp |
parseTimestampFromString(String string) |
void |
seek(PositionProvider index) |
protected void |
setConvertTreeReader(TreeReaderFactory.TreeReader convertTreeReader) |
void |
setConvertVectorElement(int elementNum)
Override this to use convertVector.
|
protected String |
stringFromBytesColumnVectorEntry(BytesColumnVector bytesColVector,
int elementNum) |
countNonNulls, getPresent, nextBatch, nextVector
protected void setConvertTreeReader(TreeReaderFactory.TreeReader convertTreeReader)
protected TreeReaderFactory.TreeReader getStringGroupTreeReader(int columnId, TypeDescription fileType) throws IOException
IOException
protected void assignStringGroupVectorEntry(BytesColumnVector bytesColVector, int elementNum, TypeDescription readerType, byte[] bytes)
protected void assignStringGroupVectorEntry(BytesColumnVector bytesColVector, int elementNum, TypeDescription readerType, byte[] bytes, int start, int length)
protected void convertStringGroupVectorElement(BytesColumnVector bytesColVector, int elementNum, TypeDescription readerType)
protected boolean getIsParseError()
protected long parseLongFromString(String string)
protected float parseFloatFromString(String string)
protected double parseDoubleFromString(String string)
protected HiveDecimal parseDecimalFromString(String string)
string
- protected Timestamp parseTimestampFromString(String string)
string
- protected Date parseDateFromString(String string)
string
- protected String stringFromBytesColumnVectorEntry(BytesColumnVector bytesColVector, int elementNum)
public boolean doubleCanFitInLong(double doubleValue)
public void seek(PositionProvider index) throws IOException
seek
in class TreeReaderFactory.TreeReader
IOException
public void setConvertVectorElement(int elementNum) throws IOException
elementNum
- IOException
public void convertVector(ColumnVector fromColVector, ColumnVector resultColVector, int batchSize) throws IOException
IOException
public void downCastAnyInteger(LongColumnVector longColVector, int elementNum, TypeDescription readerType)
public void downCastAnyInteger(LongColumnVector longColVector, int elementNum, long inputLong, TypeDescription readerType)
protected boolean integerDownCastNeeded(TypeDescription fileType, TypeDescription readerType)
Copyright © 2016 The Apache Software Foundation. All rights reserved.