apache_beam.testing.benchmarks.nexmark.models.nexmark_model module

Nexmark model.

The nexmark suite is a series of queries (streaming pipelines) performed on a simulation of auction events. The model includes the three roles that generate events:

  • The person who starts and auction or makes a bid (Person).
  • The auction item (Auction).
  • The bid on an item for auction (Bid).
class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.Person(id, name, email, credit_card, city, state, timestamp, extra=None)[source]

Bases: object

Author of an auction or a bid.

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.Auction(id, item_name, description, initial_bid, reserve_price, timestamp, expires, seller, category, extra=None)[source]

Bases: object

Item for auction.

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.Bid(auction, bidder, price, timestamp, extra=None)[source]

Bases: object

A bid for an item for auction.