Modifier and Type | Method and Description |
---|---|
static <T> FlinkGaugeWrapper<T> |
FlinkGaugeWrapper.fromGauge(Gauge<?> gauge) |
Constructor and Description |
---|
FlinkGaugeWrapper(Gauge<T> gauge) |
Modifier and Type | Method and Description |
---|---|
<T,G extends Gauge<T>> |
MetricGroup.gauge(int name,
G gauge)
Registers a new
Gauge with Flink. |
<T,G extends Gauge<T>> |
MetricGroup.gauge(String name,
G gauge)
Registers a new
Gauge with Flink. |
Modifier and Type | Method and Description |
---|---|
<T,G extends Gauge<T>> |
UnregisteredMetricsGroup.gauge(int name,
G gauge) |
<T,G extends Gauge<T>> |
UnregisteredMetricsGroup.gauge(String name,
G gauge) |
Modifier and Type | Field and Description |
---|---|
protected Map<Gauge<?>,String> |
AbstractReporter.gauges |
Modifier and Type | Method and Description |
---|---|
MetricDumpSerialization.MetricSerializationResult |
MetricDumpSerialization.MetricDumpSerializer.serialize(Map<Counter,Tuple2<QueryScopeInfo,String>> counters,
Map<Gauge<?>,Tuple2<QueryScopeInfo,String>> gauges,
Map<Histogram,Tuple2<QueryScopeInfo,String>> histograms,
Map<Meter,Tuple2<QueryScopeInfo,String>> meters)
Serializes the given metrics and returns the resulting byte array.
|
Modifier and Type | Method and Description |
---|---|
<T,G extends Gauge<T>> |
ProxyMetricGroup.gauge(int name,
G gauge) |
<T,G extends Gauge<T>> |
AbstractMetricGroup.gauge(int name,
G gauge) |
<T,G extends Gauge<T>> |
ProxyMetricGroup.gauge(String name,
G gauge) |
<T,G extends Gauge<T>> |
AbstractMetricGroup.gauge(String name,
G gauge) |
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractStreamOperator.LatencyGauge
The gauge uses a HashMap internally to avoid classloading issues when accessing
the values using JMX.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaMetricWrapper
Gauge for getting the current value of a Kafka metric.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.