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

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)[source]
apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.is_auction(event)[source]
apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.is_person(event)[source]
apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.auction_or_bid(event)[source]
class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.JustBids(label=None)[source]

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)[source]
class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.JustAuctions(label=None)[source]

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)[source]
class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.JustPerson(label=None)[source]

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)[source]
class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.AuctionByIdFn(*unused_args, **unused_kwargs)[source]

Bases: apache_beam.transforms.core.DoFn

process(element)[source]
class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.BidByAuctionIdFn(*unused_args, **unused_kwargs)[source]

Bases: apache_beam.transforms.core.DoFn

process(element)[source]
class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.PersonByIdFn(*unused_args, **unused_kwargs)[source]

Bases: apache_beam.transforms.core.DoFn

process(element)[source]
class apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util.AuctionBySellerFn(*unused_args, **unused_kwargs)[source]

Bases: apache_beam.transforms.core.DoFn

process(element)[source]