Modifier and Type | Method and Description |
---|---|
MetricGroup |
RuntimeContext.getMetricGroup()
Returns the metric group for this parallel subtask.
|
Modifier and Type | Method and Description |
---|---|
MetricGroup |
AbstractRuntimeUDFContext.getMetricGroup() |
Constructor and Description |
---|
AbstractRuntimeUDFContext(TaskInfo taskInfo,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Accumulator<?,?>> accumulators,
Map<String,Future<Path>> cpTasks,
MetricGroup metrics) |
RuntimeUDFContext(TaskInfo taskInfo,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Future<Path>> cpTasks,
Map<String,Accumulator<?,?>> accumulators,
MetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
void |
ScheduledDropwizardReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
ScheduledDropwizardReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
MetricGroup.addGroup(int name)
Creates a new MetricGroup and adds it to this groups sub-groups.
|
MetricGroup |
MetricGroup.addGroup(String name)
Creates a new MetricGroup and adds it to this groups sub-groups.
|
Modifier and Type | Class and Description |
---|---|
class |
UnregisteredMetricsGroup
A special
MetricGroup that does not register any metrics at the metrics registry
and any reporters. |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
UnregisteredMetricsGroup.addGroup(int name) |
MetricGroup |
UnregisteredMetricsGroup.addGroup(String name) |
Modifier and Type | Method and Description |
---|---|
void |
JMXReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
JMXReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Modifier and Type | Method and Description |
---|---|
void |
MetricReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a new
Metric was added. |
void |
AbstractReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
MetricReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a
Metric was should be removed. |
void |
AbstractReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Constructor and Description |
---|
SimpleCheckpointStatsTracker(int historySize,
List<ExecutionJobVertex> tasksToWaitFor,
MetricGroup metrics) |
Constructor and Description |
---|
ExecutionGraph(Executor futureExecutor,
Executor ioExecutor,
JobID jobId,
String jobName,
Configuration jobConfig,
SerializedValue<ExecutionConfig> serializedConfig,
scala.concurrent.duration.FiniteDuration timeout,
RestartStrategy restartStrategy,
List<BlobKey> requiredJarFiles,
List<URL> requiredClasspaths,
Scheduler scheduler,
ClassLoader userClassLoader,
MetricGroup metricGroup) |
Modifier and Type | Method and Description |
---|---|
DistributedRuntimeUDFContext |
AbstractIterativeTask.createRuntimeContext(MetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
void |
MetricRegistry.register(Metric metric,
String metricName,
MetricGroup group)
Registers a new
Metric with this registry. |
void |
MetricRegistry.unregister(Metric metric,
String metricName,
MetricGroup group)
Un-registers the given
Metric with this registry. |
Modifier and Type | Class and Description |
---|---|
class |
ProxyMetricGroup<P extends MetricGroup>
Metric group which forwards all registration calls to its parent metric group.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMetricGroup
Abstract
MetricGroup that contains key functionality for adding metrics and groups. |
class |
ComponentMetricGroup
Abstract
MetricGroup for system components (e.g.,
TaskManager, Job, Task, Operator). |
class |
GenericMetricGroup
A simple named
MetricGroup that is used to hold
subgroups of metrics. |
class |
IOMetricGroup
Metric group that contains shareable pre-defined IO-related metrics.
|
class |
JobManagerJobMetricGroup
Special
MetricGroup representing everything belonging to
a specific job, running on the JobManager. |
class |
JobManagerMetricGroup
Special
MetricGroup representing a JobManager. |
class |
JobMetricGroup
Special abstract
MetricGroup representing everything belonging to
a specific job. |
class |
OperatorMetricGroup
Special
MetricGroup representing an Operator. |
class |
ProxyMetricGroup<P extends MetricGroup>
Metric group which forwards all registration calls to its parent metric group.
|
class |
TaskManagerJobMetricGroup
Special
MetricGroup representing everything belonging to
a specific job, running on the TaskManager. |
class |
TaskManagerMetricGroup
Special
MetricGroup representing a TaskManager. |
class |
TaskMetricGroup
Special
MetricGroup representing a Flink runtime Task. |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
ProxyMetricGroup.addGroup(int name) |
MetricGroup |
AbstractMetricGroup.addGroup(int name) |
MetricGroup |
ProxyMetricGroup.addGroup(String name) |
MetricGroup |
AbstractMetricGroup.addGroup(String name) |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
TaskContext.getMetricGroup() |
MetricGroup |
BatchTask.getMetricGroup() |
Modifier and Type | Method and Description |
---|---|
DistributedRuntimeUDFContext |
BatchTask.createRuntimeContext(MetricGroup metrics) |
Modifier and Type | Field and Description |
---|---|
protected MetricGroup |
ChainedDriver.metrics |
Constructor and Description |
---|
DistributedRuntimeUDFContext(TaskInfo taskInfo,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Future<Path>> cpTasks,
Map<String,Accumulator<?,?>> accumulators,
MetricGroup metrics) |
Modifier and Type | Field and Description |
---|---|
protected MetricGroup |
AbstractStreamOperator.metrics |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
StreamOperator.getMetricGroup() |
MetricGroup |
AbstractStreamOperator.getMetricGroup() |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
Trigger.TriggerContext.getMetricGroup()
Returns the metric group for this
Trigger . |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractFetcher.addOffsetStateGauge(MetricGroup metricGroup)
Add current and committed offsets to metric group
|
Modifier and Type | Method and Description |
---|---|
MetricGroup |
WindowOperator.Context.getMetricGroup() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.