pyflink.common.job_execution_result.JobExecutionResult.get_accumulator_result

JobExecutionResult.get_accumulator_result(accumulator_name: str)

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.

Added in version 1.11.0.