Modifier and Type | Class and Description |
---|---|
class |
DropwizardMeterWrapper
Wrapper to use a Dropwizard
Meter as a Flink Meter . |
Constructor and Description |
---|
FlinkMeterWrapper(Meter meter) |
FlinkMeterWrapper(Meter meter,
com.codahale.metrics.Clock clock) |
Modifier and Type | Class and Description |
---|---|
class |
MeterView
A MeterView provides an average rate of events per second over a given time period.
|
Modifier and Type | Method and Description |
---|---|
<M extends Meter> |
MetricGroup.meter(int name,
M meter)
Registers a new
Meter with Flink. |
<M extends Meter> |
MetricGroup.meter(String name,
M meter)
Registers a new
Meter with Flink. |
Constructor and Description |
---|
DMeter(Meter m,
String metricName,
String host,
List<String> tags) |
Modifier and Type | Method and Description |
---|---|
<M extends Meter> |
UnregisteredMetricsGroup.meter(int name,
M meter) |
<M extends Meter> |
UnregisteredMetricsGroup.meter(String name,
M meter) |
Modifier and Type | Field and Description |
---|---|
protected Map<Meter,String> |
AbstractReporter.meters |
Constructor and Description |
---|
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesLocalIn,
Meter bytesRemoteIn,
Meter bytesOut) |
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 |
---|---|
<M extends Meter> |
ProxyMetricGroup.meter(int name,
M meter) |
<M extends Meter> |
AbstractMetricGroup.meter(int name,
M meter) |
<M extends Meter> |
ProxyMetricGroup.meter(String name,
M meter) |
<M extends Meter> |
AbstractMetricGroup.meter(String name,
M meter) |
Modifier and Type | Method and Description |
---|---|
Meter |
TaskIOMetricGroup.getNumBytesInLocalRateMeter() |
Meter |
TaskIOMetricGroup.getNumBytesInRemoteRateMeter() |
Meter |
TaskIOMetricGroup.getNumBytesOutRateMeter() |
Meter |
OperatorIOMetricGroup.getNumRecordsInRateMeter() |
Meter |
OperatorIOMetricGroup.getNumRecordsOutRate() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.