public class AccumuloSerDe extends AbstractSerDe
configErrors
Constructor and Description |
---|
AccumuloSerDe() |
Modifier and Type | Method and Description |
---|---|
Object |
deserialize(org.apache.hadoop.io.Writable writable)
Deserialize an object out of a Writable blob.
|
LazyAccumuloRow |
getCachedRow()
For testing purposes.
|
protected ArrayList<ObjectInspector> |
getColumnObjectInspectors(List<TypeInfo> columnTypes,
LazySerDeParameters serDeParams,
List<ColumnMapping> mappings,
AccumuloRowIdFactory factory) |
boolean |
getIteratorPushdown() |
ObjectInspector |
getObjectInspector()
Get the object inspector that can be used to navigate through the internal
structure of the Object returned from deserialize(...).
|
AccumuloSerDeParameters |
getParams() |
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.
|
protected AccumuloRowSerializer |
getSerializer() |
void |
initialize(org.apache.hadoop.conf.Configuration conf,
Properties properties)
Initialize the HiveSerializer.
|
org.apache.hadoop.io.Writable |
serialize(Object o,
ObjectInspector objectInspector)
Serialize an object by navigating inside the Object with the
ObjectInspector.
|
getConfigurationErrors, initialize, shouldStoreFieldsInMetastore
public void initialize(org.apache.hadoop.conf.Configuration conf, Properties properties) throws SerDeException
AbstractSerDe
initialize
in interface Deserializer
initialize
in interface Serializer
initialize
in class AbstractSerDe
conf
- System properties. Can be null in compile timeproperties
- table propertiesSerDeException
protected ArrayList<ObjectInspector> getColumnObjectInspectors(List<TypeInfo> columnTypes, LazySerDeParameters serDeParams, List<ColumnMapping> mappings, AccumuloRowIdFactory factory) throws SerDeException
SerDeException
public LazyAccumuloRow getCachedRow()
public Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()
AbstractSerDe
getSerializedClass
in interface Serializer
getSerializedClass
in class AbstractSerDe
public org.apache.hadoop.io.Writable serialize(Object o, ObjectInspector objectInspector) throws SerDeException
AbstractSerDe
serialize
in interface Serializer
serialize
in class AbstractSerDe
SerDeException
public Object deserialize(org.apache.hadoop.io.Writable writable) throws SerDeException
AbstractSerDe
deserialize
in interface Deserializer
deserialize
in class AbstractSerDe
writable
- The Writable object containing a serialized objectSerDeException
public ObjectInspector getObjectInspector() throws SerDeException
AbstractSerDe
getObjectInspector
in interface Deserializer
getObjectInspector
in class AbstractSerDe
SerDeException
public SerDeStats getSerDeStats()
AbstractSerDe
getSerDeStats
in interface Deserializer
getSerDeStats
in interface Serializer
getSerDeStats
in class AbstractSerDe
public AccumuloSerDeParameters getParams()
public boolean getIteratorPushdown()
protected AccumuloRowSerializer getSerializer()
Copyright © 2021 The Apache Software Foundation. All rights reserved.