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

Class LazySimpleDeserializeRead

java.lang.Object

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

All Implemented Interfaces:

DeserializeRead

public class LazySimpleDeserializeRead
extends Object
implements DeserializeRead

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.serde2.fast.DeserializeRead

DeserializeRead.ReadBinaryResults, DeserializeRead.ReadBytesResults, DeserializeRead.ReadDateResults, DeserializeRead.ReadDecimalResults, DeserializeRead.ReadHiveCharResults, DeserializeRead.ReadHiveVarcharResults, DeserializeRead.ReadIntervalDayTimeResults, DeserializeRead.ReadIntervalYearMonthResults, DeserializeRead.ReadStringResults, DeserializeRead.ReadTimestampResults

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Constructor and Description
LazySimpleDeserializeRead(PrimitiveTypeInfo[] primitiveTypeInfos, byte separator, LazySerDeParameters lazyParams)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	bufferRangeHasExtraDataWarned()
static int	byteArrayCompareRanges(byte[] arg1, int start1, byte[] arg2, int start2, int len)
DeserializeRead.ReadBinaryResults	createReadBinaryResults()
DeserializeRead.ReadDateResults	createReadDateResults()
DeserializeRead.ReadDecimalResults	createReadDecimalResults()
DeserializeRead.ReadHiveCharResults	createReadHiveCharResults()
DeserializeRead.ReadHiveVarcharResults	createReadHiveVarcharResults()
DeserializeRead.ReadIntervalDayTimeResults	createReadIntervalDayTimeResults()
DeserializeRead.ReadIntervalYearMonthResults	createReadIntervalYearMonthResults()
DeserializeRead.ReadStringResults	createReadStringResults()
DeserializeRead.ReadTimestampResults	createReadTimestampResults()
void	extraFieldsCheck()
void	logExceptionMessage(byte[] bytes, int bytesStart, int bytesLength, String dataType)
PrimitiveTypeInfo[]	primitiveTypeInfos()
boolean	readBeyondBufferRangeWarned()
boolean	readBeyondConfiguredFieldsWarned()
void	readBinary(DeserializeRead.ReadBinaryResults readBinaryResults)
boolean	readBoolean()
byte	readByte()
boolean	readCheckNull()
void	readDate(DeserializeRead.ReadDateResults readDateResults)
double	readDouble()
float	readFloat()
void	readHiveChar(DeserializeRead.ReadHiveCharResults readHiveCharResults)
void	readHiveDecimal(DeserializeRead.ReadDecimalResults readDecimalResults)
void	readHiveVarchar(DeserializeRead.ReadHiveVarcharResults readHiveVarcharResults)
int	readInt()
void	readIntervalDayTime(DeserializeRead.ReadIntervalDayTimeResults readIntervalDayTimeResults)
void	readIntervalYearMonth(DeserializeRead.ReadIntervalYearMonthResults readIntervalYearMonthResults)
long	readLong()
short	readShort()
void	readString(DeserializeRead.ReadStringResults readStringResults)
void	readTimestamp(DeserializeRead.ReadTimestampResults readTimestampResults)
void	set(byte[] bytes, int offset, int length)

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.apache.commons.logging.Log LOG

Constructor Detail

LazySimpleDeserializeRead

public LazySimpleDeserializeRead(PrimitiveTypeInfo[] primitiveTypeInfos,
                         byte separator,
                         LazySerDeParameters lazyParams)

Method Detail

primitiveTypeInfos

public PrimitiveTypeInfo[] primitiveTypeInfos()

Specified by:

primitiveTypeInfos in interface DeserializeRead

set

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

Specified by:

set in interface DeserializeRead

readCheckNull

public boolean readCheckNull()

Specified by:

readCheckNull in interface DeserializeRead

logExceptionMessage

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

extraFieldsCheck

public void extraFieldsCheck()

Specified by:

extraFieldsCheck in interface DeserializeRead

readBeyondConfiguredFieldsWarned

public boolean readBeyondConfiguredFieldsWarned()

Specified by:

readBeyondConfiguredFieldsWarned in interface DeserializeRead

readBeyondBufferRangeWarned

public boolean readBeyondBufferRangeWarned()

