Constructor and Description |
---|
FlinkCounterWrapper(Counter counter) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleCounter
A simple low-overhead
Counter that is not thread-safe. |
Modifier and Type | Method and Description |
---|---|
<C extends Counter> |
MetricGroup.counter(int name,
C counter)
Registers a
Counter with Flink. |
<C extends Counter> |
MetricGroup.counter(String name,
C counter)
Registers a
Counter with Flink. |
Modifier and Type | Method and Description |
---|---|
Counter |
MetricGroup.counter(int name)
Creates and registers a new
Counter with Flink. |
Counter |
MetricGroup.counter(String name)
Creates and registers a new
Counter with Flink. |
Constructor and Description |
---|
MeterView(Counter counter,
int timeSpanInSeconds) |
Modifier and Type | Method and Description |
---|---|
<C extends Counter> |
UnregisteredMetricsGroup.counter(int name,
C counter) |
<C extends Counter> |
UnregisteredMetricsGroup.counter(String name,
C counter) |
Modifier and Type | Method and Description |
---|---|
Counter |
UnregisteredMetricsGroup.counter(int name) |
Counter |
UnregisteredMetricsGroup.counter(String name) |
Modifier and Type | Field and Description |
---|---|
protected Map<Counter,String> |
AbstractReporter.counters |
Modifier and Type | Field and Description |
---|---|
protected Counter |
InputChannel.numBytesIn |
Constructor and Description |
---|
InputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
int initialBackoff,
int maxBackoff,
Counter numBytesIn) |
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 |
---|---|
<C extends Counter> |
ProxyMetricGroup.counter(int name,
C counter) |
<C extends Counter> |
AbstractMetricGroup.counter(int name,
C counter) |
<C extends Counter> |
ProxyMetricGroup.counter(String name,
C counter) |
<C extends Counter> |
AbstractMetricGroup.counter(String name,
C counter) |
Modifier and Type | Method and Description |
---|---|
Counter |
ProxyMetricGroup.counter(int name) |
Counter |
AbstractMetricGroup.counter(int name) |
Counter |
ProxyMetricGroup.counter(String name) |
Counter |
AbstractMetricGroup.counter(String name) |
Counter |
TaskIOMetricGroup.getNumBytesInLocalCounter() |
Counter |
TaskIOMetricGroup.getNumBytesInRemoteCounter() |
Counter |
TaskIOMetricGroup.getNumBytesOutCounter() |
Counter |
TaskIOMetricGroup.getNumRecordsInCounter() |
Counter |
OperatorIOMetricGroup.getNumRecordsInCounter() |
Counter |
TaskIOMetricGroup.getNumRecordsOutCounter() |
Counter |
OperatorIOMetricGroup.getNumRecordsOutCounter() |
Modifier and Type | Method and Description |
---|---|
void |
TaskIOMetricGroup.reuseRecordsInputCounter(Counter numRecordsInCounter) |
void |
TaskIOMetricGroup.reuseRecordsOutputCounter(Counter numRecordsOutCounter) |
Modifier and Type | Field and Description |
---|---|
protected Counter |
ChainedDriver.numRecordsIn |
protected Counter |
ChainedDriver.numRecordsOut |
Constructor and Description |
---|
CountingCollector(Collector<OUT> collector,
Counter numRecordsOut) |
CountingIterable(Iterable<IN> iterable,
Counter numRecordsIn) |
CountingIterator(Iterator<IN> iterator,
Counter numRecordsIn) |
CountingMutableObjectIterator(MutableObjectIterator<IN> iterator,
Counter numRecordsIn) |
Constructor and Description |
---|
CountingOutput(Output<StreamRecord<OUT>> output,
Counter counter) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.