com.asakusafw.directio.hive.parquet.v1

Class DataModelWriteSupport

java.lang.Object

parquet.hadoop.api.WriteSupport<Object>

com.asakusafw.directio.hive.parquet.v1.DataModelWriteSupport

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

Consumes a data model into RecordConsumer.

Since:

0.7.0

Nested Class Summary

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

parquet.hadoop.api.WriteSupport.FinalizedWriteContext, 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
parquet.hadoop.api.WriteSupport.WriteContext	init(org.apache.hadoop.conf.Configuration configuration)
void	prepareForWrite(parquet.io.api.RecordConsumer consumer)
void	write(Object value)

Methods inherited from class 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 parquet.hadoop.api.WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)

Specified by:

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

prepareForWrite

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

Specified by:

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

write

public void write(Object value)

Specified by:

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