pyflink.datastream.connectors.file_system.FileSourceBuilder#

class FileSourceBuilder(j_file_source_builder)[source]#

The builder for the FileSource, to configure the various behaviors.

Start building the source via one of the following methods:

for_record_stream_format()

Methods

`build`()	Creates the file source with the settings applied to this builder.
`monitor_continuously`(discovery_interval)	Sets this source to streaming ("continuous monitoring") mode.
`process_static_file_set`()	Sets this source to bounded (batch) mode.
`set_file_enumerator`(file_enumerator)	Configures the FileEnumerator for the source.
`set_split_assigner`(split_assigner)	Configures the FileSplitAssigner for the source.