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 and Description
ZipCodec()

Method Summary

Modifier and Type	Method and 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 Detail

ZipCodec

public ZipCodec()

Method Detail

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