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
     
    void
     
    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