Modifier and Type | Method and Description |
---|---|
Counter |
ChangelogStorageMetricGroup.getUploadFailuresCounter() |
Counter |
ChangelogStorageMetricGroup.getUploadsCounter() |
Modifier and Type | Method and Description |
---|---|
static void |
MetricUtil.sync(org.apache.kafka.common.Metric from,
Counter to)
Ensures that the counter has the same value as the given Kafka metric.
|
Constructor and Description |
---|
FlinkCounterWrapper(Counter counter) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleCounter
A simple low-overhead
Counter that is not thread-safe. |
class |
ThreadSafeSimpleCounter
A simple low-overhead
Counter that is thread-safe. |
Modifier and Type | Method and Description |
---|---|
default <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 |
---|---|
default 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) |
MeterView(Counter counter,
int timeSpanInSeconds) |
Constructor and Description |
---|
DCounter(Counter c,
String metricName,
String host,
List<String> tags,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
<C extends Counter> |
UnregisteredMetricsGroup.counter(String name,
C counter) |
Modifier and Type | Method and Description |
---|---|
Counter |
UnregisteredMetricsGroup.counter(String name) |
Counter |
OperatorIOMetricGroup.getNumBytesInCounter()
The total number of input bytes since the task started.
|
Counter |
OperatorIOMetricGroup.getNumBytesOutCounter()
The total number of output bytes since the task started.
|
Counter |
SinkWriterMetricGroup.getNumBytesSendCounter()
The total number of output send bytes since the task started.
|
Counter |
OperatorIOMetricGroup.getNumRecordsInCounter()
The total number of input records since the operator started.
|
Counter |
SourceReaderMetricGroup.getNumRecordsInErrorsCounter()
The total number of record that failed to consume, process, or emit.
|
Counter |
OperatorIOMetricGroup.getNumRecordsOutCounter()
The total number of output records since the operator started.
|
Counter |
SinkWriterMetricGroup.getNumRecordsOutErrorsCounter()
The total number of records failed to send.
|
Counter |
SinkWriterMetricGroup.getNumRecordsSendCounter()
The total number of records have been sent to the downstream system.
|
Counter |
SinkWriterMetricGroup.getNumRecordsSendErrorsCounter()
The total number of records failed to send.
|
Modifier and Type | Method and Description |
---|---|
void |
CacheMetricGroup.hitCounter(Counter hitCounter)
The number of cache hits.
|
void |
CacheMetricGroup.loadCounter(Counter loadCounter)
The number of times to load data into cache from external system.
|
void |
CacheMetricGroup.missCounter(Counter missCounter)
The number of cache misses.
|
void |
CacheMetricGroup.numLoadFailuresCounter(Counter numLoadFailuresCounter)
The number of load failures.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Counter,String> |
AbstractReporter.counters |
Modifier and Type | Method and Description |
---|---|
Optional<Counter> |
MetricListener.getCounter(String... identifier)
Get registered
Counter 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 | Method and Description |
---|---|
Counter |
InputChannelMetrics.getNumBuffersInLocalCounter() |
Counter |
InputChannelMetrics.getNumBuffersInRemoteCounter() |
Counter |
InputChannelMetrics.getNumBytesInLocalCounter() |
Counter |
InputChannelMetrics.getNumBytesInRemoteCounter() |
Modifier and Type | Field and Description |
---|---|
protected Counter |
ResultPartition.numBuffersOut |
protected Counter |
ResultPartition.numBytesOut |
protected Counter |
ResultPartition.numBytesProduced
The difference with
ResultPartition.numBytesOut : numBytesProduced represents the number of bytes
actually produced, and numBytesOut represents the number of bytes sent to downstream tasks. |
Modifier and Type | Field and Description |
---|---|
protected Counter |
InputChannel.numBuffersIn |
protected Counter |
InputChannel.numBytesIn |
Constructor and Description |
---|
InputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
int consumedSubpartitionIndex,
int initialBackoff,
int maxBackoff,
Counter numBytesIn,
Counter numBuffersIn) |
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
int consumedSubpartitionIndex,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
int initialBackoff,
int maxBackoff,
Counter numBytesIn,
Counter numBuffersIn,
ChannelStateWriter stateWriter) |
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
int consumedSubpartitionIndex,
ConnectionID connectionId,
ConnectionManager connectionManager,
int initialBackOff,
int maxBackoff,
int networkBuffersPerChannel,
Counter numBytesIn,
Counter numBuffersIn,
ChannelStateWriter stateWriter) |
Modifier and Type | Method and Description |
---|---|
Counter |
HsOutputMetrics.getNumBuffersOut() |
Counter |
HsOutputMetrics.getNumBytesOut() |
Constructor and Description |
---|
HsOutputMetrics(Counter numBytesOut,
Counter numBuffersOut) |
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(String name,
C counter) |
<C extends Counter> |
AbstractMetricGroup.counter(String name,
C counter) |
Modifier and Type | Method and Description |
---|---|
Counter |
ProxyMetricGroup.counter(String name) |
Counter |
AbstractMetricGroup.counter(String name) |
Counter |
TaskIOMetricGroup.getNumBuffersOutCounter() |
Counter |
InternalOperatorIOMetricGroup.getNumBytesInCounter() |
Counter |
TaskIOMetricGroup.getNumBytesInCounter() |
Counter |
InternalOperatorIOMetricGroup.getNumBytesOutCounter() |
Counter |
TaskIOMetricGroup.getNumBytesOutCounter() |
Counter |
InternalSinkWriterMetricGroup.getNumBytesSendCounter() |
Counter |
TaskIOMetricGroup.getNumMailsProcessedCounter() |
Counter |
InternalOperatorIOMetricGroup.getNumRecordsInCounter() |
Counter |
TaskIOMetricGroup.getNumRecordsInCounter() |
Counter |
InternalSourceReaderMetricGroup.getNumRecordsInErrorsCounter() |
Counter |
InternalOperatorIOMetricGroup.getNumRecordsOutCounter() |
Counter |
TaskIOMetricGroup.getNumRecordsOutCounter() |
Counter |
InternalSinkWriterMetricGroup.getNumRecordsOutErrorsCounter() |
Counter |
InternalSinkWriterMetricGroup.getNumRecordsSendCounter() |
Counter |
InternalSinkWriterMetricGroup.getNumRecordsSendErrorsCounter() |
Modifier and Type | Method and Description |
---|---|
void |
InternalCacheMetricGroup.hitCounter(Counter hitCounter) |
void |
InternalCacheMetricGroup.loadCounter(Counter loadCounter) |
void |
InternalCacheMetricGroup.missCounter(Counter missCounter) |
void |
InternalCacheMetricGroup.numLoadFailuresCounter(Counter numLoadFailuresCounter) |
void |
TaskIOMetricGroup.registerNumBytesProducedCounterForPartition(IntermediateResultPartitionID resultPartitionId,
Counter numBytesProducedCounter) |
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 |
---|
InputGateWithMetrics(IndexedInputGate inputGate,
Counter numBytesIn) |
Constructor and Description |
---|
CountingOutput(Output<StreamRecord<OUT>> output,
Counter counter) |
Modifier and Type | Method and Description |
---|---|
static <IN1,IN2> StreamMultipleInputProcessor |
StreamTwoInputProcessorFactory.create(TaskInvokable ownerTask,
CheckpointedInputGate[] checkpointedInputGates,
IOManager ioManager,
MemoryManager memoryManager,
TaskIOMetricGroup taskIOMetricGroup,
TwoInputStreamOperator<IN1,IN2,?> streamOperator,
WatermarkGauge input1WatermarkGauge,
WatermarkGauge input2WatermarkGauge,
OperatorChain<?,?> operatorChain,
StreamConfig streamConfig,
Configuration taskManagerConfig,
Configuration jobConfig,
ExecutionConfig executionConfig,
ClassLoader userClassloader,
Counter numRecordsIn,
InflightDataRescalingDescriptor inflightDataRescalingDescriptor,
java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners,
TaskInfo taskInfo) |
static StreamMultipleInputProcessor |
StreamMultipleInputProcessorFactory.create(TaskInvokable ownerTask,
CheckpointedInputGate[] checkpointedInputGates,
StreamConfig.InputConfig[] configuredInputs,
IOManager ioManager,
MemoryManager memoryManager,
TaskIOMetricGroup ioMetricGroup,
Counter mainOperatorRecordsIn,
MultipleInputStreamOperator<?> mainOperator,
WatermarkGauge[] inputWatermarkGauges,
StreamConfig streamConfig,
Configuration taskManagerConfig,
Configuration jobConfig,
ExecutionConfig executionConfig,
ClassLoader userClassloader,
OperatorChain<?,?> operatorChain,
InflightDataRescalingDescriptor inflightDataRescalingDescriptor,
java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners,
TaskInfo taskInfo) |
Modifier and Type | Field and Description |
---|---|
protected Counter |
WindowOperator.numLateRecordsDropped |
Modifier and Type | Method and Description |
---|---|
protected Counter |
StreamTask.setupNumRecordsInCounter(StreamOperator streamOperator) |
Modifier and Type | Method and Description |
---|---|
Counter |
MailboxMetricsController.getMailCounter()
Gets
Counter for number of mails processed. |
Constructor and Description |
---|
MailboxMetricsController(Histogram latencyHistogram,
Counter mailCounter)
Creates instance of
MailboxMetricsController with references to metrics provided as
parameters. |
Modifier and Type | Method and Description |
---|---|
protected Counter |
RowTimeRowsBoundedPrecedingFunction.getCounter() |
protected Counter |
RowTimeRangeBoundedPrecedingFunction.getCounter() |
protected Counter |
AbstractRowTimeUnboundedPrecedingOver.getCounter() |
Modifier and Type | Method and Description |
---|---|
protected Counter |
WindowOperator.getNumLateRecordsDropped() |
Modifier and Type | Method and Description |
---|---|
Counter |
SlicingWindowOperator.getNumLateRecordsDropped() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.