public class EsSerDe extends java.lang.Object implements SerDe
| Constructor and Description |
|---|
EsSerDe() |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Object |
deserialize(org.apache.hadoop.io.Writable blob) |
ObjectInspector |
getObjectInspector() |
SerDeStats |
getSerDeStats() |
java.lang.Class<? extends org.apache.hadoop.io.Writable> |
getSerializedClass() |
void |
initialize(org.apache.hadoop.conf.Configuration conf,
java.util.Properties tbl) |
org.apache.hadoop.io.Writable |
serialize(java.lang.Object data,
ObjectInspector objInspector) |
public void initialize(org.apache.hadoop.conf.Configuration conf,
java.util.Properties tbl)
throws SerDeException
initialize in interface Deserializerinitialize in interface SerializerSerDeExceptionpublic java.lang.Object deserialize(org.apache.hadoop.io.Writable blob)
throws SerDeException
deserialize in interface DeserializerSerDeExceptionpublic ObjectInspector getObjectInspector() throws SerDeException
getObjectInspector in interface DeserializerSerDeExceptionpublic SerDeStats getSerDeStats()
getSerDeStats in interface DeserializergetSerDeStats in interface Serializerpublic java.lang.Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()
getSerializedClass in interface Serializerpublic org.apache.hadoop.io.Writable serialize(java.lang.Object data,
ObjectInspector objInspector)
throws SerDeException
serialize in interface SerializerSerDeException