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