pyflink.datastream.connectors.file_system.FileCompactor#

class FileCompactor(j_file_compactor)[source]#

The FileCompactor is responsible for compacting files into one file.

Added in version 1.16.0.

Methods

`concat_file_compactor`([file_delimiter])	Returns a file compactor that simply concat the compacting files.
`get_java_object`()
`identical_file_compactor`()	Returns a file compactor that directly copy the content of the only input file to the output.