Package org.apache.drill.exec.store.parquet.compression

Class AirliftBytesInputCompressor

java.lang.Object
org.apache.drill.exec.store.parquet.compression.AirliftBytesInputCompressor
All Implemented Interfaces:
org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor, org.apache.parquet.compression.CompressionCodecFactory.BytesInputDecompressor
public class AirliftBytesInputCompressor extends Object implements org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor, org.apache.parquet.compression.CompressionCodecFactory.BytesInputDecompressor
A shim making an aircompressor (de)compressor available through the BytesInputCompressor and BytesInputDecompressor interfaces.

  • Constructor Summary

    Constructors
    Constructor
    Description
    AirliftBytesInputCompressor(org.apache.parquet.hadoop.metadata.CompressionCodecName codecName, org.apache.parquet.bytes.ByteBufferAllocator allocator)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.parquet.bytes.BytesInput
    compress(org.apache.parquet.bytes.BytesInput bytes)
     
    void
    decompress(ByteBuffer input, int compressedSize, ByteBuffer output, int uncompressedSize)
     
    org.apache.parquet.bytes.BytesInput
    decompress(org.apache.parquet.bytes.BytesInput bytes, int uncompressedSize)
     
    org.apache.parquet.hadoop.metadata.CompressionCodecName
    getCodecName()
     
    void
    release()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AirliftBytesInputCompressor

      public AirliftBytesInputCompressor(org.apache.parquet.hadoop.metadata.CompressionCodecName codecName, org.apache.parquet.bytes.ByteBufferAllocator allocator)

  • Method Details

    • compress

      public org.apache.parquet.bytes.BytesInput compress(org.apache.parquet.bytes.BytesInput bytes) throws IOException
      Specified by:
      compress in interface org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor
      Throws:
      IOException

    • getCodecName

      public org.apache.parquet.hadoop.metadata.CompressionCodecName getCodecName()
      Specified by:
      getCodecName in interface org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor

    • decompress

      public org.apache.parquet.bytes.BytesInput decompress(org.apache.parquet.bytes.BytesInput bytes, int uncompressedSize) throws IOException
      Specified by:
      decompress in interface org.apache.parquet.compression.CompressionCodecFactory.BytesInputDecompressor
      Throws:
      IOException

    • decompress

      public void decompress(ByteBuffer input, int compressedSize, ByteBuffer output, int uncompressedSize) throws IOException
      Specified by:
      decompress in interface org.apache.parquet.compression.CompressionCodecFactory.BytesInputDecompressor
      Throws:
      IOException

    • release

      public void release()
      Specified by:
      release in interface org.apache.parquet.compression.CompressionCodecFactory.BytesInputCompressor
      Specified by:
      release in interface org.apache.parquet.compression.CompressionCodecFactory.BytesInputDecompressor