pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.execute

StreamExecutionEnvironment.execute(job_name: str | None = None) → JobExecutionResult

Triggers the program execution. The environment will execute all parts of the program that have resulted in a “sink” operation. Sink operations are for example printing results or forwarding them to a message queue.

The program execution will be logged and displayed with the provided name

Parameters:

job_name – Desired name of the job, optional.

Returns:

The result of the job execution, containing elapsed time and accumulators.