public abstract class DeserializeRead extends Object
Modifier and Type | Field and Description |
---|---|
protected ObjectInspector.Category[] |
categories |
boolean |
currentBoolean |
byte |
currentByte |
byte[] |
currentBytes |
int |
currentBytesLength |
int |
currentBytesStart |
DateWritableV2 |
currentDateWritable |
long |
currentDecimal64 |
double |
currentDouble |
boolean |
currentExternalBufferNeeded |
int |
currentExternalBufferNeededLen |
float |
currentFloat |
org.apache.hadoop.hive.serde2.io.HiveDecimalWritable |
currentHiveDecimalWritable |
HiveIntervalDayTimeWritable |
currentHiveIntervalDayTimeWritable |
HiveIntervalYearMonthWritable |
currentHiveIntervalYearMonthWritable |
int |
currentInt |
long |
currentLong |
short |
currentShort |
TimestampWritableV2 |
currentTimestampWritable |
protected org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] |
dataTypePhysicalVariations |
protected PrimitiveObjectInspector.PrimitiveCategory[] |
primitiveCategories |
protected TypeInfo[] |
typeInfos |
protected boolean |
useExternalBuffer |
Modifier | Constructor and Description |
---|---|
protected |
DeserializeRead() |
|
DeserializeRead(TypeInfo[] typeInfos,
boolean useExternalBuffer) |
|
DeserializeRead(TypeInfo[] typeInfos,
org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] dataTypePhysicalVariations,
boolean useExternalBuffer)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
copyToExternalBuffer(byte[] externalBuffer,
int externalBufferStart) |
abstract void |
finishComplexVariableFieldsType() |
org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] |
getDataTypePhysicalVariations() |
abstract String |
getDetailedReadPositionString() |
abstract boolean |
isEndOfInputReached() |
abstract boolean |
isNextComplexMultiValue() |
boolean |
isReadFieldSupported() |
abstract boolean |
readComplexField() |
boolean |
readField(int fieldIndex) |
abstract boolean |
readNextField() |
abstract void |
set(byte[] bytes,
int offset,
int length) |
abstract void |
skipNextField() |
TypeInfo[] |
typeInfos() |
protected final TypeInfo[] typeInfos
protected org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] dataTypePhysicalVariations
protected final boolean useExternalBuffer
protected final ObjectInspector.Category[] categories
protected final PrimitiveObjectInspector.PrimitiveCategory[] primitiveCategories
public boolean currentBoolean
public byte currentByte
public short currentShort
public int currentInt
public long currentLong
public float currentFloat
public double currentDouble
public boolean currentExternalBufferNeeded
public int currentExternalBufferNeededLen
public byte[] currentBytes
public int currentBytesStart
public int currentBytesLength
public DateWritableV2 currentDateWritable
public TimestampWritableV2 currentTimestampWritable
public HiveIntervalYearMonthWritable currentHiveIntervalYearMonthWritable
public HiveIntervalDayTimeWritable currentHiveIntervalDayTimeWritable
public org.apache.hadoop.hive.serde2.io.HiveDecimalWritable currentHiveDecimalWritable
public long currentDecimal64
public DeserializeRead(TypeInfo[] typeInfos, org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] dataTypePhysicalVariations, boolean useExternalBuffer)
typeInfos
- dataTypePhysicalVariations
- Specify for each corresponding TypeInfo a read variation. Can be
null. dataTypePhysicalVariation.NONE is then assumed.useExternalBuffer
- Specify true when the caller is prepared to provide a bytes buffer
to receive a string/char/varchar/binary field that needs format
conversion.public DeserializeRead(TypeInfo[] typeInfos, boolean useExternalBuffer)
protected DeserializeRead()
public TypeInfo[] typeInfos()
public org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] getDataTypePhysicalVariations()
public abstract void set(byte[] bytes, int offset, int length)
public abstract boolean readNextField() throws IOException
IOException
public abstract void skipNextField() throws IOException
IOException
public boolean isReadFieldSupported()
public boolean readField(int fieldIndex) throws IOException
IOException
public abstract boolean isNextComplexMultiValue() throws IOException
IOException
public abstract boolean readComplexField() throws IOException
IOException
public abstract void finishComplexVariableFieldsType()
public abstract boolean isEndOfInputReached()
public abstract String getDetailedReadPositionString()
public void copyToExternalBuffer(byte[] externalBuffer, int externalBufferStart) throws IOException
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.