Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

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.

previous

pyflink.datastream.connectors.file_system.BulkFormat

next

pyflink.datastream.connectors.file_system.FileSource

On this page
  • FileSourceBuilder
Show Source

Created using Sphinx 5.3.0.