apache_beam.testing.benchmarks package

Subpackages

• apache_beam.testing.benchmarks.nexmark package
  • Subpackages
    • apache_beam.testing.benchmarks.nexmark.models package
      • Submodules
    • apache_beam.testing.benchmarks.nexmark.queries package
      • Submodules
  • Submodules
    • apache_beam.testing.benchmarks.nexmark.monitor module
      • Monitor
      • MonitorDoFn
      • MonitorSuffix
    • apache_beam.testing.benchmarks.nexmark.nexmark_launcher module
      • NexmarkLauncher
    • apache_beam.testing.benchmarks.nexmark.nexmark_perf module
      • NexmarkPerf
    • apache_beam.testing.benchmarks.nexmark.nexmark_util module
      • Command
      • setup_coder()
      • ParseEventFn
      • ParseJsonEventFn
      • CountAndLog
      • log_count_info()
      • display()
      • millis_to_timestamp()
      • get_counter_metric()
      • get_start_time_metric()
      • get_end_time_metric()
• apache_beam.testing.benchmarks.wordcount package
  • Submodules
    • apache_beam.testing.benchmarks.wordcount.wordcount module
      • WordcountCostBenchmark

Submodules

• apache_beam.testing.benchmarks.sort_and_batch_benchmark module
  • generate_highly_skewed_data()
  • generate_lognormal_data()
  • generate_bimodal_data()
  • generate_low_variance_data()
  • simulate_inference_latency()
  • percentile()
  • compute_padding_stats()
  • validate_invariants()
  • run_performance_benchmark()
  • run_benchmark()
  • print_results()
  • main()