org.apache.spark.sql.hive.parquet

Class FakeParquetSerDe

Object

org.apache.spark.sql.hive.parquet.FakeParquetSerDe

All Implemented Interfaces:

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

public class FakeParquetSerDe
extends Object
implements org.apache.hadoop.hive.serde2.SerDe

A placeholder that allows Spark SQL users to create metastore tables that are stored as parquet files. It is only intended to pass the checks that the serde is valid and exists when a CREATE TABLE is run. The actual work of decoding will be done by ParquetTableScan when "spark.sql.hive.convertMetastoreParquet" is set to true.

Constructor Summary

Constructors

Constructor and Description
FakeParquetSerDe()

Method Summary

Methods

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

Methods inherited from class Object

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

Constructor Detail

FakeParquetSerDe

public FakeParquetSerDe()

Method Detail

getObjectInspector

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

Specified by:

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

deserialize

public Object deserialize(org.apache.hadoop.io.Writable p1)

Specified by:

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

initialize

public void initialize(org.apache.hadoop.conf.Configuration p1,
              java.util.Properties p2)

Specified by:

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

Specified by:

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

getSerializedClass

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

Specified by:

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

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

serialize

public org.apache.hadoop.io.Writable serialize(Object p1,
                                      org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector p2)

Specified by:

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