public class AccumulatorSnapshot extends Object implements Serializable
Constructor and Description |
---|
AccumulatorSnapshot(JobID jobID,
ExecutionAttemptID executionAttemptID,
Map<String,Accumulator<?,?>> userAccumulators) |
Modifier and Type | Method and Description |
---|---|
Map<String,Accumulator<?,?>> |
deserializeUserAccumulators(ClassLoader classLoader)
Gets the user-defined accumulators values.
|
ExecutionAttemptID |
getExecutionAttemptID() |
JobID |
getJobID() |
public AccumulatorSnapshot(JobID jobID, ExecutionAttemptID executionAttemptID, Map<String,Accumulator<?,?>> userAccumulators) throws IOException
IOException
public JobID getJobID()
public ExecutionAttemptID getExecutionAttemptID()
public Map<String,Accumulator<?,?>> deserializeUserAccumulators(ClassLoader classLoader) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.