public class JsonSerDe extends AbstractSerDe
configErrors
Constructor and Description |
---|
JsonSerDe() |
Modifier and Type | Method and Description |
---|---|
Object |
deserialize(org.apache.hadoop.io.Writable blob)
Takes JSON string in Text form, and has to return an object representation above
it that's readable by the corresponding object inspector.
|
String |
getHiveInternalColumnName(int fpos) |
ObjectInspector |
getObjectInspector()
Returns an object inspector for the specified schema that
is capable of reading in the object representation of the JSON string
|
int |
getPositionFromHiveInternalColumnName(String internalName) |
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.
|
org.apache.hadoop.io.Writable |
serialize(Object obj,
ObjectInspector objInspector)
Given an object and object inspector pair, traverse the object
and generate a Text representation of the object.
|
getConfigurationErrors, initialize, shouldStoreFieldsInMetastore
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 Object deserialize(org.apache.hadoop.io.Writable blob) throws SerDeException
deserialize
in interface Deserializer
deserialize
in class AbstractSerDe
blob
- The Writable object containing a serialized objectSerDeException
public String getHiveInternalColumnName(int fpos)
public int getPositionFromHiveInternalColumnName(String internalName)
public org.apache.hadoop.io.Writable serialize(Object obj, ObjectInspector objInspector) throws SerDeException
serialize
in interface Serializer
serialize
in class AbstractSerDe
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 © 2022 The Apache Software Foundation. All rights reserved.