com.splicemachine.mrio.api.hive

Class SMSerDe

java.lang.Object

com.splicemachine.mrio.api.hive.SMSerDe

All Implemented Interfaces:

org.apache.hadoop.hive.serde2.Deserializer, org.apache.hadoop.hive.serde2.SerDe, org.apache.hadoop.hive.serde2.Serializer

public class SMSerDe
extends java.lang.Object
implements org.apache.hadoop.hive.serde2.SerDe

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<java.lang.String>	colNames
protected java.util.List<org.apache.hadoop.hive.serde2.typeinfo.TypeInfo>	colTypes
protected static org.apache.log4j.Logger	Log
protected java.util.List<java.lang.Object>	objectCache
protected org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	rowOI
protected org.apache.hadoop.hive.serde2.typeinfo.StructTypeInfo	rowTypeInfo
protected SMSQLUtil	sqlUtil
protected java.lang.String	tableName

Constructor Summary

Constructors

Constructor and Description
SMSerDe()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	deserialize(org.apache.hadoop.io.Writable blob) This method does the work of deserializing a record into Java objects that Hive can work with via the ObjectInspector interface.
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	getObjectInspector() Return an ObjectInspector for the row of data
org.apache.hadoop.hive.serde2.SerDeStats	getSerDeStats() Unimplemented
java.lang.Class<? extends org.apache.hadoop.io.Writable>	getSerializedClass() Return the class that stores the serialized data representation.
void	initialize(org.apache.hadoop.conf.Configuration conf, java.util.Properties tbl) An initialization function used to gather information about the table.
org.apache.hadoop.io.Writable	serialize(java.lang.Object obj, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi) This method takes an object representing a row of data from Hive, and uses the ObjectInspector to get the data for each column and serialize it.

Methods inherited from class java.lang.Object

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

Field Detail

rowTypeInfo

protected org.apache.hadoop.hive.serde2.typeinfo.StructTypeInfo rowTypeInfo

rowOI

protected org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector rowOI

sqlUtil

protected SMSQLUtil sqlUtil

colNames

protected java.util.List<java.lang.String> colNames

colTypes

protected java.util.List<org.apache.hadoop.hive.serde2.typeinfo.TypeInfo> colTypes

Log

protected static org.apache.log4j.Logger Log

objectCache

protected java.util.List<java.lang.Object> objectCache

tableName

protected java.lang.String tableName

Constructor Detail

SMSerDe

public SMSerDe()

Method Detail

initialize

public void initialize(org.apache.hadoop.conf.Configuration conf,
                       java.util.Properties tbl)
                throws org.apache.hadoop.hive.serde2.SerDeException

An initialization function used to gather information about the table. Typically, a SerDe implementation will be interested in the list of column names and their types. That information will be used to help perform actual serialization and deserialization of data.

Specified by:

initialize in interface org.apache.hadoop.hive.serde2.Deserializer

Specified by:

initialize in interface org.apache.hadoop.hive.serde2.Serializer

Throws:

org.apache.hadoop.hive.serde2.SerDeException

deserialize

public java.lang.Object deserialize(org.apache.hadoop.io.Writable blob)
                             throws org.apache.hadoop.hive.serde2.SerDeException

This method does the work of deserializing a record into Java objects that Hive can work with via the ObjectInspector interface.

Specified by:

deserialize in interface org.apache.hadoop.hive.serde2.Deserializer

Throws:

org.apache.hadoop.hive.serde2.SerDeException

getObjectInspector

public org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector()
                                                                                 throws org.apache.hadoop.hive.serde2.SerDeException

Return an ObjectInspector for the row of data

Specified by:

getObjectInspector in interface org.apache.hadoop.hive.serde2.Deserializer

Throws:

org.apache.hadoop.hive.serde2.SerDeException

getSerDeStats

public org.apache.hadoop.hive.serde2.SerDeStats getSerDeStats()

Unimplemented

Specified by:

getSerDeStats in interface org.apache.hadoop.hive.serde2.Deserializer

Specified by:

getSerDeStats in interface org.apache.hadoop.hive.serde2.Serializer

getSerializedClass

public java.lang.Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()

Return the class that stores the serialized data representation.

Specified by:

getSerializedClass in interface org.apache.hadoop.hive.serde2.Serializer

serialize

public org.apache.hadoop.io.Writable serialize(java.lang.Object obj,
                                               org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
                                        throws org.apache.hadoop.hive.serde2.SerDeException

This method takes an object representing a row of data from Hive, and uses the ObjectInspector to get the data for each column and serialize it.

Specified by:

serialize in interface org.apache.hadoop.hive.serde2.Serializer

Throws:

org.apache.hadoop.hive.serde2.SerDeException