org.apache.flink.connector.file.src.compression

Class StandardDeCompressors

java.lang.Object

org.apache.flink.connector.file.src.compression.StandardDeCompressors

@PublicEvolving
public final class StandardDeCompressors
extends Object

A collection of common compression formats and de-compressors.

Method Summary

Modifier and Type	Method and Description
static Collection<String>	getCommonSuffixes() Gets all common file extensions of supported file compression formats.
static InflaterInputStreamFactory<?>	getDecompressorForExtension(String extension) Gets the decompressor for a file extension.
static InflaterInputStreamFactory<?>	getDecompressorForFileName(String fileName) Gets the decompressor for a file name.

Methods inherited from class java.lang.Object

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

Method Detail

getCommonSuffixes

public static Collection<String> getCommonSuffixes()

Gets all common file extensions of supported file compression formats.

getDecompressorForExtension

@Nullable
public static InflaterInputStreamFactory<?> getDecompressorForExtension(String extension)

Gets the decompressor for a file extension. Returns null if there is no decompressor for this file extension.

getDecompressorForFileName

@Nullable
public static InflaterInputStreamFactory<?> getDecompressorForFileName(String fileName)

Gets the decompressor for a file name. This checks the file against all known and supported file extensions. Returns null if there is no decompressor for this file name.