org.apache.spark.sql.parquet

Class RowReadSupport

Object

parquet.hadoop.api.ReadSupport<org.apache.spark.sql.Row>

org.apache.spark.sql.parquet.RowReadSupport

All Implemented Interfaces:

Logging

public class RowReadSupport
extends parquet.hadoop.api.ReadSupport<org.apache.spark.sql.Row>
implements Logging

A parquet.hadoop.api.ReadSupport for Row objects.

Nested Class Summary

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

parquet.hadoop.api.ReadSupport.ReadContext

Field Summary

Fields inherited from class parquet.hadoop.api.ReadSupport

PARQUET_READ_SCHEMA

Constructor Summary

Constructors

Constructor and Description
RowReadSupport()

Method Summary

Methods

Modifier and Type	Method and Description
parquet.hadoop.api.ReadSupport.ReadContext	init(org.apache.hadoop.conf.Configuration configuration, java.util.Map<String,String> keyValueMetaData, parquet.schema.MessageType fileSchema)
parquet.io.api.RecordMaterializer<org.apache.spark.sql.Row>	prepareForRead(org.apache.hadoop.conf.Configuration conf, java.util.Map<String,String> stringMap, parquet.schema.MessageType fileSchema, parquet.hadoop.api.ReadSupport.ReadContext readContext)
static String	SPARK_METADATA_KEY()
static String	SPARK_ROW_REQUESTED_SCHEMA()

Methods inherited from class parquet.hadoop.api.ReadSupport

getSchemaForRead, getSchemaForRead, init

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

RowReadSupport

public RowReadSupport()

Method Detail

SPARK_ROW_REQUESTED_SCHEMA

public static String SPARK_ROW_REQUESTED_SCHEMA()

SPARK_METADATA_KEY

public static String SPARK_METADATA_KEY()

prepareForRead

public parquet.io.api.RecordMaterializer<org.apache.spark.sql.Row> prepareForRead(org.apache.hadoop.conf.Configuration conf,
                                                                         java.util.Map<String,String> stringMap,
                                                                         parquet.schema.MessageType fileSchema,
                                                                         parquet.hadoop.api.ReadSupport.ReadContext readContext)

Specified by:

prepareForRead in class parquet.hadoop.api.ReadSupport<org.apache.spark.sql.Row>

init

public parquet.hadoop.api.ReadSupport.ReadContext init(org.apache.hadoop.conf.Configuration configuration,
                                              java.util.Map<String,String> keyValueMetaData,
                                              parquet.schema.MessageType fileSchema)

Overrides:

init in class parquet.hadoop.api.ReadSupport<org.apache.spark.sql.Row>