pyflink.common.job_execution_result.JobExecutionResult.get_all_accumulator_results

JobExecutionResult.get_all_accumulator_results() → Dict[str, Any]

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.

Added in version 1.11.0.