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 org.apache.flink.api.common.io.compression.InflaterInputStreamFactory<?>getDecompressorForExtension(String extension)Gets the decompressor for a file extension.static org.apache.flink.api.common.io.compression.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 org.apache.flink.api.common.io.compression.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 org.apache.flink.api.common.io.compression.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.
-
-