org.apache.hadoop.hive.serde2.lazy.fast

Class LazySimpleDeserializeRead

java.lang.Object

org.apache.hadoop.hive.serde2.fast.DeserializeRead

org.apache.hadoop.hive.serde2.lazy.fast.LazySimpleDeserializeRead

public final class LazySimpleDeserializeRead
extends DeserializeRead

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hive.serde2.fast.DeserializeRead

categories, currentBoolean, currentByte, currentBytes, currentBytesLength, currentBytesStart, currentDateWritable, currentDecimal64, currentDouble, currentExternalBufferNeeded, currentExternalBufferNeededLen, currentFloat, currentHiveDecimalWritable, currentHiveIntervalDayTimeWritable, currentHiveIntervalYearMonthWritable, currentInt, currentLong, currentShort, currentTimestampWritable, dataTypePhysicalVariations, primitiveCategories, typeInfos, useExternalBuffer

Constructor Summary

Constructors

Constructor and Description
LazySimpleDeserializeRead(TypeInfo[] typeInfos, boolean useExternalBuffer, LazySerDeParameters lazyParams)
LazySimpleDeserializeRead(TypeInfo[] typeInfos, org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] dataTypePhysicalVariations, boolean useExternalBuffer, LazySerDeParameters lazyParams)

Method Summary

Modifier and Type	Method and Description
static int	byteArrayCompareRanges(byte[] arg1, int start1, byte[] arg2, int start2, int len)
void	copyToExternalBuffer(byte[] externalBuffer, int externalBufferStart)
void	finishComplexVariableFieldsType()
String	getDetailedReadPositionString()
boolean	isEndOfInputReached()
boolean	isNextComplexMultiValue()
boolean	isReadFieldSupported()
void	logExceptionMessage(byte[] bytes, int bytesStart, int bytesLength, ObjectInspector.Category dataComplexCategory, PrimitiveObjectInspector.PrimitiveCategory dataPrimitiveCategory)
void	logExceptionMessage(byte[] bytes, int bytesStart, int bytesLength, String dataType)
boolean	readComplexField()
boolean	readField(int fieldIndex)
boolean	readNextField()
void	set(byte[] bytes, int offset, int length)
void	skipNextField()

Methods inherited from class org.apache.hadoop.hive.serde2.fast.DeserializeRead

getDataTypePhysicalVariations, typeInfos

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

LazySimpleDeserializeRead

public LazySimpleDeserializeRead(TypeInfo[] typeInfos,
                                 org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] dataTypePhysicalVariations,
                                 boolean useExternalBuffer,
                                 LazySerDeParameters lazyParams)

LazySimpleDeserializeRead

public LazySimpleDeserializeRead(TypeInfo[] typeInfos,
                                 boolean useExternalBuffer,
                                 LazySerDeParameters lazyParams)

Method Detail

set

public void set(byte[] bytes,
                int offset,
                int length)

Specified by:

set in class DeserializeRead

getDetailedReadPositionString

public String getDetailedReadPositionString()

Specified by:

getDetailedReadPositionString in class DeserializeRead

readNextField

public boolean readNextField()
                      throws IOException

Specified by:

readNextField in class DeserializeRead

Throws:

IOException

skipNextField

public void skipNextField()
                   throws IOException

Specified by:

skipNextField in class DeserializeRead

Throws:

IOException

isReadFieldSupported

public boolean isReadFieldSupported()

Overrides:

isReadFieldSupported in class DeserializeRead

readField

public boolean readField(int fieldIndex)
                  throws IOException

Overrides:

readField in class DeserializeRead

Throws:

IOException

copyToExternalBuffer

public void copyToExternalBuffer(byte[] externalBuffer,
                                 int externalBufferStart)

Overrides:

copyToExternalBuffer in class DeserializeRead

isNextComplexMultiValue

public boolean isNextComplexMultiValue()

Specified by:

isNextComplexMultiValue in class DeserializeRead

readComplexField

public boolean readComplexField()
                         throws IOException

Specified by:

readComplexField in class DeserializeRead

Throws:

IOException

finishComplexVariableFieldsType

public void finishComplexVariableFieldsType()

Specified by:

finishComplexVariableFieldsType in class DeserializeRead

isEndOfInputReached

public boolean isEndOfInputReached()

Specified by:

isEndOfInputReached in class DeserializeRead

logExceptionMessage

public void logExceptionMessage(byte[] bytes,
                                int bytesStart,
                                int bytesLength,
                                ObjectInspector.Category dataComplexCategory,
                                PrimitiveObjectInspector.PrimitiveCategory dataPrimitiveCategory)

logExceptionMessage

public void logExceptionMessage(byte[] bytes,
                                int bytesStart,
                                int bytesLength,
                                String dataType)

byteArrayCompareRanges

public static int byteArrayCompareRanges(byte[] arg1,
                                         int start1,
                                         byte[] arg2,
                                         int start2,
                                         int len)