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
All Methods Static Methods Concrete Methods Modifier and Type Method 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.
-
-
-
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.
-
-