apache_beam.testing.load_tests.load_test_metrics_utils module

Utility functions used for integrating Metrics API into load tests pipelines.

class apache_beam.testing.load_tests.load_test_metrics_utils.BigQueryClient(project_name, table, dataset, schema_map)[source]

Bases: object

match_and_save(result_list)[source]
class apache_beam.testing.load_tests.load_test_metrics_utils.MetricsMonitor(project_name, table, dataset, schema_map)[source]

Bases: object

send_metrics(result)[source]
class apache_beam.testing.load_tests.load_test_metrics_utils.MeasureTime(namespace)[source]

Bases: apache_beam.transforms.core.DoFn

start_bundle()[source]
finish_bundle()[source]
process(element)[source]
apache_beam.testing.load_tests.load_test_metrics_utils.count_bytes(counter_name)[source]