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. |
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,
scala.Tuple2<Integer,Integer> initialAndMaxBackoff,
Counter numBytesIn) |
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 |
IOMetricGroup.getBytesOutCounter() |
Counter |
IOMetricGroup.getNumBytesInLocalCounter() |
Counter |
IOMetricGroup.getNumBytesInRemoteCounter() |
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.