public static class TestingJobManagerMessages.UpdatedAccumulators extends Object implements scala.Product, scala.Serializable
Constructor and Description |
---|
UpdatedAccumulators(JobID jobID,
Map<ExecutionAttemptID,Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> flinkAccumulators,
Map<String,Accumulator<?,?>> userAccumulators) |
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> |
flinkAccumulators() |
JobID |
jobID() |
Map<String,Accumulator<?,?>> |
userAccumulators() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public UpdatedAccumulators(JobID jobID, Map<ExecutionAttemptID,Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> flinkAccumulators, Map<String,Accumulator<?,?>> userAccumulators)
public JobID jobID()
public Map<ExecutionAttemptID,Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> flinkAccumulators()
public Map<String,Accumulator<?,?>> userAccumulators()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.