You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2020/08/14 01:21:04 UTC
[beam] branch beam-10702 updated (8e57e98 -> c5da208)
This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch beam-10702
in repository https://gitbox.apache.org/repos/asf/beam.git.
discard 8e57e98 Adds a Julia Set test on portable local runner
discard 6c4dc26 [BEAM-10702] Do not implicitly decompress artifacts
add 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
add de4464b Update nexmark dashboard links.
add e028256 Merge pull request #12475 from tysonjh/www-nexmark
add 1b985bb [BEAM-10500] Make KeyedTimerDataCoder encode output timestamp (#12535)
add 72a9093 [BEAM-10648] Remove unused BigQuery queryTempDataset value
add a6907c0 Merge pull request #12478 from regadas/bigquery_remove_unused
add 23f3b49 Import WordExtractingDoFn from wordcount_with_metrics
add 70fcd57 Merge pull request #12569 from apache/aaltay-patch-1
add f1e780d [BEAM-10646] Remove SparkPortableExecutionTest.testExecution.
add 1709588 [BEAM-10646] Don't wait for test to time out if pipeline fails.
add 228c621 Merge pull request #12477 from ibzib/BEAM-10646
add 699f872 Extending ApproximateQuantiles functionality to deal with non-uniform weights. (#12420)
add b423fe3 fix logic issue in metric name namespace filtering (#12570)
add 0f04de7 Better error on BQ schema parse (#12549)
add 5ae71f9 [BEAM-10545] HtmlView module
add 213c2c7 Use primitive string[] to replace Array<string> type
add bf85a7a Merge pull request #12460 from [BEAM-10545] HtmlView module
add b37f1f6 [BEAM-10702] Do not implicitly decompress artifacts
add b214d1b Adds a Julia Set test on portable local runner
add c5da208 Address review comments
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (8e57e98)
\
N -- N -- N refs/heads/beam-10702 (c5da208)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../beam/runners/jobsubmission/JobInvocation.java | 2 +-
.../beam/runners/samza/runtime/KeyedTimerData.java | 6 +-
.../runners/samza/runtime/KeyedTimerDataTest.java | 8 +-
.../runners/spark/SparkPortableExecutionTest.java | 96 +-------
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 2 -
sdks/python/apache_beam/dataframe/expressions.py | 11 +-
sdks/python/apache_beam/dataframe/frame_base.py | 5 -
sdks/python/apache_beam/dataframe/frames.py | 136 ++++++++---
sdks/python/apache_beam/dataframe/frames_test.py | 23 +-
sdks/python/apache_beam/dataframe/transforms.py | 22 ++
.../apache_beam/examples/streaming_wordcount.py | 2 +-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 12 +-
sdks/python/apache_beam/metrics/metric.py | 11 +-
.../apache-beam-jupyterlab-sidepanel/.eslintrc.js | 12 +-
.../.prettierrc.json | 3 +-
.../apache-beam-jupyterlab-sidepanel/package.json | 8 +-
.../src/__tests__/common/HtmlView.test.tsx | 111 +++++++++
.../src/__tests__/kernel/KernelModel.test.ts | 21 +-
.../src/common/HtmlView.tsx | 119 +++++++++
.../apache-beam-jupyterlab-sidepanel/tsconfig.json | 1 +
.../apache-beam-jupyterlab-sidepanel/yarn.lock | 146 ++++++++++-
.../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/apache_beam/transforms/stats.py | 266 +++++++++++++++------
sdks/python/apache_beam/transforms/stats_test.py | 62 ++++-
sdks/python/scripts/generate_pydoc.sh | 1 +
sdks/python/test-suites/portable/common.gradle | 2 +-
.../en/documentation/sdks/java/testing/nexmark.md | 24 +-
38 files changed, 1552 insertions(+), 348 deletions(-)
create mode 100644 sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/__tests__/common/HtmlView.test.tsx
create mode 100644 sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/common/HtmlView.tsx
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