org.apache.hadoop.hive.ql.io.parquet.serde
Class ParquetHiveSerDe
java.lang.Object
org.apache.hadoop.hive.serde2.AbstractSerDe
org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe
- All Implemented Interfaces:
- Deserializer, SerDe, Serializer
public class ParquetHiveSerDe
- extends AbstractSerDe
A ParquetHiveSerDe for Hive (with the deprecated package mapred)
Field Summary |
static org.apache.hadoop.io.Text |
ARRAY
|
static org.apache.hadoop.io.Text |
MAP
|
static org.apache.hadoop.io.Text |
MAP_KEY
|
static org.apache.hadoop.io.Text |
MAP_VALUE
|
MAP_KEY
public static final org.apache.hadoop.io.Text MAP_KEY
MAP_VALUE
public static final org.apache.hadoop.io.Text MAP_VALUE
MAP
public static final org.apache.hadoop.io.Text MAP
ARRAY
public static final org.apache.hadoop.io.Text ARRAY
ParquetHiveSerDe
public ParquetHiveSerDe()
initialize
public final void initialize(org.apache.hadoop.conf.Configuration conf,
Properties tbl)
throws SerDeException
- Specified by:
initialize
in interface Deserializer
- Specified by:
initialize
in interface Serializer
- Specified by:
initialize
in class AbstractSerDe
- Throws:
SerDeException
deserialize
public Object deserialize(org.apache.hadoop.io.Writable blob)
throws SerDeException
- Specified by:
deserialize
in interface Deserializer
- Specified by:
deserialize
in class AbstractSerDe
- Throws:
SerDeException
getObjectInspector
public ObjectInspector getObjectInspector()
throws SerDeException
- Specified by:
getObjectInspector
in interface Deserializer
- Specified by:
getObjectInspector
in class AbstractSerDe
- Throws:
SerDeException
getSerializedClass
public Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()
- Specified by:
getSerializedClass
in interface Serializer
- Specified by:
getSerializedClass
in class AbstractSerDe
serialize
public org.apache.hadoop.io.Writable serialize(Object obj,
ObjectInspector objInspector)
throws SerDeException
- Specified by:
serialize
in interface Serializer
- Specified by:
serialize
in class AbstractSerDe
- Throws:
SerDeException
getSerDeStats
public SerDeStats getSerDeStats()
- Specified by:
getSerDeStats
in interface Deserializer
- Specified by:
getSerDeStats
in interface Serializer
- Specified by:
getSerDeStats
in class AbstractSerDe
Copyright © 2014 The Apache Software Foundation. All rights reserved.