pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.execute

StreamExecutionEnvironment.execute(job_name: Optional[str] = None) → pyflink.common.job_execution_result.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.