pyflink.datastream.connectors.file_system.FileEnumeratorProvider

class FileEnumeratorProvider(j_file_enumerator_provider)

Factory for FileEnumerator which task is to discover all files to be read and to split them into a set of file source splits. This includes possibly, path traversals, file filtering (by name or other patterns) and deciding whether to split files into multiple splits, and how to split them.

Methods

default_non_splittable_file_enumerator()	The default file enumerator used for non-splittable formats.
default_splittable_file_enumerator()	The default file enumerator used for splittable formats.