public class TableSerDe extends Object
Modifier and Type | Field and Description |
---|---|
protected List<Object> |
hiveRow |
protected MapWritable |
kvMapWritable |
Constructor and Description |
---|
TableSerDe() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector |
createObjectInspector() |
Object |
deserialize(Writable field)
Deserializes the given Writable parameter and returns a Java Object
representing the contents of that parameter.
|
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector |
getObjectInspector()
Returns the ObjectInspector that can be used to navigate through the
internal structure of the Object returned from the deserialize method.
|
org.apache.hadoop.hive.serde2.SerDeStats |
getSerDeStats()
Returns statistics collected when deserializing and/or serializing.
|
Class<? extends Writable> |
getSerializedClass()
Return the Writable class returned by the serialize method; which is
used to initialize the SequenceFile header.
|
void |
initialize(Configuration job,
Properties tbl) |
Writable |
serialize(Object obj,
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector)
Serialize the given Object by navigating inside the Object with the
given ObjectInspector.
|
protected void |
setStore(KVStore testStore)
For testing only; to support the use of a mocked store.
|
String |
toString() |
protected void |
validateParams(Properties tbl)
Verifies that the names and types of the fields in the KV Store
table correctly map to the names and types of the Hive table
against which the Hive query is to be executed.
|
protected MapWritable kvMapWritable
protected void validateParams(Properties tbl) throws org.apache.hadoop.hive.serde2.SerDeException
protected org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector createObjectInspector() throws org.apache.hadoop.hive.serde2.SerDeException
public Object deserialize(Writable field) throws org.apache.hadoop.hive.serde2.SerDeException
deserialize
in interface org.apache.hadoop.hive.serde2.Deserializer
field
- The Writable object containing a serialized object from
a row of the KVStore table with name specified by tableName.org.apache.hadoop.hive.serde2.SerDeException
public Writable serialize(Object obj, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector) throws org.apache.hadoop.hive.serde2.SerDeException
serialize
in interface org.apache.hadoop.hive.serde2.Serializer
obj
- The Object whose contents are examined and from which the
return value is constructed.objectInspector
- The object to use to navigate the given Object's
contents.org.apache.hadoop.hive.serde2.SerDeException
public void initialize(Configuration job, Properties tbl) throws org.apache.hadoop.hive.serde2.SerDeException
initialize
in interface org.apache.hadoop.hive.serde2.Deserializer
initialize
in interface org.apache.hadoop.hive.serde2.Serializer
org.apache.hadoop.hive.serde2.SerDeException
public org.apache.hadoop.hive.serde2.SerDeStats getSerDeStats()
getSerDeStats
in interface org.apache.hadoop.hive.serde2.Deserializer
getSerDeStats
in interface org.apache.hadoop.hive.serde2.Serializer
public org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector() throws org.apache.hadoop.hive.serde2.SerDeException
getObjectInspector
in interface org.apache.hadoop.hive.serde2.Deserializer
org.apache.hadoop.hive.serde2.SerDeException
public Class<? extends Writable> getSerializedClass()
getSerializedClass
in interface org.apache.hadoop.hive.serde2.Serializer
protected void setStore(KVStore testStore)
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.