apache_beam.testing.benchmarks.nexmark.monitor module

class apache_beam.testing.benchmarks.nexmark.monitor.Monitor(namespace: str, name_prefix: str)

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)

Bases: DoFn

start_bundle()

process(element, timestamp=TimestampParam)

finish_bundle()

class apache_beam.testing.benchmarks.nexmark.monitor.MonitorSuffix

Bases: object

ELEMENT_COUNTER = '.elements'

EVENT_TIMESTAMP = '.event_timestamp'

EVENT_TIME = '.event_time'