Package org.apache.flink.changelog.fs

Class ChangelogStorageMetricGroup

java.lang.Object

org.apache.flink.runtime.metrics.groups.ProxyMetricGroup<MetricGroup>

org.apache.flink.changelog.fs.ChangelogStorageMetricGroup

All Implemented Interfaces:

MetricGroup

@ThreadSafe
public class ChangelogStorageMetricGroup
extends ProxyMetricGroup<MetricGroup>

Metrics related to the Changelog Storage used by the Changelog State Backend. Thread-safety is required because it is used by multiple uploader threads.

Field Summary

Fields

Modifier and Type	Field	Description
static String	CHANGELOG_STORAGE_ATTEMPTS_PER_UPLOAD
static String	CHANGELOG_STORAGE_NUM_UPLOAD_FAILURES
static String	CHANGELOG_STORAGE_NUM_UPLOAD_REQUESTS
static String	CHANGELOG_STORAGE_TOTAL_ATTEMPTS_PER_UPLOAD
static String	CHANGELOG_STORAGE_UPLOAD_BATCH_SIZES
static String	CHANGELOG_STORAGE_UPLOAD_LATENCIES_NANOS
static String	CHANGELOG_STORAGE_UPLOAD_QUEUE_SIZE
static String	CHANGELOG_STORAGE_UPLOAD_SIZES

Fields inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

parentMetricGroup

Constructor Summary

Constructors

Constructor	Description
ChangelogStorageMetricGroup(MetricGroup parent)

Method Summary

Modifier and Type	Method	Description
Histogram	getAttemptsPerUpload()
Histogram	getTotalAttemptsPerUpload()
Histogram	getUploadBatchSizes()	The number of upload tasks (coming from one or more writers, i.e. backends/tasks) that were grouped together and form a single upload resulting in a single file.
Counter	getUploadFailuresCounter()
Histogram	getUploadLatenciesNanos()
Counter	getUploadsCounter()
Histogram	getUploadSizes()
void	registerUploadQueueSizeGauge(Gauge<Integer> gauge)

Methods inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

addGroup, addGroup, addSpan, counter, counter, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, meter

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.metrics.MetricGroup

addGroup, counter, counter, gauge, histogram, meter

Field Detail

CHANGELOG_STORAGE_NUM_UPLOAD_REQUESTS

public static final String CHANGELOG_STORAGE_NUM_UPLOAD_REQUESTS

See Also:

Constant Field Values

CHANGELOG_STORAGE_NUM_UPLOAD_FAILURES

public static final String CHANGELOG_STORAGE_NUM_UPLOAD_FAILURES

See Also:

Constant Field Values

CHANGELOG_STORAGE_UPLOAD_SIZES

public static final String CHANGELOG_STORAGE_UPLOAD_SIZES

See Also:

Constant Field Values

CHANGELOG_STORAGE_UPLOAD_LATENCIES_NANOS

public static final String CHANGELOG_STORAGE_UPLOAD_LATENCIES_NANOS

See Also:

Constant Field Values

CHANGELOG_STORAGE_ATTEMPTS_PER_UPLOAD

public static final String CHANGELOG_STORAGE_ATTEMPTS_PER_UPLOAD

See Also:

Constant Field Values

CHANGELOG_STORAGE_TOTAL_ATTEMPTS_PER_UPLOAD

public static final String CHANGELOG_STORAGE_TOTAL_ATTEMPTS_PER_UPLOAD

See Also:

Constant Field Values

CHANGELOG_STORAGE_UPLOAD_BATCH_SIZES

public static final String CHANGELOG_STORAGE_UPLOAD_BATCH_SIZES

See Also:

Constant Field Values

CHANGELOG_STORAGE_UPLOAD_QUEUE_SIZE

public static final String CHANGELOG_STORAGE_UPLOAD_QUEUE_SIZE

See Also:

Constant Field Values

Constructor Detail

ChangelogStorageMetricGroup

public ChangelogStorageMetricGroup(MetricGroup parent)

Method Detail

getUploadsCounter

public Counter getUploadsCounter()

getUploadFailuresCounter

public Counter getUploadFailuresCounter()

getAttemptsPerUpload

public Histogram getAttemptsPerUpload()

getTotalAttemptsPerUpload

public Histogram getTotalAttemptsPerUpload()

getUploadBatchSizes

public Histogram getUploadBatchSizes()

The number of upload tasks (coming from one or more writers, i.e. backends/tasks) that were grouped together and form a single upload resulting in a single file.

getUploadSizes

public Histogram getUploadSizes()

getUploadLatenciesNanos

public Histogram getUploadLatenciesNanos()

registerUploadQueueSizeGauge

public void registerUploadQueueSizeGauge(Gauge<Integer> gauge)