org.apache.hadoop.hive.ql.io.parquet.read

Class DataWritableReadSupport

java.lang.Object

parquet.hadoop.api.ReadSupport<org.apache.hadoop.io.ArrayWritable>

org.apache.hadoop.hive.ql.io.parquet.read.DataWritableReadSupport

public class DataWritableReadSupport
extends parquet.hadoop.api.ReadSupport<org.apache.hadoop.io.ArrayWritable>

A MapWritableReadSupport Manages the translation between Hive and Parquet

Nested Class Summary

Nested classes/interfaces inherited from class parquet.hadoop.api.ReadSupport

parquet.hadoop.api.ReadSupport.ReadContext

Field Summary

Fields

Modifier and Type	Field and Description
static String	HIVE_TABLE_AS_PARQUET_SCHEMA
static String	PARQUET_COLUMN_INDEX_ACCESS

Fields inherited from class parquet.hadoop.api.ReadSupport

PARQUET_READ_SCHEMA

Constructor Summary

Constructors

Constructor and Description
DataWritableReadSupport()

Method Summary

Methods

Modifier and Type	Method and Description
parquet.hadoop.api.ReadSupport.ReadContext	init(parquet.hadoop.api.InitContext context) It creates the readContext for Parquet side with the requested schema during the init phase.
parquet.io.api.RecordMaterializer<org.apache.hadoop.io.ArrayWritable>	prepareForRead(org.apache.hadoop.conf.Configuration configuration, Map<String,String> keyValueMetaData, parquet.schema.MessageType fileSchema, parquet.hadoop.api.ReadSupport.ReadContext readContext) It creates the hive read support to interpret data from parquet to hive

Methods inherited from class parquet.hadoop.api.ReadSupport

getSchemaForRead, getSchemaForRead, init

Methods inherited from class java.lang.Object

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

Field Detail

HIVE_TABLE_AS_PARQUET_SCHEMA

public static final String HIVE_TABLE_AS_PARQUET_SCHEMA

See Also:

Constant Field Values

PARQUET_COLUMN_INDEX_ACCESS

public static final String PARQUET_COLUMN_INDEX_ACCESS

See Also:

Constant Field Values

Constructor Detail

DataWritableReadSupport

public DataWritableReadSupport()

Method Detail

init

public parquet.hadoop.api.ReadSupport.ReadContext init(parquet.hadoop.api.InitContext context)

It creates the readContext for Parquet side with the requested schema during the init phase.

Overrides:

init in class parquet.hadoop.api.ReadSupport<org.apache.hadoop.io.ArrayWritable>

Parameters:

context -

Returns:

the parquet ReadContext

prepareForRead

public parquet.io.api.RecordMaterializer<org.apache.hadoop.io.ArrayWritable> prepareForRead(org.apache.hadoop.conf.Configuration configuration,
                                                                                   Map<String,String> keyValueMetaData,
                                                                                   parquet.schema.MessageType fileSchema,
                                                                                   parquet.hadoop.api.ReadSupport.ReadContext readContext)

It creates the hive read support to interpret data from parquet to hive

Specified by:

prepareForRead in class parquet.hadoop.api.ReadSupport<org.apache.hadoop.io.ArrayWritable>

Parameters:

configuration - // unused

keyValueMetaData -

fileSchema - // unused

readContext - containing the requested schema and the schema of the hive table

Returns:

Record Materialize for Hive