Package org.apache.parquet.hadoop

Class ParquetColumnChunkPageWriteStore

java.lang.Object

org.apache.parquet.hadoop.ParquetColumnChunkPageWriteStore

All Implemented Interfaces:

AutoCloseable, org.apache.parquet.column.page.PageWriteStore, org.apache.parquet.column.values.bloomfilter.BloomFilterWriteStore

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

Constructor Summary

Constructors

Constructor	Description
ParquetColumnChunkPageWriteStore(org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor compressor, org.apache.parquet.schema.MessageType schema, int initialSlabSize, int maxCapacityHint, org.apache.parquet.bytes.ByteBufferAllocator allocator, int columnIndexTruncateLength)
ParquetColumnChunkPageWriteStore(org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor 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.compression.CompressionCodecFactory.BytesInputCompressor 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	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 Details

ParquetColumnChunkPageWriteStore

public ParquetColumnChunkPageWriteStore(org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor 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.compression.CompressionCodecFactory.BytesInputCompressor 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.compression.CompressionCodecFactory.BytesInputCompressor 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 Details

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 AutoCloseable