public final class LazySimpleDeserializeRead extends DeserializeRead
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
categories, currentBoolean, currentByte, currentBytes, currentBytesLength, currentBytesStart, currentDateWritable, currentDouble, currentExternalBufferNeeded, currentExternalBufferNeededLen, currentFloat, currentHiveDecimalWritable, currentHiveIntervalDayTimeWritable, currentHiveIntervalYearMonthWritable, currentInt, currentLong, currentShort, currentTimestampWritable, primitiveCategories, typeInfos, useExternalBuffer
Constructor and Description |
---|
LazySimpleDeserializeRead(TypeInfo[] typeInfos,
boolean useExternalBuffer,
byte separator,
LazySerDeParameters lazyParams) |
LazySimpleDeserializeRead(TypeInfo[] typeInfos,
boolean useExternalBuffer,
LazySerDeParameters lazyParams) |
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) |
String |
getDetailedReadPositionString() |
boolean |
isEndOfInputReached() |
boolean |
isReadFieldSupported() |
void |
logExceptionMessage(byte[] bytes,
int bytesStart,
int bytesLength,
PrimitiveObjectInspector.PrimitiveCategory dataCategory) |
void |
logExceptionMessage(byte[] bytes,
int bytesStart,
int bytesLength,
String dataType) |
boolean |
readField(int fieldIndex) |
boolean |
readNextField() |
void |
set(byte[] bytes,
int offset,
int length) |
void |
skipNextField() |
typeInfos
public LazySimpleDeserializeRead(TypeInfo[] typeInfos, boolean useExternalBuffer, byte separator, LazySerDeParameters lazyParams)
public LazySimpleDeserializeRead(TypeInfo[] typeInfos, boolean useExternalBuffer, LazySerDeParameters lazyParams)
public void set(byte[] bytes, int offset, int length)
set
in class DeserializeRead
public String getDetailedReadPositionString()
getDetailedReadPositionString
in class DeserializeRead
public boolean readNextField() throws IOException
readNextField
in class DeserializeRead
IOException
public void skipNextField() throws IOException
skipNextField
in class DeserializeRead
IOException
public boolean isReadFieldSupported()
isReadFieldSupported
in class DeserializeRead
public boolean readField(int fieldIndex) throws IOException
readField
in class DeserializeRead
IOException
public void copyToExternalBuffer(byte[] externalBuffer, int externalBufferStart)
copyToExternalBuffer
in class DeserializeRead
public boolean isEndOfInputReached()
isEndOfInputReached
in class DeserializeRead
public void logExceptionMessage(byte[] bytes, int bytesStart, int bytesLength, PrimitiveObjectInspector.PrimitiveCategory dataCategory)
public void logExceptionMessage(byte[] bytes, int bytesStart, int bytesLength, String dataType)
public static int byteArrayCompareRanges(byte[] arg1, int start1, byte[] arg2, int start2, int len)
Copyright © 2021 The Apache Software Foundation. All rights reserved.