com.asakusafw.directio.hive.parquet.v2

Class DataModelMaterializer

java.lang.Object

org.apache.parquet.io.api.RecordMaterializer<Object>

com.asakusafw.directio.hive.parquet.v2.DataModelMaterializer

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

An implementation of parquet record materializer for Asakusa data models.

Since:

0.7.0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.parquet.io.api.RecordMaterializer

org.apache.parquet.io.api.RecordMaterializer.RecordMaterializationException

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class org.apache.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,
                             org.apache.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 org.apache.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 org.apache.parquet.io.api.RecordMaterializer<Object>

getRootConverter

public org.apache.parquet.io.api.GroupConverter getRootConverter()

Specified by:

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