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)

apache_beam.tools.sideinput_microbenchmark.run_benchmark(num_runs=50, input_per_source=4000, num_sources=4)