gets the flink internal accumulators values . concode_field_sep JobID jobID concode_elem_sep long serialVersionUID concode_elem_sep SerializedValue<Map<String,Accumulator<?,?>>> userAccumulators concode_elem_sep ExecutionAttemptID executionAttemptID concode_elem_sep SerializedValue<Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> flinkAccumulators concode_field_sep Map<String,Accumulator<?,?>> deserializeUserAccumulators concode_elem_sep JobID getJobID concode_elem_sep ExecutionAttemptID getExecutionAttemptID
Map < AccumulatorRegistry . Metric , Accumulator < ? , ? >> function ( ) { return flinkAccumulators . deserializeValue ( ClassLoader . getSystemClassLoader ( ) ) ; }