pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.execute#
- StreamExecutionEnvironment.execute(job_name: Optional[str] = None) JobExecutionResult[source]#
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.