com.asakusafw.directio.hive.parquet.v2

Class DataModelWriteSupport

java.lang.Object

org.apache.parquet.hadoop.api.WriteSupport<Object>

com.asakusafw.directio.hive.parquet.v2.DataModelWriteSupport

public class DataModelWriteSupport
extends org.apache.parquet.hadoop.api.WriteSupport<Object>

Consumes a data model into RecordConsumer.

Since:

0.7.0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.parquet.hadoop.api.WriteSupport

org.apache.parquet.hadoop.api.WriteSupport.FinalizedWriteContext, org.apache.parquet.hadoop.api.WriteSupport.WriteContext

Constructor Summary

Constructors

Constructor and Description
DataModelWriteSupport(DataModelDescriptor descriptor) Creates a new instance with empty extra-metadata.
DataModelWriteSupport(DataModelDescriptor descriptor, Map<String,String> metadata) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
org.apache.parquet.hadoop.api.WriteSupport.WriteContext	init(org.apache.hadoop.conf.Configuration configuration)
void	prepareForWrite(org.apache.parquet.io.api.RecordConsumer consumer)
void	write(Object value)

Methods inherited from class org.apache.parquet.hadoop.api.WriteSupport

finalizeWrite

Methods inherited from class java.lang.Object

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

Constructor Detail

DataModelWriteSupport

public DataModelWriteSupport(DataModelDescriptor descriptor)

Creates a new instance with empty extra-metadata.

Parameters:

descriptor - the target data model descriptor

DataModelWriteSupport

public DataModelWriteSupport(DataModelDescriptor descriptor,
                             Map<String,String> metadata)

Creates a new instance.

Parameters:

descriptor - the target data model descriptor

metadata - the extra metadata

Method Detail

init

public org.apache.parquet.hadoop.api.WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)

Specified by:

init in class org.apache.parquet.hadoop.api.WriteSupport<Object>

prepareForWrite

public void prepareForWrite(org.apache.parquet.io.api.RecordConsumer consumer)

Specified by:

prepareForWrite in class org.apache.parquet.hadoop.api.WriteSupport<Object>

write

public void write(Object value)

Specified by:

write in class org.apache.parquet.hadoop.api.WriteSupport<Object>