com.oracle.eid.oozie.hive

Class CsvSerDe

java.lang.Object

org.apache.hadoop.hive.serde2.AbstractSerDe

com.oracle.eid.oozie.hive.CsvSerDe

All Implemented Interfaces:

org.apache.hadoop.hive.serde2.Deserializer, org.apache.hadoop.hive.serde2.SerDe, org.apache.hadoop.hive.serde2.Serializer

public class CsvSerDe
extends org.apache.hadoop.hive.serde2.AbstractSerDe

This class extends the hive AbstractSerDe class and provides serialization/deserialization of csv (text) files. It is intended to be used for creating hive tables backed by Sqoop2 generated text files.

Author:

Oracle Big Data Discovery, ruhu

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ESCAPE_CHAR
static java.lang.String	QUOTE_CHAR
static java.lang.String	SEPARATOR_CHAR

Constructor Summary

Constructors

Constructor and Description
CsvSerDe()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.Object	deserialize(org.apache.hadoop.io.Writable writable)
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	getObjectInspector()
org.apache.hadoop.hive.serde2.SerDeStats	getSerDeStats()
java.lang.Class<? extends org.apache.hadoop.io.Writable>	getSerializedClass()
void	initialize(org.apache.hadoop.conf.Configuration conf, java.util.Properties properties)
org.apache.hadoop.io.Writable	serialize(java.lang.Object obj, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)

Methods inherited from class org.apache.hadoop.hive.serde2.AbstractSerDe

initialize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ESCAPE_CHAR

public static final java.lang.String ESCAPE_CHAR

See Also:

Constant Field Values

QUOTE_CHAR

public static final java.lang.String QUOTE_CHAR

See Also:

Constant Field Values

SEPARATOR_CHAR

public static final java.lang.String SEPARATOR_CHAR

See Also:

Constant Field Values

Constructor Detail

CsvSerDe

public CsvSerDe()

Method Detail

initialize

public void initialize(org.apache.hadoop.conf.Configuration conf,
              java.util.Properties properties)
                throws org.apache.hadoop.hive.serde2.SerDeException

Specified by:

initialize in interface org.apache.hadoop.hive.serde2.Deserializer

Specified by:

initialize in interface org.apache.hadoop.hive.serde2.Serializer

Specified by:

initialize in class org.apache.hadoop.hive.serde2.AbstractSerDe

Throws:

org.apache.hadoop.hive.serde2.SerDeException

serialize

public org.apache.hadoop.io.Writable serialize(java.lang.Object obj,
                                      org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
                                        throws org.apache.hadoop.hive.serde2.SerDeException

Specified by:

serialize in interface org.apache.hadoop.hive.serde2.Serializer

Specified by:

serialize in class org.apache.hadoop.hive.serde2.AbstractSerDe

Throws:

org.apache.hadoop.hive.serde2.SerDeException

deserialize

public java.lang.Object deserialize(org.apache.hadoop.io.Writable writable)
                             throws org.apache.hadoop.hive.serde2.SerDeException

Specified by:

deserialize in interface org.apache.hadoop.hive.serde2.Deserializer

Specified by:

deserialize in class org.apache.hadoop.hive.serde2.AbstractSerDe

Throws:

org.apache.hadoop.hive.serde2.SerDeException

getObjectInspector

public org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector()
                                                                                 throws org.apache.hadoop.hive.serde2.SerDeException

Specified by:

getObjectInspector in interface org.apache.hadoop.hive.serde2.Deserializer

Specified by:

getObjectInspector in class org.apache.hadoop.hive.serde2.AbstractSerDe

Throws:

org.apache.hadoop.hive.serde2.SerDeException

getSerDeStats

public org.apache.hadoop.hive.serde2.SerDeStats getSerDeStats()

Specified by:

getSerDeStats in interface org.apache.hadoop.hive.serde2.Deserializer

Specified by:

getSerDeStats in interface org.apache.hadoop.hive.serde2.Serializer

Specified by:

getSerDeStats in class org.apache.hadoop.hive.serde2.AbstractSerDe

getSerializedClass

public java.lang.Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()

Specified by:

getSerializedClass in interface org.apache.hadoop.hive.serde2.Serializer

Specified by:

getSerializedClass in class org.apache.hadoop.hive.serde2.AbstractSerDe