Class GzipInflaterInputStreamFactory
- java.lang.Object
-
- org.apache.flink.api.common.io.compression.GzipInflaterInputStreamFactory
-
- All Implemented Interfaces:
InflaterInputStreamFactory<GZIPInputStream>
@Internal public class GzipInflaterInputStreamFactory extends Object implements InflaterInputStreamFactory<GZIPInputStream>
Factory for input streams that decompress the GZIP compression format.
-
-
Constructor Summary
Constructors Constructor Description GzipInflaterInputStreamFactory()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description GZIPInputStreamcreate(InputStream in)Creates aInflaterInputStreamthat 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 theInflaterInputStreamT.static GzipInflaterInputStreamFactorygetInstance()
-
-
-
Method Detail
-
getInstance
public static GzipInflaterInputStreamFactory getInstance()
-
create
public GZIPInputStream create(InputStream in) throws IOException
Description copied from interface:InflaterInputStreamFactoryCreates aInflaterInputStreamthat wraps the given input stream.- Specified by:
createin interfaceInflaterInputStreamFactory<GZIPInputStream>- Parameters:
in- is the compressed input stream- Returns:
- the inflated input stream
- Throws:
IOException
-
getCommonFileExtensions
public Collection<String> getCommonFileExtensions()
Description copied from interface:InflaterInputStreamFactoryLists a collection of typical file extensions (e.g., "gz", "gzip") that are associated with the compression algorithm in theInflaterInputStreamT.- Specified by:
getCommonFileExtensionsin interfaceInflaterInputStreamFactory<GZIPInputStream>- Returns:
- a (possibly empty) collection of lower-case file extensions, without the period
-
-