org.apache.spark.sql.parquet

Class CatalystPrimitiveConverter

Object

parquet.io.api.Converter

parquet.io.api.PrimitiveConverter

org.apache.spark.sql.parquet.CatalystPrimitiveConverter

Direct Known Subclasses:

CatalystPrimitiveStringConverter

public class CatalystPrimitiveConverter
extends parquet.io.api.PrimitiveConverter

A parquet.io.api.PrimitiveConverter that converts Parquet types to Catalyst types.

Constructor Summary

Constructors

Constructor and Description
CatalystPrimitiveConverter(CatalystConverter parent, int fieldIndex)

Method Summary

Methods

Modifier and Type	Method and Description
void	addBinary(parquet.io.api.Binary value)
void	addBoolean(boolean value)
void	addDouble(double value)
void	addFloat(float value)
void	addInt(int value)
void	addLong(long value)

Methods inherited from class parquet.io.api.PrimitiveConverter

addValueFromDictionary, asPrimitiveConverter, hasDictionarySupport, isPrimitive, setDictionary

Methods inherited from class parquet.io.api.Converter

asGroupConverter

Methods inherited from class Object

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

Constructor Detail

CatalystPrimitiveConverter

public CatalystPrimitiveConverter(CatalystConverter parent,
                          int fieldIndex)

Method Detail

addBinary

public void addBinary(parquet.io.api.Binary value)

Overrides:

addBinary in class parquet.io.api.PrimitiveConverter

addBoolean

public void addBoolean(boolean value)

Overrides:

addBoolean in class parquet.io.api.PrimitiveConverter

addDouble

public void addDouble(double value)

Overrides:

addDouble in class parquet.io.api.PrimitiveConverter

addFloat

public void addFloat(float value)

Overrides:

addFloat in class parquet.io.api.PrimitiveConverter

addInt

public void addInt(int value)

Overrides:

addInt in class parquet.io.api.PrimitiveConverter

addLong

public void addLong(long value)

Overrides:

addLong in class parquet.io.api.PrimitiveConverter