Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.metrics |
This package contains classes implementing various metrics for the job execution, based on the
Execution Graph . |
org.apache.flink.runtime.scheduler |
Modifier and Type | Interface and Description |
---|---|
interface |
AccessExecutionGraph
Common interface for the runtime
DefaultExecutionGraph and ArchivedExecutionGraph . |
interface |
ExecutionGraph
The execution graph is the central data structure that coordinates the distributed execution of a
data flow.
|
Modifier and Type | Class and Description |
---|---|
class |
ArchivedExecutionGraph
An archived execution graph represents a serializable form of an
ExecutionGraph . |
class |
DefaultExecutionGraph
Default implementation of the
ExecutionGraph . |
Constructor and Description |
---|
DownTimeGauge(JobStatusProvider jobStatusProvider) |
UpTimeGauge(JobStatusProvider jobStatusProvider) |
Modifier and Type | Class and Description |
---|---|
class |
JobStatusStore
Listens for and exposes the current job state and state timestamps.
|
Modifier and Type | Method and Description |
---|---|
static void |
SchedulerBase.registerJobMetrics(MetricGroup metrics,
JobStatusProvider jobStatusProvider,
Gauge<Long> numberOfRestarts,
DeploymentStateTimeMetrics deploymentTimeMetrics,
java.util.function.Consumer<JobStatusListener> jobStatusListenerRegistrar,
long initializationTimestamp,
MetricOptions.JobStatusMetricsSettings jobStatusMetricsSettings) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.