public class RowRecordMaterializer extends parquet.io.api.RecordMaterializer<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 |
---|---|
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)