pyflink.metrics package

Module contents

class pyflink.metrics.Counter

Bases: pyflink.metrics.metricbase.Metric, abc.ABC

Counter metric interface. Allows a count to be incremented/decremented during pipeline execution.

New in version 1.11.0.

abstract dec(n: int = 1)

Decrement the current count by 1.

New in version 1.11.0.

abstract get_count() → int

Returns the current count.

New in version 1.11.0.

abstract inc(n: int = 1)

Increment the current count by the given value.

New in version 1.11.0.

class pyflink.metrics.Distribution

Bases: pyflink.metrics.metricbase.Metric, abc.ABC

Distribution Metric interface.

Allows statistics about the distribution of a variable to be collected during pipeline execution.

New in version 1.11.0.

abstract update(value)

class pyflink.metrics.Meter

Bases: pyflink.metrics.metricbase.Metric, abc.ABC

Meter Metric interface.

Metric for measuring throughput.

New in version 1.11.0.

abstract get_count() → int

Get number of events marked on the meter.

New in version 1.11.0.

abstract mark_event(value: int = 1)

Mark occurrence of the specified number of events.

New in version 1.11.0.

class pyflink.metrics.Metric

Bases: abc.ABC

Base interface of a metric object.

New in version 1.11.0.

class pyflink.metrics.MetricGroup

Bases: abc.ABC

A MetricGroup is a named container for metrics and further metric subgroups.

Instances of this class can be used to register new metrics with Flink and to create a nested hierarchy based on the group names.

A MetricGroup is uniquely identified by it’s place in the hierarchy and name.

New in version 1.11.0.

abstract add_group(name: str, extra: str = None) → pyflink.metrics.metricbase.MetricGroup

Creates a new MetricGroup and adds it to this groups sub-groups.

If extra is not None, creates a new key-value MetricGroup pair. The key group is added to this group’s sub-groups, while the value group is added to the key group’s sub-groups. In this case, the value group will be returned and a user variable will be defined.

New in version 1.11.0.

abstract counter(name: str) → pyflink.metrics.metricbase.Counter

Registers a new Counter with Flink.

New in version 1.11.0.

abstract distribution(name: str) → pyflink.metrics.metricbase.Distribution

Registers a new Distribution with Flink.

New in version 1.11.0.

abstract gauge(name: str, obj: Callable[], int]) → None

Registers a new Gauge with Flink.

New in version 1.11.0.

abstract meter(name: str, time_span_in_seconds: int = 60) → pyflink.metrics.metricbase.Meter

Registers a new Meter with Flink.

New in version 1.11.0.