org.apache.flink.runtime.metrics

Interface MetricRegistry

All Known Implementing Classes:

MetricRegistryImpl, NoOpMetricRegistry

public interface MetricRegistry

Interface for a metric registry.

Method Summary

Modifier and Type	Method and Description
void	addSpan(SpanBuilder spanBuilder) Add and log a Span.
char	getDelimiter() Returns the global delimiter.
default String	getMetricQueryServiceGatewayRpcAddress() Returns the gateway of the MetricQueryService or null, if none is started.
int	getNumberReporters() Returns the number of registered reporters.
ScopeFormats	getScopeFormats() Returns the scope formats.
void	register(Metric metric, String metricName, AbstractMetricGroup group) Registers a new Metric with this registry.
void	unregister(Metric metric, String metricName, AbstractMetricGroup group) Un-registers the given Metric with this registry.

Method Detail

getDelimiter

char getDelimiter()

Returns the global delimiter.

Returns:

global delimiter

getNumberReporters

int getNumberReporters()

Returns the number of registered reporters.

addSpan

void addSpan(SpanBuilder spanBuilder)

Add and log a Span.

register

void register(Metric metric,
              String metricName,
              AbstractMetricGroup group)

Registers a new Metric with this registry.

Parameters:

metric - the metric that was added

metricName - the name of the metric

group - the group that contains the metric

unregister

void unregister(Metric metric,
                String metricName,
                AbstractMetricGroup group)

Un-registers the given Metric with this registry.

Parameters:

metric - the metric that should be removed

metricName - the name of the metric

group - the group that contains the metric

getScopeFormats

ScopeFormats getScopeFormats()

Returns the scope formats.

Returns:

scope formats

getMetricQueryServiceGatewayRpcAddress

@Nullable
default String getMetricQueryServiceGatewayRpcAddress()

Returns the gateway of the MetricQueryService or null, if none is started.

Returns:

Gateway of the MetricQueryService or null, if none is started