pyflink.common.job_client.JobClient.get_accumulators

JobClient.get_accumulators() → CompletableFuture

Requests the accumulators of the associated job. Accumulators can be requested while it is running or after it has finished. The class loader is used to deserialize the incoming accumulator results.

Parameters:

class_loader – Class loader used to deserialize the incoming accumulator results.

Returns:

A CompletableFuture containing the accumulators of the associated job.

Added in version 1.11.0.