org.apache.flink.configuration

Class MetricOptions

java.lang.Object

org.apache.flink.configuration.MetricOptions

@PublicEvolving
public class MetricOptions
extends Object

Configuration options for metrics and metric reporters.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Integer>	LATENCY_HISTORY_SIZE The number of measured latencies to maintain at each operator.
static ConfigOption<Long>	LATENCY_INTERVAL
static ConfigOption<String>	LATENCY_SOURCE_GRANULARITY
static ConfigOption<Long>	METRIC_FETCHER_UPDATE_INTERVAL The config parameter defining the update interval for the metric fetcher used by the web UI in milliseconds.
static ConfigOption<String>	QUERY_SERVICE_PORT The default network port range for Flink's internal metric query service.
static ConfigOption<Integer>	QUERY_SERVICE_THREAD_PRIORITY The thread priority for Flink's internal metric query service.
static ConfigOption<String>	REPORTER_CLASS
static ConfigOption<String>	REPORTER_CONFIG_PARAMETER
static ConfigOption<java.time.Duration>	REPORTER_INTERVAL
static ConfigOption<String>	REPORTERS_LIST An optional list of reporter names.
static ConfigOption<String>	SCOPE_DELIMITER The delimiter used to assemble the metric identifier.
static ConfigOption<String>	SCOPE_NAMING_JM The scope format string that is applied to all metrics scoped to a JobManager.
static ConfigOption<String>	SCOPE_NAMING_JM_JOB The scope format string that is applied to all metrics scoped to a job on a JobManager.
static ConfigOption<String>	SCOPE_NAMING_OPERATOR The scope format string that is applied to all metrics scoped to an operator.
static ConfigOption<String>	SCOPE_NAMING_TASK The scope format string that is applied to all metrics scoped to a task.
static ConfigOption<String>	SCOPE_NAMING_TM The scope format string that is applied to all metrics scoped to a TaskManager.
static ConfigOption<String>	SCOPE_NAMING_TM_JOB The scope format string that is applied to all metrics scoped to a job on a TaskManager.
static ConfigOption<Boolean>	SYSTEM_RESOURCE_METRICS Whether Flink should report system resource metrics such as machine's CPU, memory or network usage.
static ConfigOption<Long>	SYSTEM_RESOURCE_METRICS_PROBING_INTERVAL Interval between probing of system resource metrics specified in milliseconds.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

REPORTERS_LIST

public static final ConfigOption<String> REPORTERS_LIST

An optional list of reporter names. If configured, only reporters whose name matches any of the names in the list will be started. Otherwise, all reporters that could be found in the configuration will be started.

Example:

 metrics.reporters = foo,bar

 metrics.reporter.foo.class = org.apache.flink.metrics.reporter.JMXReporter
 metrics.reporter.foo.interval = 10

 metrics.reporter.bar.class = org.apache.flink.metrics.graphite.GraphiteReporter
 metrics.reporter.bar.port = 1337
 

REPORTER_CLASS

public static final ConfigOption<String> REPORTER_CLASS

REPORTER_INTERVAL

public static final ConfigOption<java.time.Duration> REPORTER_INTERVAL

REPORTER_CONFIG_PARAMETER

public static final ConfigOption<String> REPORTER_CONFIG_PARAMETER

SCOPE_DELIMITER

public static final ConfigOption<String> SCOPE_DELIMITER

The delimiter used to assemble the metric identifier.

SCOPE_NAMING_JM

public static final ConfigOption<String> SCOPE_NAMING_JM

The scope format string that is applied to all metrics scoped to a JobManager.

SCOPE_NAMING_TM

public static final ConfigOption<String> SCOPE_NAMING_TM

The scope format string that is applied to all metrics scoped to a TaskManager.

SCOPE_NAMING_JM_JOB

public static final ConfigOption<String> SCOPE_NAMING_JM_JOB

The scope format string that is applied to all metrics scoped to a job on a JobManager.

SCOPE_NAMING_TM_JOB

public static final ConfigOption<String> SCOPE_NAMING_TM_JOB

The scope format string that is applied to all metrics scoped to a job on a TaskManager.

SCOPE_NAMING_TASK

public static final ConfigOption<String> SCOPE_NAMING_TASK

The scope format string that is applied to all metrics scoped to a task.

SCOPE_NAMING_OPERATOR

public static final ConfigOption<String> SCOPE_NAMING_OPERATOR

The scope format string that is applied to all metrics scoped to an operator.

LATENCY_INTERVAL

public static final ConfigOption<Long> LATENCY_INTERVAL

LATENCY_SOURCE_GRANULARITY

public static final ConfigOption<String> LATENCY_SOURCE_GRANULARITY

LATENCY_HISTORY_SIZE

public static final ConfigOption<Integer> LATENCY_HISTORY_SIZE

The number of measured latencies to maintain at each operator.

SYSTEM_RESOURCE_METRICS

public static final ConfigOption<Boolean> SYSTEM_RESOURCE_METRICS

Whether Flink should report system resource metrics such as machine's CPU, memory or network usage.

SYSTEM_RESOURCE_METRICS_PROBING_INTERVAL

public static final ConfigOption<Long> SYSTEM_RESOURCE_METRICS_PROBING_INTERVAL

Interval between probing of system resource metrics specified in milliseconds. Has an effect only when SYSTEM_RESOURCE_METRICS is enabled.

QUERY_SERVICE_PORT

public static final ConfigOption<String> QUERY_SERVICE_PORT

The default network port range for Flink's internal metric query service. The "0" means that Flink searches for a free port.

QUERY_SERVICE_THREAD_PRIORITY

public static final ConfigOption<Integer> QUERY_SERVICE_THREAD_PRIORITY

The thread priority for Flink's internal metric query service. The 1 means the min priority and the 10 means the max priority.

METRIC_FETCHER_UPDATE_INTERVAL

public static final ConfigOption<Long> METRIC_FETCHER_UPDATE_INTERVAL

The config parameter defining the update interval for the metric fetcher used by the web UI in milliseconds.