public final class LazySimpleDeserializeRead extends DeserializeRead
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
categories, columnsToInclude, currentBoolean, currentByte, currentBytes, currentBytesLength, currentBytesStart, currentDateWritable, currentDouble, currentFloat, currentHiveDecimalWritable, currentHiveIntervalDayTimeWritable, currentHiveIntervalYearMonthWritable, currentInt, currentLong, currentShort, currentTimestampWritable, primitiveCategories, typeInfos
Constructor and Description |
---|
LazySimpleDeserializeRead(TypeInfo[] typeInfos,
byte separator,
LazySerDeParameters lazyParams) |
LazySimpleDeserializeRead(TypeInfo[] typeInfos,
LazySerDeParameters lazyParams) |
Modifier and Type | Method and Description |
---|---|
boolean |
bufferRangeHasExtraDataWarned() |
static int |
byteArrayCompareRanges(byte[] arg1,
int start1,
byte[] arg2,
int start2,
int len) |
void |
extraFieldsCheck() |
String |
getDetailedReadPositionString() |
void |
logExceptionMessage(byte[] bytes,
int bytesStart,
int bytesLength,
String dataType) |
boolean |
readBeyondConfiguredFieldsWarned() |
boolean |
readCheckNull() |
void |
set(byte[] bytes,
int offset,
int length) |
setColumnsToInclude, typeInfos
public LazySimpleDeserializeRead(TypeInfo[] typeInfos, byte separator, LazySerDeParameters lazyParams)
public LazySimpleDeserializeRead(TypeInfo[] typeInfos, LazySerDeParameters lazyParams)
public void set(byte[] bytes, int offset, int length)
set
in class DeserializeRead
public String getDetailedReadPositionString()
getDetailedReadPositionString
in class DeserializeRead
public boolean readCheckNull()
readCheckNull
in class DeserializeRead
public void logExceptionMessage(byte[] bytes, int bytesStart, int bytesLength, String dataType)
public void extraFieldsCheck()
extraFieldsCheck
in class DeserializeRead
public boolean readBeyondConfiguredFieldsWarned()
readBeyondConfiguredFieldsWarned
in class DeserializeRead
public boolean bufferRangeHasExtraDataWarned()
bufferRangeHasExtraDataWarned
in class DeserializeRead
public static int byteArrayCompareRanges(byte[] arg1, int start1, byte[] arg2, int start2, int len)
Copyright © 2016 The Apache Software Foundation. All rights reserved.