com.asakusafw.directio.hive.parquet

Class DataModelMaterializer

java.lang.Object

parquet.io.api.RecordMaterializer<Object>

com.asakusafw.directio.hive.parquet.DataModelMaterializer

public class DataModelMaterializer
extends parquet.io.api.RecordMaterializer<Object>

An implementation of parquet record materializer for Asakusa data models.

Since:

0.7.0

Constructor Summary

Constructors

Constructor and Description
DataModelMaterializer(DataModelDescriptor descriptor, parquet.schema.MessageType schema, DataModelMapping configuration) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
Object	getCurrentRecord()
parquet.schema.MessageType	getMaterializeSchema() Returns the schema which this materializer is required.
parquet.io.api.GroupConverter	getRootConverter()
void	setNextRecord(Object object) Sets the next record.

Methods inherited from class parquet.io.api.RecordMaterializer

skipCurrentRecord

Methods inherited from class java.lang.Object

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

Constructor Detail

DataModelMaterializer

public DataModelMaterializer(DataModelDescriptor descriptor,
                             parquet.schema.MessageType schema,
                             DataModelMapping configuration)

Creates a new instance.

Parameters:

descriptor - the target descriptor

schema - the file schema

configuration - the mapping configuration

Method Detail

getMaterializeSchema

public parquet.schema.MessageType getMaterializeSchema()

Returns the schema which this materializer is required.

Returns:

the schema for materializer

setNextRecord

public void setNextRecord(Object object)

Sets the next record.

Parameters:

object - the next record object

getCurrentRecord

public Object getCurrentRecord()

Specified by:

getCurrentRecord in class parquet.io.api.RecordMaterializer<Object>

getRootConverter

public parquet.io.api.GroupConverter getRootConverter()

Specified by:

getRootConverter in class parquet.io.api.RecordMaterializer<Object>