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 |
---|---|
default <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,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
<M extends Meter> |
UnregisteredMetricsGroup.meter(String name,
M meter) |
Modifier and Type | Field and Description |
---|---|
protected Map<Meter,String> |
AbstractReporter.meters |
Modifier and Type | Method and Description |
---|---|
Optional<Meter> |
MetricListener.getMeter(String... identifier)
Get registered
Meter with identifier relative to the root metric group. |
Constructor and Description |
---|
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesIn,
Meter bytesOut,
Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters,
Gauge<Long> accumulatedBackPressuredTime,
Gauge<Long> accumulatedIdleTime,
Gauge<Double> accumulatedBusyTime) |
Modifier and Type | Class and Description |
---|---|
class |
ThresholdMeter
A timestamp queue based threshold meter.
|
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(String name,
M meter) |
<M extends Meter> |
AbstractMetricGroup.meter(String name,
M meter) |
Modifier and Type | Method and Description |
---|---|
Meter |
TaskIOMetricGroup.getMailboxThroughput() |
Meter |
InternalOperatorIOMetricGroup.getNumRecordsInRateMeter() |
Meter |
InternalOperatorIOMetricGroup.getNumRecordsOutRate() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.