Modifier and Type | Method and Description |
---|---|
AccumulatorSnapshot |
AccumulatorRegistry.getSnapshot()
Creates a snapshot of this accumulator registry.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.updateAccumulators(AccumulatorSnapshot accumulatorSnapshot)
Updates the accumulators during the runtime of a job.
|
Modifier and Type | Method and Description |
---|---|
void |
SchedulerBase.updateAccumulators(AccumulatorSnapshot accumulatorSnapshot) |
void |
SchedulerNG.updateAccumulators(AccumulatorSnapshot accumulatorSnapshot) |
Modifier and Type | Method and Description |
---|---|
Collection<AccumulatorSnapshot> |
AccumulatorReport.getAccumulatorSnapshots() |
Constructor and Description |
---|
AccumulatorReport(List<AccumulatorSnapshot> accumulatorSnapshots) |
Modifier and Type | Method and Description |
---|---|
AccumulatorSnapshot |
TaskExecutionState.getAccumulators()
Gets flink and user-defined accumulators in serialized form.
|
Constructor and Description |
---|
TaskExecutionState(JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error,
AccumulatorSnapshot accumulators,
IOMetrics ioMetrics)
Creates a new task execution state update, with an attached exception.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.