public class EsSerDe extends AbstractSerDe
configErrors| Constructor and Description |
|---|
EsSerDe() |
| Modifier and Type | Method and Description |
|---|---|
Object |
deserialize(Writable blob) |
ObjectInspector |
getObjectInspector() |
SerDeStats |
getSerDeStats() |
Class<? extends Writable> |
getSerializedClass() |
void |
initialize(Configuration conf,
Properties tbl) |
void |
initialize(Configuration conf,
Properties tbl,
Properties partitionProperties) |
Writable |
serialize(Object data,
ObjectInspector objInspector) |
getConfigurationErrorspublic void initialize(Configuration conf, Properties tbl, Properties partitionProperties) throws SerDeException
initialize in class AbstractSerDeSerDeExceptionpublic void initialize(Configuration conf, Properties tbl) throws SerDeException
initialize in interface Deserializerinitialize in interface Serializerinitialize in class AbstractSerDeSerDeExceptionpublic Object deserialize(Writable blob) throws SerDeException
deserialize in interface Deserializerdeserialize in class AbstractSerDeSerDeExceptionpublic ObjectInspector getObjectInspector() throws SerDeException
getObjectInspector in interface DeserializergetObjectInspector in class AbstractSerDeSerDeExceptionpublic SerDeStats getSerDeStats()
getSerDeStats in interface DeserializergetSerDeStats in interface SerializergetSerDeStats in class AbstractSerDepublic Class<? extends Writable> getSerializedClass()
getSerializedClass in interface SerializergetSerializedClass in class AbstractSerDepublic Writable serialize(Object data, ObjectInspector objInspector) throws SerDeException
serialize in interface Serializerserialize in class AbstractSerDeSerDeException