public static class TestingJobManagerMessages.NotifyWhenAccumulatorChange extends Object implements scala.Product, scala.Serializable
TestingTaskManagerMessages.AccumulatorsChanged
message by a task that changed the accumulators. This message is then
forwarded to the JobManager which will send the accumulators in the TestingJobManagerMessages.UpdatedAccumulators
message when the next Heartbeat occurs.Constructor and Description |
---|
NotifyWhenAccumulatorChange(JobID jobID) |
Modifier and Type | Method and Description |
---|---|
JobID |
jobID() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.