org.apache.spark.sql.parquet

Class CatalystConverter

Object

parquet.io.api.Converter

parquet.io.api.GroupConverter

org.apache.spark.sql.parquet.CatalystConverter

Direct Known Subclasses:

CatalystArrayContainsNullConverter, CatalystArrayConverter, CatalystGroupConverter, CatalystMapConverter, CatalystNativeArrayConverter, CatalystPrimitiveRowConverter

public abstract class CatalystConverter
extends parquet.io.api.GroupConverter

Constructor Summary

Constructors

Constructor and Description
CatalystConverter()

Method Summary

Methods

Modifier and Type	Method and Description
static String	ARRAY_CONTAINS_NULL_BAG_SCHEMA_NAME()
static String	ARRAY_ELEMENTS_SCHEMA_NAME()
org.apache.spark.sql.catalyst.expressions.Row	getCurrentRecord() Should only be called in the root (group) converter!
static String	MAP_KEY_SCHEMA_NAME()
static String	MAP_SCHEMA_NAME()
static String	MAP_VALUE_SCHEMA_NAME()

Methods inherited from class parquet.io.api.GroupConverter

asGroupConverter, end, getConverter, isPrimitive, start

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

CatalystConverter

public CatalystConverter()

Method Detail

ARRAY_CONTAINS_NULL_BAG_SCHEMA_NAME

public static String ARRAY_CONTAINS_NULL_BAG_SCHEMA_NAME()

ARRAY_ELEMENTS_SCHEMA_NAME

public static String ARRAY_ELEMENTS_SCHEMA_NAME()

MAP_KEY_SCHEMA_NAME

public static String MAP_KEY_SCHEMA_NAME()

MAP_VALUE_SCHEMA_NAME

public static String MAP_VALUE_SCHEMA_NAME()

MAP_SCHEMA_NAME

public static String MAP_SCHEMA_NAME()

getCurrentRecord

public org.apache.spark.sql.catalyst.expressions.Row getCurrentRecord()

Should only be called in the root (group) converter!

Returns: