org.apache.flink.streaming.connectors.kinesis.metrics

Class KinesisConsumerMetricConstants

java.lang.Object

org.apache.flink.streaming.connectors.kinesis.metrics.KinesisConsumerMetricConstants

@Internal
public class KinesisConsumerMetricConstants
extends Object

A collection of consumer metric related constant names.

The names must not be changed, as that would break backwards compatibility for the consumer metrics.

Field Summary

Fields

Modifier and Type	Field and Description
static String	AVG_RECORD_SIZE_BYTES
static String	BYTES_PER_READ
static String	KINESIS_CONSUMER_METRICS_GROUP
static String	LOOP_FREQUENCY_HZ
static String	MAX_RECORDS_PER_FETCH
static String	MILLIS_BEHIND_LATEST_GAUGE
static String	NUM_AGGREGATED_RECORDS_PER_FETCH
static String	NUM_DEAGGREGATED_RECORDS_PER_FETCH
static String	RUNTIME_LOOP_NANOS
static String	SHARD_METRICS_GROUP
static String	SLEEP_TIME_MILLIS
static String	STREAM_METRICS_GROUP

Constructor Summary

Constructors

Constructor and Description
KinesisConsumerMetricConstants()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KINESIS_CONSUMER_METRICS_GROUP

public static final String KINESIS_CONSUMER_METRICS_GROUP

See Also:

Constant Field Values

STREAM_METRICS_GROUP

public static final String STREAM_METRICS_GROUP

See Also:

Constant Field Values

SHARD_METRICS_GROUP

public static final String SHARD_METRICS_GROUP

See Also:

Constant Field Values

MILLIS_BEHIND_LATEST_GAUGE

public static final String MILLIS_BEHIND_LATEST_GAUGE

See Also:

Constant Field Values

SLEEP_TIME_MILLIS

public static final String SLEEP_TIME_MILLIS

See Also:

Constant Field Values

MAX_RECORDS_PER_FETCH

public static final String MAX_RECORDS_PER_FETCH

See Also:

Constant Field Values

NUM_AGGREGATED_RECORDS_PER_FETCH

public static final String NUM_AGGREGATED_RECORDS_PER_FETCH

See Also:

Constant Field Values

NUM_DEAGGREGATED_RECORDS_PER_FETCH

public static final String NUM_DEAGGREGATED_RECORDS_PER_FETCH

See Also:

Constant Field Values

AVG_RECORD_SIZE_BYTES

public static final String AVG_RECORD_SIZE_BYTES

See Also:

Constant Field Values

RUNTIME_LOOP_NANOS

public static final String RUNTIME_LOOP_NANOS

See Also:

Constant Field Values

LOOP_FREQUENCY_HZ

public static final String LOOP_FREQUENCY_HZ

See Also:

Constant Field Values

BYTES_PER_READ

public static final String BYTES_PER_READ

See Also:

Constant Field Values

Constructor Detail

KinesisConsumerMetricConstants

public KinesisConsumerMetricConstants()