Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.runtime.rest.handler.util | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
IOMetrics |
ArchivedExecution.getIOMetrics() |
IOMetrics |
Execution.getIOMetrics() |
IOMetrics |
AccessExecution.getIOMetrics() |
Constructor and Description |
---|
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
IOMetrics ioMetrics,
ExecutionAttemptID attemptId,
int attemptNumber,
ExecutionState state,
String failureCause,
TaskManagerLocation assignedResourceLocation,
AllocationID assignedAllocationID,
int parallelSubtaskIndex,
long[] stateTimestamps) |
Modifier and Type | Method and Description |
---|---|
IOMetrics |
TaskIOMetricGroup.createSnapshot() |
Modifier and Type | Class and Description |
---|---|
class |
MutableIOMetrics
This class is a mutable version of the
IOMetrics class that allows adding up IO-related metrics. |
Modifier and Type | Method and Description |
---|---|
IOMetrics |
TaskExecutionState.getIOMetrics() |
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.