Specified by:

readBeyondBufferRangeWarned in interface DeserializeRead

bufferRangeHasExtraDataWarned

public boolean bufferRangeHasExtraDataWarned()

Specified by:

bufferRangeHasExtraDataWarned in interface DeserializeRead

readBoolean

public boolean readBoolean()

Specified by:

readBoolean in interface DeserializeRead

readByte

public byte readByte()

Specified by:

readByte in interface DeserializeRead

readShort

public short readShort()

Specified by:

readShort in interface DeserializeRead

readInt

public int readInt()

Specified by:

readInt in interface DeserializeRead

readLong

public long readLong()

Specified by:

readLong in interface DeserializeRead

readFloat

public float readFloat()

Specified by:

readFloat in interface DeserializeRead

readDouble

public double readDouble()

Specified by:

readDouble in interface DeserializeRead

createReadStringResults

public DeserializeRead.ReadStringResults createReadStringResults()

Specified by:

createReadStringResults in interface DeserializeRead

readString

public void readString(DeserializeRead.ReadStringResults readStringResults)

Specified by:

readString in interface DeserializeRead

createReadHiveCharResults

public DeserializeRead.ReadHiveCharResults createReadHiveCharResults()

Specified by:

createReadHiveCharResults in interface DeserializeRead

readHiveChar

public void readHiveChar(DeserializeRead.ReadHiveCharResults readHiveCharResults)
                  throws IOException

Specified by:

readHiveChar in interface DeserializeRead

Throws:

IOException

createReadHiveVarcharResults

public DeserializeRead.ReadHiveVarcharResults createReadHiveVarcharResults()

Specified by:

createReadHiveVarcharResults in interface DeserializeRead

readHiveVarchar

public void readHiveVarchar(DeserializeRead.ReadHiveVarcharResults readHiveVarcharResults)
                     throws IOException

Specified by:

readHiveVarchar in interface DeserializeRead

Throws:

IOException

createReadBinaryResults

public DeserializeRead.ReadBinaryResults createReadBinaryResults()

Specified by:

createReadBinaryResults in interface DeserializeRead

readBinary

public void readBinary(DeserializeRead.ReadBinaryResults readBinaryResults)

Specified by:

readBinary in interface DeserializeRead

createReadDateResults

public DeserializeRead.ReadDateResults createReadDateResults()

Specified by:

createReadDateResults in interface DeserializeRead

readDate

public void readDate(DeserializeRead.ReadDateResults readDateResults)

Specified by:

readDate in interface DeserializeRead

createReadIntervalYearMonthResults

public DeserializeRead.ReadIntervalYearMonthResults createReadIntervalYearMonthResults()

Specified by:

createReadIntervalYearMonthResults in interface DeserializeRead

readIntervalYearMonth

public void readIntervalYearMonth(DeserializeRead.ReadIntervalYearMonthResults readIntervalYearMonthResults)
                           throws IOException

Specified by:

readIntervalYearMonth in interface DeserializeRead

Throws:

IOException

createReadIntervalDayTimeResults

public DeserializeRead.ReadIntervalDayTimeResults createReadIntervalDayTimeResults()

Specified by:

createReadIntervalDayTimeResults in interface DeserializeRead

readIntervalDayTime

public void readIntervalDayTime(DeserializeRead.ReadIntervalDayTimeResults readIntervalDayTimeResults)
                         throws IOException

Specified by:

readIntervalDayTime in interface DeserializeRead

Throws:

IOException

createReadTimestampResults

public DeserializeRead.ReadTimestampResults createReadTimestampResults()

Specified by:

createReadTimestampResults in interface DeserializeRead

readTimestamp

public void readTimestamp(DeserializeRead.ReadTimestampResults readTimestampResults)

Specified by:

readTimestamp in interface DeserializeRead

createReadDecimalResults

public DeserializeRead.ReadDecimalResults createReadDecimalResults()

Specified by:

createReadDecimalResults in interface DeserializeRead

readHiveDecimal

public void readHiveDecimal(DeserializeRead.ReadDecimalResults readDecimalResults)

Specified by:

readHiveDecimal in interface DeserializeRead

byteArrayCompareRanges

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