Package | Description |
---|---|
org.apache.flink.configuration | |
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.metrics |
Modifier and Type | Method and Description |
---|---|
static MetricOptions.JobStatusMetricsSettings |
MetricOptions.JobStatusMetricsSettings.fromConfiguration(Configuration configuration) |
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) |
Modifier and Type | Method and Description |
---|---|
static void |
StateTimeMetric.register(MetricOptions.JobStatusMetricsSettings jobStatusMetricsSettings,
MetricGroup metricGroup,
StateTimeMetric stateTimeMetric,
String baseName) |
Constructor and Description |
---|
DeploymentStateTimeMetrics(JobType semantic,
MetricOptions.JobStatusMetricsSettings stateTimeMetricsSettings) |
JobStatusMetrics(long initializationTimestamp,
MetricOptions.JobStatusMetricsSettings jobStatusMetricsSettings) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.