java.lang.Object
org.apache.hadoop.hbase.io.compress.aircompressor.Lz4Codec
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec

@Private public class Lz4Codec extends Object implements org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec
Hadoop Lz4 codec implemented with aircompressor.

This is data format compatible with Hadoop's native lz4 codec.

  • Field Details

  • Constructor Details

  • Method Details

    • getConf

      public org.apache.hadoop.conf.Configuration getConf()
      Specified by:
      getConf in interface org.apache.hadoop.conf.Configurable
    • setConf

      public void setConf(org.apache.hadoop.conf.Configuration conf)
      Specified by:
      setConf in interface org.apache.hadoop.conf.Configurable
    • createCompressor

      public org.apache.hadoop.io.compress.Compressor createCompressor()
      Specified by:
      createCompressor in interface org.apache.hadoop.io.compress.CompressionCodec
    • createDecompressor

      public org.apache.hadoop.io.compress.Decompressor createDecompressor()
      Specified by:
      createDecompressor in interface org.apache.hadoop.io.compress.CompressionCodec
    • createInputStream

      public org.apache.hadoop.io.compress.CompressionInputStream createInputStream(InputStream in) throws IOException
      Specified by:
      createInputStream in interface org.apache.hadoop.io.compress.CompressionCodec
      Throws:
      IOException
    • createInputStream

      public org.apache.hadoop.io.compress.CompressionInputStream createInputStream(InputStream in, org.apache.hadoop.io.compress.Decompressor d) throws IOException
      Specified by:
      createInputStream in interface org.apache.hadoop.io.compress.CompressionCodec
      Throws:
      IOException
    • createOutputStream

      public org.apache.hadoop.io.compress.CompressionOutputStream createOutputStream(OutputStream out) throws IOException
      Specified by:
      createOutputStream in interface org.apache.hadoop.io.compress.CompressionCodec
      Throws:
      IOException
    • createOutputStream

      public org.apache.hadoop.io.compress.CompressionOutputStream createOutputStream(OutputStream out, org.apache.hadoop.io.compress.Compressor c) throws IOException
      Specified by:
      createOutputStream in interface org.apache.hadoop.io.compress.CompressionCodec
      Throws:
      IOException
    • getCompressorType

      public Class<? extends org.apache.hadoop.io.compress.Compressor> getCompressorType()
      Specified by:
      getCompressorType in interface org.apache.hadoop.io.compress.CompressionCodec
    • getDecompressorType

      public Class<? extends org.apache.hadoop.io.compress.Decompressor> getDecompressorType()
      Specified by:
      getDecompressorType in interface org.apache.hadoop.io.compress.CompressionCodec
    • getDefaultExtension

      Specified by:
      getDefaultExtension in interface org.apache.hadoop.io.compress.CompressionCodec
    • getBufferSize

      static int getBufferSize(org.apache.hadoop.conf.Configuration conf)