apache_beam.testing.load_tests package

Submodules

• apache_beam.testing.load_tests.dataflow_cost_benchmark module
  • DataflowCostBenchmark
    • DataflowCostBenchmark.run()
• apache_beam.testing.load_tests.dataflow_cost_consts module
  • Accelerator
    • Accelerator.P100
    • Accelerator.V100
    • Accelerator.T4
    • Accelerator.P4
    • Accelerator.L4
    • Accelerator.A100_40GB
    • Accelerator.A100_80GB
• apache_beam.testing.load_tests.load_test_metrics_utils module
  • parse_step()
  • split_metrics_by_namespace_and_name()
  • get_generic_distributions()
  • get_all_distributions_by_type()
  • get_distribution_dict()
  • MetricsReader
    • MetricsReader.get_counter_metric()
    • MetricsReader.publish_metrics()
    • MetricsReader.publish_values()
  • Metric
    • Metric.as_dict()
  • CounterMetric
  • DistributionMetric
  • RuntimeMetric
  • MetricsPublisher
    • MetricsPublisher.publish()
  • ConsoleMetricsPublisher
    • ConsoleMetricsPublisher.publish()
  • BigQueryMetricsPublisher
    • BigQueryMetricsPublisher.publish()
  • BigQueryClient
    • BigQueryClient.save()
  • InfluxDBMetricsPublisherOptions
    • InfluxDBMetricsPublisherOptions.validate()
    • InfluxDBMetricsPublisherOptions.http_auth_enabled()
  • InfluxDBMetricsPublisher
    • InfluxDBMetricsPublisher.publish()
  • MeasureTime
    • MeasureTime.start_bundle()
    • MeasureTime.finish_bundle()
    • MeasureTime.process()
  • MeasureBytes
    • MeasureBytes.LABEL
    • MeasureBytes.process()
  • CountMessages
    • CountMessages.LABEL
    • CountMessages.process()
  • MeasureLatency
    • MeasureLatency.LABEL
    • MeasureLatency.process()
  • AssignTimestamps
    • AssignTimestamps.process()