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.stream_execution_environment.StreamExecutionEnvironment.configure#

StreamExecutionEnvironment.configure(configuration: Configuration)[source]#

Sets all relevant options contained in the Configuration. such as e.g. pipeline.time-characteristic. It will reconfigure StreamExecutionEnvironment, ExecutionConfig and CheckpointConfig.

It will change the value of a setting only if a corresponding option was set in the configuration. If a key is not present, the current value of a field will remain untouched.

Parameters

configuration – a configuration to read the values from.

New in version 1.15.0.

previous

pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_stream_time_characteristic

next

pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.add_python_file

On this page
  • StreamExecutionEnvironment.configure()
Show Source

Created using Sphinx 5.3.0.