apache_beam.testing.benchmarks.nexmark.queries package

Submodules

• apache_beam.testing.benchmarks.nexmark.queries.nexmark_query_util module
  • ResultNames
    • ResultNames.SELLER
    • ResultNames.PRICE
    • ResultNames.NAME
    • ResultNames.CITY
    • ResultNames.STATE
    • ResultNames.AUCTION_ID
    • ResultNames.ID
    • ResultNames.RESERVE
    • ResultNames.CATEGORY
    • ResultNames.IS_LAST
    • ResultNames.BIDDER_ID
    • ResultNames.BID_COUNT
    • ResultNames.NUM
  • is_bid()
  • is_auction()
  • is_person()
  • auction_or_bid()
  • JustBids
    • JustBids.expand()
  • JustAuctions
    • JustAuctions.expand()
  • JustPerson
    • JustPerson.expand()
  • AuctionByIdFn
    • AuctionByIdFn.process()
  • BidByAuctionIdFn
    • BidByAuctionIdFn.process()
  • PersonByIdFn
    • PersonByIdFn.process()
  • AuctionBySellerFn
    • AuctionBySellerFn.process()
• apache_beam.testing.benchmarks.nexmark.queries.query0 module
  • RoundTripFn
    • RoundTripFn.process()
  • load()
• apache_beam.testing.benchmarks.nexmark.queries.query1 module
  • load()
• apache_beam.testing.benchmarks.nexmark.queries.query10 module
  • OutputFile
  • open_writable_gcs_file()
  • output_file_for()
  • index_path_for()
  • load()
  • ShardEventsDoFn
    • ShardEventsDoFn.process()
  • WriteEventDoFn
    • WriteEventDoFn.process()
  • WriteIndexDoFn
    • WriteIndexDoFn.process()
• apache_beam.testing.benchmarks.nexmark.queries.query11 module
  • load()
• apache_beam.testing.benchmarks.nexmark.queries.query12 module
  • load()
• apache_beam.testing.benchmarks.nexmark.queries.query2 module
  • load()
• apache_beam.testing.benchmarks.nexmark.queries.query3 module
  • load()
  • JoinFn
    • JoinFn.AUCTIONS
    • JoinFn.PERSON
    • JoinFn.PERSON_EXPIRING
    • JoinFn.auction_spec
    • JoinFn.person_spec
    • JoinFn.person_timer_spec
    • JoinFn.process()
    • JoinFn.expiry()
• apache_beam.testing.benchmarks.nexmark.queries.query4 module
  • load()
  • ProjectToCategoryPriceFn
    • ProjectToCategoryPriceFn.process()
• apache_beam.testing.benchmarks.nexmark.queries.query5 module
  • load()
  • MostBidCombineFn
    • MostBidCombineFn.create_accumulator()
    • MostBidCombineFn.add_input()
    • MostBidCombineFn.merge_accumulators()
    • MostBidCombineFn.extract_output()
• apache_beam.testing.benchmarks.nexmark.queries.query6 module
  • load()
  • MovingMeanSellingPriceFn
    • MovingMeanSellingPriceFn.create_accumulator()
    • MovingMeanSellingPriceFn.add_input()
    • MovingMeanSellingPriceFn.merge_accumulators()
    • MovingMeanSellingPriceFn.extract_output()
• apache_beam.testing.benchmarks.nexmark.queries.query7 module
  • load()
  • SelectMaxBidFn
    • SelectMaxBidFn.process()
• apache_beam.testing.benchmarks.nexmark.queries.query8 module
  • load()
  • JoinPersonAuctionFn
    • JoinPersonAuctionFn.process()
• apache_beam.testing.benchmarks.nexmark.queries.query9 module
  • load()
• apache_beam.testing.benchmarks.nexmark.queries.winning_bids module
  • AuctionOrBidWindow
    • AuctionOrBidWindow.for_auction()
    • AuctionOrBidWindow.for_bid()
    • AuctionOrBidWindow.is_auction_window_fn()
  • AuctionOrBidWindowCoder
    • AuctionOrBidWindowCoder.is_deterministic()
  • AuctionOrBidWindowCoderImpl
    • AuctionOrBidWindowCoderImpl.encode_to_stream()
    • AuctionOrBidWindowCoderImpl.decode_from_stream()
  • AuctionOrBidWindowFn
    • AuctionOrBidWindowFn.assign()
    • AuctionOrBidWindowFn.merge()
    • AuctionOrBidWindowFn.get_window_coder()
    • AuctionOrBidWindowFn.get_transformed_output_time()
  • JoinAuctionBidFn
    • JoinAuctionBidFn.higher_bid()
    • JoinAuctionBidFn.process()
  • WinningBids
    • WinningBids.expand()