pyflink.common.job_execution_result.JobExecutionResult.get_all_accumulator_results#
- JobExecutionResult.get_all_accumulator_results() Dict[str, Any] [source]#
Gets all accumulators produced by the job. The map contains the accumulators as mappings from the accumulator name to the accumulator value.
- Returns
The dict which the keys are names of the accumulator and the values are values of the accumulator produced by the job.
New in version 1.11.0.