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

Class LazySimpleSerializeWrite

java.lang.Object

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

All Implemented Interfaces:

SerializeWrite

public final class LazySimpleSerializeWrite
extends Object
implements SerializeWrite

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
LazySimpleSerializeWrite(int fieldCount, LazySerDeParameters lazyParams)

Method Summary

Modifier and Type	Method and Description
void	beginList(List list)
void	beginMap(Map<?,?> map)
void	beginStruct(List fieldValues)
void	beginUnion(int tag)
void	finishList()
void	finishMap()
void	finishStruct()
void	finishUnion()
void	reset()
void	separateKey()
void	separateKeyValuePair()
void	separateList()
void	separateStruct()
void	set(ByteStream.Output output)
void	setAppend(ByteStream.Output output)
void	writeBinary(byte[] v)
void	writeBinary(byte[] v, int start, int length)
void	writeBoolean(boolean v)
void	writeByte(byte v)
void	writeDate(Date date)
void	writeDate(int dateAsDays)
void	writeDecimal64(long decimal64Long, int scale)
void	writeDouble(double v)
void	writeFloat(float vf)
void	writeHiveChar(HiveChar hiveChar)
void	writeHiveDecimal(org.apache.hadoop.hive.common.type.HiveDecimal dec, int scale)
void	writeHiveDecimal(org.apache.hadoop.hive.serde2.io.HiveDecimalWritable decWritable, int scale)
void	writeHiveIntervalDayTime(org.apache.hadoop.hive.common.type.HiveIntervalDayTime vidt)
void	writeHiveIntervalYearMonth(HiveIntervalYearMonth viyt)
void	writeHiveIntervalYearMonth(int totalMonths)
void	writeHiveVarchar(HiveVarchar hiveVarchar)
void	writeInt(int v)
void	writeLong(long v)
void	writeNull()
void	writeShort(short v)
void	writeString(byte[] v)
void	writeString(byte[] v, int start, int length)
void	writeTimestamp(Timestamp v)

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

LazySimpleSerializeWrite

public LazySimpleSerializeWrite(int fieldCount,
                                LazySerDeParameters lazyParams)

Method Detail

set

public void set(ByteStream.Output output)

Specified by:

set in interface SerializeWrite

setAppend

public void setAppend(ByteStream.Output output)

Specified by:

setAppend in interface SerializeWrite

reset

public void reset()

Specified by:

reset in interface SerializeWrite

writeNull

public void writeNull()
               throws IOException

Specified by:

writeNull in interface SerializeWrite

Throws:

IOException

writeBoolean

public void writeBoolean(boolean v)
                  throws IOException

Specified by:

writeBoolean in interface SerializeWrite

Throws:

IOException

writeByte

public void writeByte(byte v)
               throws IOException

Specified by:

writeByte in interface SerializeWrite

Throws:

IOException

writeShort

public void writeShort(short v)
                throws IOException

Specified by:

writeShort in interface SerializeWrite

Throws:

IOException

writeInt

public void writeInt(int v)
              throws IOException

Specified by:

writeInt in interface SerializeWrite

Throws:

IOException

writeLong

public void writeLong(long v)
               throws IOException

Specified by:

writeLong in interface SerializeWrite

Throws:

IOException

writeFloat

public void writeFloat(float vf)
                throws IOException

Specified by:

writeFloat in interface SerializeWrite

Throws:

IOException

writeDouble

public void writeDouble(double v)
                 throws IOException

Specified by:

writeDouble in interface SerializeWrite

Throws:

IOException

writeString

public void writeString(byte[] v)
                 throws IOException

Specified by:

writeString in interface SerializeWrite

Throws:

IOException

writeString

public void writeString(byte[] v,
                        int start,
                        int length)
                 throws IOException

Specified by:

writeString in interface SerializeWrite

Throws:

IOException

writeHiveChar

public void writeHiveChar(HiveChar hiveChar)
                   throws IOException

Specified by:

writeHiveChar in interface SerializeWrite

Throws:

IOException

writeHiveVarchar

public void writeHiveVarchar(HiveVarchar hiveVarchar)
                      throws IOException

Specified by:

writeHiveVarchar in interface SerializeWrite

Throws:

IOException

writeBinary

public void writeBinary(byte[] v)
                 throws IOException

Specified by:

writeBinary in interface SerializeWrite

Throws:

IOException

writeBinary

public void writeBinary(byte[] v,
                        int start,
                        int length)
                 throws IOException

Specified by:

writeBinary in interface SerializeWrite

Throws:

IOException

writeDate

public void writeDate(Date date)
               throws IOException

Specified by:

writeDate in interface SerializeWrite

Throws:

IOException

writeDate

public void writeDate(int dateAsDays)
               throws IOException

Specified by:

writeDate in interface SerializeWrite

Throws:

IOException

writeTimestamp

public void writeTimestamp(Timestamp v)
                    throws IOException

Specified by:

writeTimestamp in interface SerializeWrite

Throws:

IOException

writeHiveIntervalYearMonth

public void writeHiveIntervalYearMonth(HiveIntervalYearMonth viyt)
                                throws IOException

Specified by:

writeHiveIntervalYearMonth in interface SerializeWrite

Throws:

IOException

writeHiveIntervalYearMonth

public void writeHiveIntervalYearMonth(int totalMonths)
                                throws IOException

Specified by:

writeHiveIntervalYearMonth in interface SerializeWrite

Throws:

IOException

writeHiveIntervalDayTime

public void writeHiveIntervalDayTime(org.apache.hadoop.hive.common.type.HiveIntervalDayTime vidt)
                              throws IOException

Specified by:

writeHiveIntervalDayTime in interface SerializeWrite

Throws:

IOException

writeDecimal64

public void writeDecimal64(long decimal64Long,
                           int scale)
                    throws IOException

Specified by:

writeDecimal64 in interface SerializeWrite

Throws:

IOException

writeHiveDecimal

public void writeHiveDecimal(org.apache.hadoop.hive.common.type.HiveDecimal dec,
                             int scale)
                      throws IOException

Specified by:

writeHiveDecimal in interface SerializeWrite

Throws:

IOException

writeHiveDecimal

public void writeHiveDecimal(org.apache.hadoop.hive.serde2.io.HiveDecimalWritable decWritable,
                             int scale)
                      throws IOException

Specified by:

writeHiveDecimal in interface SerializeWrite

Throws:

IOException

beginList

public void beginList(List list)

Specified by:

beginList in interface SerializeWrite

separateList

public void separateList()

Specified by:

separateList in interface SerializeWrite

finishList

public void finishList()

Specified by:

finishList in interface SerializeWrite

beginMap

public void beginMap(Map<?,?> map)

Specified by:

beginMap in interface SerializeWrite

separateKey

public void separateKey()

Specified by:

separateKey in interface SerializeWrite

separateKeyValuePair

public void separateKeyValuePair()

Specified by:

separateKeyValuePair in interface SerializeWrite

finishMap

public void finishMap()

Specified by:

finishMap in interface SerializeWrite

beginStruct

public void beginStruct(List fieldValues)

Specified by:

beginStruct in interface SerializeWrite

separateStruct

public void separateStruct()

Specified by:

separateStruct in interface SerializeWrite

finishStruct

public void finishStruct()

Specified by:

finishStruct in interface SerializeWrite

beginUnion

public void beginUnion(int tag)
                throws IOException

Specified by:

beginUnion in interface SerializeWrite

Throws:

IOException

finishUnion

public void finishUnion()

Specified by:

finishUnion in interface SerializeWrite