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 |
TaskExecutionStateTransition.getIOMetrics() |
IOMetrics |
Execution.getIOMetrics() |
IOMetrics |
AccessExecution.getIOMetrics() |
IOMetrics |
ArchivedExecution.getIOMetrics() |
Constructor and Description |
---|
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
IOMetrics ioMetrics,
ExecutionAttemptID attemptId,
ExecutionState state,
ErrorInfo failureCause,
TaskManagerLocation assignedResourceLocation,
AllocationID assignedAllocationID,
long[] stateTimestamps,
long[] stateEndTimestamps) |
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(ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error,
AccumulatorSnapshot accumulators,
IOMetrics ioMetrics)
Creates a new task execution state update, with an attached exception.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.