apache_beam.runners.direct.direct_metrics module

DirectRunner implementation of MetricResults. It is in charge not only of responding to queries of current metrics, but also of keeping the common state consistent.

class apache_beam.runners.direct.direct_metrics.DirectMetrics[source]

Bases: MetricResults

commit_logical(bundle, updates)[source]
commit_physical(bundle, updates)[source]
update_physical(bundle, updates)[source]
query(filter=None)[source]
class apache_beam.runners.direct.direct_metrics.DirectMetric(aggregator)[source]

Bases: object

Keeps a consistent state for a single metric.

It keeps track of the metric’s physical and logical updates. It’s thread safe.

commit_logical(bundle, update)[source]
commit_physical(bundle, update)[source]
update_physical(bundle, update)[source]
extract_committed()[source]
extract_latest_attempted()[source]