This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 198a583 [BEAM-9547] Lift associative aggregations. (#12469)
add a098130 Merge pull request #12427 from [BEAM-2855] nexmark python
suite implement queries 0, 1, 2 and 9
No new revisions were added by this update.
Summary of changes:
.../benchmarks/nexmark/models/auction_bid.py | 57 ++++++
.../benchmarks/nexmark/models/auction_price.py | 56 ++++++
.../benchmarks/nexmark/models/field_name.py} | 27 ++-
.../benchmarks/nexmark/models/nexmark_model.py | 153 +++++++++++++---
.../testing/benchmarks/nexmark/nexmark_launcher.py | 24 ++-
.../testing/benchmarks/nexmark/nexmark_util.py | 130 +++++++++++++-
.../queries/{query2.py => nexmark_query_util.py} | 59 +++---
.../testing/benchmarks/nexmark/queries/query0.py | 15 +-
.../testing/benchmarks/nexmark/queries/query1.py | 21 ++-
.../testing/benchmarks/nexmark/queries/query2.py | 29 ++-
.../benchmarks/nexmark/queries/query9.py} | 19 +-
.../benchmarks/nexmark/queries/winning_bids.py | 198 +++++++++++++++++++++
sdks/python/scripts/generate_pydoc.sh | 1 +
13 files changed, 694 insertions(+), 95 deletions(-)
create mode 100644
sdks/python/apache_beam/testing/benchmarks/nexmark/models/auction_bid.py
create mode 100644
sdks/python/apache_beam/testing/benchmarks/nexmark/models/auction_price.py
copy sdks/python/apache_beam/{runners/dataflow/__init__.py =>
testing/benchmarks/nexmark/models/field_name.py} (62%)
copy sdks/python/apache_beam/testing/benchmarks/nexmark/queries/{query2.py =>
nexmark_query_util.py} (52%)
copy sdks/python/apache_beam/{runners/dataflow/__init__.py =>
testing/benchmarks/nexmark/queries/query9.py} (65%)
create mode 100644
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/winning_bids.py
