apache_beam.testing.benchmarks.nexmark.monitor module

class apache_beam.testing.benchmarks.nexmark.monitor.Monitor(namespace, name_prefix)[source]

Bases: object

A monitor of elements with support for later retrieving their metrics

monitor objects contains a doFn to record metrics

Parameters:
  • namespace – the namespace all metrics within this Monitor uses
  • name_prefix – a prefix for this Monitor’s metrics’ names, intended to be unique in per-monitor basis in pipeline
class apache_beam.testing.benchmarks.nexmark.monitor.MonitorDoFn(namespace, prefix)[source]

Bases: apache_beam.transforms.core.DoFn

start_bundle()[source]
process(element, timestamp=TimestampParam)[source]
finish_bundle()[source]
class apache_beam.testing.benchmarks.nexmark.monitor.MonitorSuffix[source]

Bases: object

ELEMENT_COUNTER = '.elements'
EVENT_TIMESTAMP = '.event_timestamp'
EVENT_TIME = '.event_time'