apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util module

Utilities for working with NEXmark data stream.

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.ResultNames

Bases: object

SELLER = 'seller'

PRICE = 'price'

NAME = 'name'

CITY = 'city'

STATE = 'state'

AUCTION_ID = 'auction_id'

ID = 'id'

RESERVE = 'reserve'

CATEGORY = 'category'

IS_LAST = 'is_last'

BIDDER_ID = 'bidder_id'

BID_COUNT = 'bid_count'

NUM = 'num'

apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.is_bid(event)

apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.is_auction(event)

apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.is_person(event)

apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.auction_or_bid(event)

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.JustBids(label=None)

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.JustAuctions(label=None)

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.JustPerson(label=None)

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.AuctionByIdFn(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element)

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.BidByAuctionIdFn(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element)

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.PersonByIdFn(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element)

class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.AuctionBySellerFn(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element)