- All Implemented Interfaces:
public class ChangelogStorageMetricGroup
Metrics related to the Changelog Storage used by the Changelog State Backend. Thread-safety is
required because it is used by multiple uploader threads.
Methods inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
addGroup, addGroup, 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
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.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.