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.PersonCoder[source]

Bases: apache_beam.coders.coders.FastCoder

to_type_hint()[source]
is_deterministic()[source]
class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.Person(id, name, email, credit_card, city, state, date_time, extra=None)[source]

Bases: object

Author of an auction or a bid.

CODER = PersonCoder
class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.AuctionCoder[source]

Bases: apache_beam.coders.coders.FastCoder

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

Bases: object

Item for auction.

CODER = AuctionCoder
class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.BidCoder[source]

Bases: apache_beam.coders.coders.FastCoder

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

Bases: object

A bid for an item for auction.

CODER = BidCoder
class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.AuctionCoderImpl[source]

Bases: apache_beam.coders.coder_impl.StreamCoderImpl

encode_to_stream(value, stream, nested)[source]
decode_from_stream(stream, nested)[source]
class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.BidCoderImpl[source]

Bases: apache_beam.coders.coder_impl.StreamCoderImpl

encode_to_stream(value, stream, nested)[source]
decode_from_stream(stream, nested)[source]
class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.PersonCoderImpl[source]

Bases: apache_beam.coders.coder_impl.StreamCoderImpl

encode_to_stream(value, stream, nested)[source]
decode_from_stream(stream, nested)[source]