org.apache.parquet.hadoop

Class ParquetColumnChunkPageWriteStore

java.lang.Object

org.apache.parquet.hadoop.ParquetColumnChunkPageWriteStore

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.parquet.column.page.PageWriteStore

public class ParquetColumnChunkPageWriteStore
extends Object
implements org.apache.parquet.column.page.PageWriteStore, Closeable

This is a copy of ColumnChunkPageWriteStore from parquet library except of OutputStream that is used here. Using of CapacityByteArrayOutputStream allows to use different ByteBuffer allocators. It will be no need in this class once PARQUET-1006 is resolved.

Constructor Summary

Constructors

Constructor and Description
ParquetColumnChunkPageWriteStore(org.apache.parquet.hadoop.CodecFactory.BytesCompressor compressor, org.apache.parquet.schema.MessageType schema, int initialSlabSize, int maxCapacityHint, org.apache.parquet.bytes.ByteBufferAllocator allocator, boolean pageWriteChecksumEnabled, int columnIndexTruncateLength)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flushToFileWriter(org.apache.parquet.hadoop.ParquetFileWriter writer) Writes the column chunks in the corresponding row group
org.apache.parquet.column.page.PageWriter	getPageWriter(org.apache.parquet.column.ColumnDescriptor path)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetColumnChunkPageWriteStore

public ParquetColumnChunkPageWriteStore(org.apache.parquet.hadoop.CodecFactory.BytesCompressor compressor,
                                        org.apache.parquet.schema.MessageType schema,
                                        int initialSlabSize,
                                        int maxCapacityHint,
                                        org.apache.parquet.bytes.ByteBufferAllocator allocator,
                                        boolean pageWriteChecksumEnabled,
                                        int columnIndexTruncateLength)

Method Detail

getPageWriter

public org.apache.parquet.column.page.PageWriter getPageWriter(org.apache.parquet.column.ColumnDescriptor path)

Specified by:

getPageWriter in interface org.apache.parquet.column.page.PageWriteStore

flushToFileWriter

public void flushToFileWriter(org.apache.parquet.hadoop.ParquetFileWriter writer)
                       throws IOException

Writes the column chunks in the corresponding row group

Parameters:

writer - the parquet file writer

Throws:

IOException - if the file can not be created

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable