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

Class HiveStructConverter

java.lang.Object

org.apache.parquet.io.api.Converter

org.apache.parquet.io.api.GroupConverter

org.apache.hadoop.hive.ql.io.parquet.convert.HiveGroupConverter

org.apache.hadoop.hive.ql.io.parquet.convert.HiveStructConverter

public class HiveStructConverter
extends HiveGroupConverter

A MapWritableGroupConverter, real converter between hive and parquet types recursively for complex types.

Constructor Summary

Constructors

Constructor and Description
HiveStructConverter(org.apache.parquet.schema.GroupType selectedGroupType, org.apache.hadoop.hive.ql.io.parquet.convert.ConverterParent parent, int index, org.apache.parquet.schema.GroupType containingGroupType, TypeInfo hiveTypeInfo)
HiveStructConverter(org.apache.parquet.schema.GroupType groupType, org.apache.hadoop.hive.ql.io.parquet.convert.ConverterParent parent, int index, TypeInfo hiveTypeInfo)
HiveStructConverter(org.apache.parquet.schema.GroupType requestedSchema, org.apache.parquet.schema.GroupType tableSchema, Map<String,String> metadata, TypeInfo hiveTypeInfo)

Method Summary

Modifier and Type	Method and Description
void	end()
org.apache.parquet.io.api.Converter	getConverter(int fieldIndex)
org.apache.hadoop.io.ArrayWritable	getCurrentArray()
void	set(int fieldIndex, org.apache.hadoop.io.Writable value)
void	start()

Methods inherited from class org.apache.hadoop.hive.ql.io.parquet.convert.HiveGroupConverter

getConverterFromDescription, getConverterFromDescription, getConverterFromDescription, getMetadata, setMetadata

Methods inherited from class org.apache.parquet.io.api.GroupConverter

asGroupConverter, isPrimitive

Methods inherited from class org.apache.parquet.io.api.Converter

asPrimitiveConverter

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveStructConverter

public HiveStructConverter(org.apache.parquet.schema.GroupType requestedSchema,
                           org.apache.parquet.schema.GroupType tableSchema,
                           Map<String,String> metadata,
                           TypeInfo hiveTypeInfo)

HiveStructConverter

public HiveStructConverter(org.apache.parquet.schema.GroupType groupType,
                           org.apache.hadoop.hive.ql.io.parquet.convert.ConverterParent parent,
                           int index,
                           TypeInfo hiveTypeInfo)

HiveStructConverter

public HiveStructConverter(org.apache.parquet.schema.GroupType selectedGroupType,
                           org.apache.hadoop.hive.ql.io.parquet.convert.ConverterParent parent,
                           int index,
                           org.apache.parquet.schema.GroupType containingGroupType,
                           TypeInfo hiveTypeInfo)

Method Detail

getCurrentArray

public final org.apache.hadoop.io.ArrayWritable getCurrentArray()

set

public void set(int fieldIndex,
                org.apache.hadoop.io.Writable value)

Specified by:

set in class HiveGroupConverter

getConverter

public org.apache.parquet.io.api.Converter getConverter(int fieldIndex)

Specified by:

getConverter in class org.apache.parquet.io.api.GroupConverter

start

public void start()

Specified by:

start in class org.apache.parquet.io.api.GroupConverter

end

public void end()

Specified by:

end in class org.apache.parquet.io.api.GroupConverter