Uses of Interface
org.apache.flink.runtime.metrics.MetricRegistry

Packages that use MetricRegistry

Package	Description
org.apache.flink.runtime.entrypoint.component
org.apache.flink.runtime.metrics
org.apache.flink.runtime.metrics.groups
org.apache.flink.runtime.metrics.util
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.taskexecutor

Uses of MetricRegistry in org.apache.flink.runtime.entrypoint.component

Methods in org.apache.flink.runtime.entrypoint.component with parameters of type MetricRegistry

Modifier and Type	Method and Description
DispatcherResourceManagerComponent	DefaultDispatcherResourceManagerComponentFactory.create(Configuration configuration, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
DispatcherResourceManagerComponent	DispatcherResourceManagerComponentFactory.create(Configuration configuration, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)

Uses of MetricRegistry in org.apache.flink.runtime.metrics

Classes in org.apache.flink.runtime.metrics that implement MetricRegistry

Modifier and Type	Class and Description
class	MetricRegistryImpl A MetricRegistry keeps track of all registered Metrics.
class	NoOpMetricRegistry Metric registry which does nothing.

Fields in org.apache.flink.runtime.metrics declared as MetricRegistry

Modifier and Type	Field and Description
static MetricRegistry	NoOpMetricRegistry.INSTANCE

Uses of MetricRegistry in org.apache.flink.runtime.metrics.groups

Fields in org.apache.flink.runtime.metrics.groups declared as MetricRegistry

Modifier and Type	Field and Description
protected MetricRegistry	AbstractMetricGroup.registry The registry that this metrics group belongs to.

Methods in org.apache.flink.runtime.metrics.groups with parameters of type MetricRegistry

Modifier and Type	Method and Description
static ProcessMetricGroup	ProcessMetricGroup.create(MetricRegistry metricRegistry, String hostname)
static ResourceManagerMetricGroup	ResourceManagerMetricGroup.create(MetricRegistry metricRegistry, String hostname)
static SlotManagerMetricGroup	SlotManagerMetricGroup.create(MetricRegistry metricRegistry, String hostname)

Constructors in org.apache.flink.runtime.metrics.groups with parameters of type MetricRegistry

Constructor and Description
AbstractMetricGroup(MetricRegistry registry, String[] scope, A parent)
ComponentMetricGroup(MetricRegistry registry, String[] scope, P parent) Creates a new ComponentMetricGroup.
GenericMetricGroup(MetricRegistry registry, AbstractMetricGroup parent, String name)
JobManagerJobMetricGroup(MetricRegistry registry, JobManagerMetricGroup parent, JobID jobId, String jobName)
JobManagerMetricGroup(MetricRegistry registry, String hostname)
JobMetricGroup(MetricRegistry registry, C parent, JobID jobId, String jobName, String[] scope)
OperatorMetricGroup(MetricRegistry registry, TaskMetricGroup parent, OperatorID operatorID, String operatorName)
TaskManagerJobMetricGroup(MetricRegistry registry, TaskManagerMetricGroup parent, JobID jobId, String jobName)
TaskManagerMetricGroup(MetricRegistry registry, String hostname, String taskManagerId)
TaskMetricGroup(MetricRegistry registry, TaskManagerJobMetricGroup parent, JobVertexID vertexId, ExecutionAttemptID executionId, String taskName, int subtaskIndex, int attemptNumber)

Uses of MetricRegistry in org.apache.flink.runtime.metrics.util

Methods in org.apache.flink.runtime.metrics.util with parameters of type MetricRegistry

Modifier and Type	Method and Description
static JobManagerMetricGroup	MetricUtils.instantiateJobManagerMetricGroup(MetricRegistry metricRegistry, String hostname)
static ProcessMetricGroup	MetricUtils.instantiateProcessMetricGroup(MetricRegistry metricRegistry, String hostname, Optional<Time> systemResourceProbeInterval)
static Tuple2<TaskManagerMetricGroup,MetricGroup>	MetricUtils.instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry, String hostName, ResourceID resourceID, Optional<Time> systemResourceProbeInterval)

Uses of MetricRegistry in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster with parameters of type MetricRegistry

Modifier and Type	Method and Description
protected Collection<? extends DispatcherResourceManagerComponent>	MiniCluster.createDispatcherResourceManagerComponents(Configuration configuration, MiniCluster.RpcServiceFactory rpcServiceFactory, HighAvailabilityServices haServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)

Uses of MetricRegistry in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager with parameters of type MetricRegistry

Modifier and Type	Method and Description
ResourceManager<T>	ResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)

Uses of MetricRegistry in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor with parameters of type MetricRegistry

Modifier and Type	Method and Description
TaskManagerRunner.TaskExecutorService	TaskManagerRunner.TaskExecutorServiceFactory.createTaskExecutor(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, FatalErrorHandler fatalErrorHandler)
static TaskManagerRunner.TaskExecutorService	TaskManagerRunner.createTaskExecutorService(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, FatalErrorHandler fatalErrorHandler)
static TaskExecutor	TaskManagerRunner.startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, FatalErrorHandler fatalErrorHandler)