public class S3LogDeserializer extends AbstractSerDe
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
configuration, log, partitionProperties, properties, tableProperties
Constructor and Description |
---|
S3LogDeserializer() |
Modifier and Type | Method and Description |
---|---|
static Object |
deserialize(S3LogStruct c,
String row) |
Object |
deserialize(org.apache.hadoop.io.Writable field)
Deserialize an object out of a Writable blob.
|
ObjectInspector |
getObjectInspector()
Get the object inspector that can be used to navigate through the internal
structure of the Object returned from deserialize(...).
|
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 configuration,
Properties tableProperties,
Properties partitionProperties)
Initialize the SerDe.
|
static void |
main(String[] args) |
org.apache.hadoop.io.Writable |
serialize(Object obj,
ObjectInspector objInspector)
Serialize an object by navigating inside the Object with the
ObjectInspector.
|
static Integer |
toInt(String s) |
String |
toString() |
getColumnComments, getColumnNames, getColumnTypes, getConfiguration, getPartitionColumnComments, getPartitionColumnNames, getPartitionColumnTypes, getSerDeStats, parseColumnComments, parseColumnNames, parseColumnNames, parseColumnTypes, parseColumnTypes, shouldStoreFieldsInMetastore
public S3LogDeserializer() throws SerDeException
SerDeException
public String toString()
toString
in class AbstractSerDe
public void initialize(org.apache.hadoop.conf.Configuration configuration, Properties tableProperties, Properties partitionProperties) throws SerDeException
AbstractSerDe
initialize
in class AbstractSerDe
configuration
- Hadoop configurationtableProperties
- Table propertiespartitionProperties
- Partition properties (may be null
if
table has no partitions)SerDeException
- if SerDe fails to initializepublic static Object deserialize(S3LogStruct c, String row) throws Exception
Exception
public Object deserialize(org.apache.hadoop.io.Writable field) throws SerDeException
Deserializer
deserialize
in interface Deserializer
deserialize
in class AbstractSerDe
field
- The Writable object containing a serialized objectSerDeException
public ObjectInspector getObjectInspector() throws SerDeException
Deserializer
SerDeException
public static void main(String[] args)
args
- 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 obj, ObjectInspector objInspector) throws SerDeException
Serializer
serialize
in interface Serializer
serialize
in class AbstractSerDe
SerDeException
Copyright © 2022 The Apache Software Foundation. All rights reserved.