apache_beam.tools.sideinput_microbenchmark module

A microbenchmark for measuring performance of Side Inputs iterable.

Runs side input iterable that fetches from multiple FakeSources, and measures the time to fetch all elements from all sources.

Run as
python -m apache_beam.tools.sideinput_microbenchmark
apache_beam.tools.sideinput_microbenchmark.long_generator(value, elements)[source]
apache_beam.tools.sideinput_microbenchmark.run_benchmark(num_runs=50, input_per_source=4000, num_sources=4)[source]