org.apache.spark.sql.parquet

Class RowRecordMaterializer

Object

parquet.io.api.RecordMaterializer<org.apache.spark.sql.Row>

org.apache.spark.sql.parquet.RowRecordMaterializer

public class RowRecordMaterializer
extends parquet.io.api.RecordMaterializer<org.apache.spark.sql.Row>

A parquet.io.api.RecordMaterializer for Rows.

Constructor Summary

Constructors

Constructor and Description
RowRecordMaterializer(CatalystConverter root)
RowRecordMaterializer(parquet.schema.MessageType parquetSchema, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> attributes)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.Row	getCurrentRecord()
parquet.io.api.GroupConverter	getRootConverter()

Methods inherited from class parquet.io.api.RecordMaterializer

skipCurrentRecord

Methods inherited from class Object

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

Constructor Detail

RowRecordMaterializer

public RowRecordMaterializer(CatalystConverter root)

RowRecordMaterializer

public RowRecordMaterializer(parquet.schema.MessageType parquetSchema,
                     scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> attributes)

Method Detail

getCurrentRecord

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

Specified by:

getCurrentRecord in class parquet.io.api.RecordMaterializer<org.apache.spark.sql.Row>

getRootConverter

public parquet.io.api.GroupConverter getRootConverter()

Specified by:

getRootConverter in class parquet.io.api.RecordMaterializer<org.apache.spark.sql.Row>