apache_beam.testing.benchmarks.nexmark.nexmark_perf module

performance summary for a run of nexmark query

class apache_beam.testing.benchmarks.nexmark.nexmark_perf.NexmarkPerf(runtime_sec=None, event_count=None, event_per_sec=None, result_count=None)[source]

Bases: object

has_progress(previous_perf: NexmarkPerf) bool[source]
Parameters:

previous_perf – a NexmarkPerf object to be compared to self

Returns:

True if there are observed pipeline activity between self and other

NexmarkPerf values