Package org.apache.drill.exec.store.dfs

Class ZipCodec

java.lang.Object
org.apache.hadoop.io.compress.DefaultCodec
org.apache.drill.exec.store.dfs.ZipCodec
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec, org.apache.hadoop.io.compress.DirectDecompressionCodec
public class ZipCodec extends org.apache.hadoop.io.compress.DefaultCodec
ZIP codec implementation which cna read or create single entry.

Note: Do not rename this class. Class naming must be 'ZipCodec' so it can be mapped by CompressionCodecFactory to the 'zip' extension.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.io.compress.CompressionCodec

    org.apache.hadoop.io.compress.CompressionCodec.Util

  • Constructor Summary

    Constructors
    Constructor
    Description
    ZipCodec()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.io.compress.CompressionInputStream
    createInputStream(InputStream in)
     
    org.apache.hadoop.io.compress.CompressionOutputStream
    createOutputStream(OutputStream out)
     
    String
    getDefaultExtension()
     

    Methods inherited from class org.apache.hadoop.io.compress.DefaultCodec

    createCompressor, createDecompressor, createDirectDecompressor, createInputStream, createOutputStream, getCompressorType, getConf, getDecompressorType, setConf

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ZipCodec

      public ZipCodec()

  • Method Details

    • createOutputStream

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

    • createInputStream

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

    • getDefaultExtension

      public String getDefaultExtension()
      Specified by:
      getDefaultExtension in interface org.apache.hadoop.io.compress.CompressionCodec
      Overrides:
      getDefaultExtension in class org.apache.hadoop.io.compress.DefaultCodec