org.apache.spark.sql.parquet

Class CatalystMapConverter

Object

parquet.io.api.Converter

parquet.io.api.GroupConverter

org.apache.spark.sql.parquet.CatalystConverter

org.apache.spark.sql.parquet.CatalystMapConverter

public class CatalystMapConverter
extends CatalystConverter

A parquet.io.api.GroupConverter that converts two-element groups that match the characteristics of a map (see ParquetTypesConverter) into an MapType.

Constructor Summary

Constructors

Constructor and Description
CatalystMapConverter(org.apache.spark.sql.catalyst.types.StructField[] schema, int index, CatalystConverter parent)

Method Summary

Methods

Modifier and Type	Method and Description
void	end()
parquet.io.api.Converter	getConverter(int fieldIndex)
void	start()

Methods inherited from class org.apache.spark.sql.parquet.CatalystConverter

ARRAY_CONTAINS_NULL_BAG_SCHEMA_NAME, ARRAY_ELEMENTS_SCHEMA_NAME, getCurrentRecord, MAP_KEY_SCHEMA_NAME, MAP_SCHEMA_NAME, MAP_VALUE_SCHEMA_NAME

Methods inherited from class parquet.io.api.GroupConverter

asGroupConverter, isPrimitive

Methods inherited from class parquet.io.api.Converter

asPrimitiveConverter

Methods inherited from class Object

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

Constructor Detail

CatalystMapConverter

public CatalystMapConverter(org.apache.spark.sql.catalyst.types.StructField[] schema,
                    int index,
                    CatalystConverter parent)

Method Detail

start

public void start()

Specified by:

start in class parquet.io.api.GroupConverter

end

public void end()

Specified by:

end in class parquet.io.api.GroupConverter

getConverter

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

Specified by:

getConverter in class parquet.io.api.GroupConverter