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
     
    void
     

    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