Package org.apache.flink.api.common.io.compression

Class Bzip2InputStreamFactory

java.lang.Object

org.apache.flink.api.common.io.compression.Bzip2InputStreamFactory

All Implemented Interfaces:

InflaterInputStreamFactory<org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream>

@Internal
public class Bzip2InputStreamFactory
extends Object
implements InflaterInputStreamFactory<org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream>

Factory for Bzip2 decompressors.

Constructor Summary

Constructors

Constructor	Description
Bzip2InputStreamFactory()

Method Summary

Modifier and Type	Method	Description
org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream	create(InputStream in)	Creates a InflaterInputStream that wraps the given input stream.
Collection<String>	getCommonFileExtensions()	Lists a collection of typical file extensions (e.g., "gz", "gzip") that are associated with the compression algorithm in the InflaterInputStream T.
static Bzip2InputStreamFactory	getInstance()

Methods inherited from class java.lang.Object

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

Constructor Detail

Bzip2InputStreamFactory

public Bzip2InputStreamFactory()

Method Detail

getInstance

public static Bzip2InputStreamFactory getInstance()

create

public org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream create(InputStream in)
                                                                                throws IOException

Description copied from interface: InflaterInputStreamFactory

Creates a InflaterInputStream that wraps the given input stream.

Specified by:

create in interface InflaterInputStreamFactory<org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream>

Parameters:

in - is the compressed input stream

Returns:

the inflated input stream

Throws:

IOException

getCommonFileExtensions

public Collection<String> getCommonFileExtensions()

Description copied from interface: InflaterInputStreamFactory

Lists a collection of typical file extensions (e.g., "gz", "gzip") that are associated with the compression algorithm in the InflaterInputStream T.

Specified by:

getCommonFileExtensions in interface InflaterInputStreamFactory<org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream>

Returns:

a (possibly empty) collection of lower-case file extensions, without the period