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