pyflink.datastream.connectors.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.