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.

New in version 1.11.0.