pyflink.common.job_execution_result.JobExecutionResult.get_accumulator_result#
- JobExecutionResult.get_accumulator_result(accumulator_name: str)[source]#
Gets the accumulator with the given name. Returns None, if no accumulator with that name was produced.
- Parameters
accumulator_name – The name of the accumulator.
- Returns
The value of the accumulator with the given name.
New in version 1.11.0.