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

Bases: FastCoder

to_type_hint()

is_deterministic()

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

Bases: object

Author of an auction or a bid.

CODER = PersonCoder

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.AuctionCoder

Bases: FastCoder

to_type_hint()

is_deterministic()

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)

Bases: object

Item for auction.

CODER = AuctionCoder

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.BidCoder

Bases: FastCoder

to_type_hint()

is_deterministic()

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.Bid(auction, bidder, price, date_time, extra=None)

Bases: object

A bid for an item for auction.

CODER = BidCoder

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.AuctionCoderImpl

Bases: StreamCoderImpl

encode_to_stream(value, stream, nested)

decode_from_stream(stream, nested)

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.BidCoderImpl

Bases: StreamCoderImpl

encode_to_stream(value, stream, nested)

decode_from_stream(stream, nested)

class apache_beam.testing.benchmarks.nexmark.models.nexmark_model.PersonCoderImpl

Bases: StreamCoderImpl

encode_to_stream(value, stream, nested)

decode_from_stream(stream, nested)