apache_beam.testing.benchmarks.nexmark package

Subpackages

• apache_beam.testing.benchmarks.nexmark.models package
  • Submodules
    • apache_beam.testing.benchmarks.nexmark.models.auction_bid module
      • AuctionBidCoder
      • AuctionBid
      • AuctionBidCoderImpl
    • apache_beam.testing.benchmarks.nexmark.models.field_name module
      • FieldNames
    • apache_beam.testing.benchmarks.nexmark.models.nexmark_model module
      • PersonCoder
      • Person
      • AuctionCoder
      • Auction
      • BidCoder
      • Bid
      • AuctionCoderImpl
      • BidCoderImpl
      • PersonCoderImpl
• apache_beam.testing.benchmarks.nexmark.queries package
  • Submodules
    • apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util module
      • ResultNames
      • is_bid()
      • is_auction()
      • is_person()
      • auction_or_bid()
      • JustBids
      • JustAuctions
      • JustPerson
      • AuctionByIdFn
      • BidByAuctionIdFn
      • PersonByIdFn
      • AuctionBySellerFn
    • apache_beam.testing.benchmarks.nexmark.queries.query0 module
      • RoundTripFn
      • load()
    • apache_beam.testing.benchmarks.nexmark.queries.query1 module
      • load()
    • apache_beam.testing.benchmarks.nexmark.queries.query10 module
      • OutputFile
      • open_writable_gcs_file()
      • output_file_for()
      • index_path_for()
      • load()
      • ShardEventsDoFn
      • WriteEventDoFn
      • WriteIndexDoFn
    • apache_beam.testing.benchmarks.nexmark.queries.query11 module
      • load()
    • apache_beam.testing.benchmarks.nexmark.queries.query12 module
      • load()
    • apache_beam.testing.benchmarks.nexmark.queries.query2 module
      • load()
    • apache_beam.testing.benchmarks.nexmark.queries.query3 module
      • load()
      • JoinFn
    • apache_beam.testing.benchmarks.nexmark.queries.query4 module
      • load()
      • ProjectToCategoryPriceFn
    • apache_beam.testing.benchmarks.nexmark.queries.query5 module
      • load()
      • MostBidCombineFn
    • apache_beam.testing.benchmarks.nexmark.queries.query6 module
      • load()
      • MovingMeanSellingPriceFn
    • apache_beam.testing.benchmarks.nexmark.queries.query7 module
      • load()
      • SelectMaxBidFn
    • apache_beam.testing.benchmarks.nexmark.queries.query8 module
      • load()
      • JoinPersonAuctionFn
    • apache_beam.testing.benchmarks.nexmark.queries.query9 module
      • load()
    • apache_beam.testing.benchmarks.nexmark.queries.winning_bids module
      • AuctionOrBidWindow
      • AuctionOrBidWindowCoder
      • AuctionOrBidWindowCoderImpl
      • AuctionOrBidWindowFn
      • JoinAuctionBidFn
      • WinningBids

Submodules

• apache_beam.testing.benchmarks.nexmark.monitor module
  • Monitor
  • MonitorDoFn
    • MonitorDoFn.start_bundle()
    • MonitorDoFn.process()
    • MonitorDoFn.finish_bundle()
  • MonitorSuffix
    • MonitorSuffix.ELEMENT_COUNTER
    • MonitorSuffix.EVENT_TIMESTAMP
    • MonitorSuffix.EVENT_TIME
• apache_beam.testing.benchmarks.nexmark.nexmark_launcher module
  • NexmarkLauncher
    • NexmarkLauncher.DONE_DELAY
    • NexmarkLauncher.PERF_DELAY
    • NexmarkLauncher.TERMINATE_DELAY
    • NexmarkLauncher.WARNING_DELAY
    • NexmarkLauncher.parse_args()
    • NexmarkLauncher.generate_events()
    • NexmarkLauncher.read_from_file()
    • NexmarkLauncher.read_from_pubsub()
    • NexmarkLauncher.run_query()
    • NexmarkLauncher.monitor()
    • NexmarkLauncher.log_performance()
    • NexmarkLauncher.publish_performance_influxdb()
    • NexmarkLauncher.get_performance()
    • NexmarkLauncher.cleanup()
    • NexmarkLauncher.run()
• apache_beam.testing.benchmarks.nexmark.nexmark_perf module
  • NexmarkPerf
    • NexmarkPerf.has_progress()
• apache_beam.testing.benchmarks.nexmark.nexmark_util module
  • Command
    • Command.run()
  • setup_coder()
  • ParseEventFn
    • ParseEventFn.process()
  • ParseJsonEventFn
    • ParseJsonEventFn.process()
  • CountAndLog
    • CountAndLog.expand()
  • log_count_info()
  • display()
  • model_to_json()
  • construct_json_dict()
  • unnest_to_json()
  • millis_to_timestamp()
  • get_counter_metric()
  • get_start_time_metric()
  • get_end_time_metric()