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, org.apache.parquet.column.values.bloomfilter.BloomFilterWriteStore

@InterfaceAudience.Private
public class ParquetColumnChunkPageWriteStore
extends Object
implements org.apache.parquet.column.page.PageWriteStore, org.apache.parquet.column.values.bloomfilter.BloomFilterWriteStore, Closeable

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, int columnIndexTruncateLength)
ParquetColumnChunkPageWriteStore(org.apache.parquet.hadoop.CodecFactory.BytesCompressor compressor, org.apache.parquet.schema.MessageType schema, int initialSlabSize, int maxCapacityHint, org.apache.parquet.bytes.ByteBufferAllocator allocator, int columnIndexTruncateLength, boolean pageWriteChecksumEnabled)
ParquetColumnChunkPageWriteStore(org.apache.parquet.hadoop.CodecFactory.BytesCompressor compressor, org.apache.parquet.schema.MessageType schema, int initialSlabSize, int maxCapacityHint, org.apache.parquet.bytes.ByteBufferAllocator allocator, int columnIndexTruncateLength, boolean pageWriteChecksumEnabled, org.apache.parquet.crypto.InternalFileEncryptor fileEncryptor, int rowGroupOrdinal)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flushToFileWriter(ParquetFileWriter writer)
org.apache.parquet.column.values.bloomfilter.BloomFilterWriter	getBloomFilterWriter(org.apache.parquet.column.ColumnDescriptor path)
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,
                                        int columnIndexTruncateLength)

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,
                                        int columnIndexTruncateLength,
                                        boolean pageWriteChecksumEnabled)

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,
                                        int columnIndexTruncateLength,
                                        boolean pageWriteChecksumEnabled,
                                        org.apache.parquet.crypto.InternalFileEncryptor fileEncryptor,
                                        int rowGroupOrdinal)

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

getBloomFilterWriter

public org.apache.parquet.column.values.bloomfilter.BloomFilterWriter getBloomFilterWriter(org.apache.parquet.column.ColumnDescriptor path)

Specified by:

getBloomFilterWriter in interface org.apache.parquet.column.values.bloomfilter.BloomFilterWriteStore

flushToFileWriter

public void flushToFileWriter(ParquetFileWriter writer)
                       throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable