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: apache_beam.metrics.metric.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]