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.

New in version 1.11.0.