public class RowRecordMaterializer
extends parquet.io.api.RecordMaterializer<org.apache.spark.sql.catalyst.expressions.Row>
parquet.io.api.RecordMaterializer
for Rows.
Constructor and Description |
---|
RowRecordMaterializer(CatalystConverter root) |
RowRecordMaterializer(parquet.schema.MessageType parquetSchema,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> attributes) |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.catalyst.expressions.Row |
getCurrentRecord() |
parquet.io.api.GroupConverter |
getRootConverter() |
public RowRecordMaterializer(CatalystConverter root)
public RowRecordMaterializer(parquet.schema.MessageType parquetSchema, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> attributes)
public org.apache.spark.sql.catalyst.expressions.Row getCurrentRecord()
getCurrentRecord
in class parquet.io.api.RecordMaterializer<org.apache.spark.sql.catalyst.expressions.Row>
public parquet.io.api.GroupConverter getRootConverter()
getRootConverter
in class parquet.io.api.RecordMaterializer<org.apache.spark.sql.catalyst.expressions.Row>