public class HCatRecordSerDe extends AbstractSerDe
configErrors
Constructor and Description |
---|
HCatRecordSerDe() |
Modifier and Type | Method and Description |
---|---|
Object |
deserialize(org.apache.hadoop.io.Writable data)
The purpose of a deserialize method is to turn a data blob
which is a writable representation of the data into an
object that can then be parsed using the appropriate
ObjectInspector.
|
ObjectInspector |
getObjectInspector()
Return an object inspector that can read through the object
that we return from deserialize().
|
SerDeStats |
getSerDeStats()
Returns statistics collected when serializing
|
Class<? extends org.apache.hadoop.io.Writable> |
getSerializedClass()
Returns the Writable class that would be returned by the serialize method.
|
void |
initialize(org.apache.hadoop.conf.Configuration conf,
Properties tbl)
Initialize the HiveSerializer.
|
void |
initialize(HCatSchema hsch) |
org.apache.hadoop.io.Writable |
serialize(Object obj,
ObjectInspector objInspector)
The purpose of the serialize method is to turn an object-representation
with a provided ObjectInspector into a Writable format, which
the underlying layer can then use to write out.
|
static Object |
serializeField(Object field,
ObjectInspector fieldObjectInspector)
Return underlying Java Object from an object-representation
that is readable by a provided ObjectInspector.
|
getConfigurationErrors, initialize, shouldStoreFieldsInMetastore
public HCatRecordSerDe() throws SerDeException
SerDeException
public void initialize(org.apache.hadoop.conf.Configuration conf, Properties tbl) throws SerDeException
AbstractSerDe
initialize
in interface Deserializer
initialize
in interface Serializer
initialize
in class AbstractSerDe
conf
- System properties. Can be null in compile timetbl
- table propertiesSerDeException
public void initialize(HCatSchema hsch) throws SerDeException
SerDeException
public Object deserialize(org.apache.hadoop.io.Writable data) throws SerDeException
deserialize
in interface Deserializer
deserialize
in class AbstractSerDe
data
- The Writable object containing a serialized objectSerDeException
public org.apache.hadoop.io.Writable serialize(Object obj, ObjectInspector objInspector) throws SerDeException
serialize
in interface Serializer
serialize
in class AbstractSerDe
SerDeException
public static Object serializeField(Object field, ObjectInspector fieldObjectInspector) throws SerDeException
SerDeException
public ObjectInspector getObjectInspector() throws SerDeException
getObjectInspector
in interface Deserializer
getObjectInspector
in class AbstractSerDe
SerDeException
public Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()
AbstractSerDe
getSerializedClass
in interface Serializer
getSerializedClass
in class AbstractSerDe
public SerDeStats getSerDeStats()
AbstractSerDe
getSerDeStats
in interface Deserializer
getSerDeStats
in interface Serializer
getSerDeStats
in class AbstractSerDe
Copyright © 2019 The Apache Software Foundation. All rights reserved.