pyflink.datastream.connectors.file_system.FileCompactor

class FileCompactor(j_file_compactor)

The FileCompactor is responsible for compacting files into one file.

New 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.