Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
IOMetrics |
Execution.getIOMetrics() |
IOMetrics |
ArchivedExecution.getIOMetrics() |
IOMetrics |
AccessExecution.getIOMetrics() |
Modifier and Type | Method and Description |
---|---|
IOMetrics |
TaskIOMetricGroup.createSnapshot() |
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–2017 The Apache Software Foundation. All rights reserved.