You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/10/06 03:30:46 UTC
[beam] tag nightly-master updated (b822366 -> bed6bee)

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.


*** WARNING: tag nightly-master was modified! ***

    from b822366  (commit)
      to bed6bee  (commit)
    from b822366  [BEAM-13000] Disable Reshuffle Translation in Samza Portable Mode (#15655)
     add 59ea30a  Switch hintNumWorkers to ValueProvider, switch firstInstant to side input.
     add 3da8de4  Merge pull request #15569 from [BEAM-12949] Fix DatastoreIO template compatibility
     add b833f90  Only stage the single (fat) jar when auto-starting expansion service. (#15638)
     add 476efbb  Disable samza counters (#15659)
     add 7d4afdc  Merge pull request #15614 from [BEAM-12953] [Playground] Create protobuf file for front-back communication
     add 63211ee  [BEAM-11831] Parially Revert "[BEAM-11805] Replace user-agent for spanner (#13990)" (#15591)
     add 8c0601c  [BEAM-10708] Enable submit beam_sql built jobs to Dataflow
     add bed6bee  Merge pull request #15647 from KevinGG/beam_sql_on_df

No new revisions were added by this update.

Summary of changes:
 playground/backend/go.mod                          |   7 +-
 playground/playground/v1/playground.proto          |  95 ++++++
 sdks/go/test/integration/integration.go            |   2 +
 .../sdk/expansion/service/ExpansionService.java    |  24 +-
 .../beam/sdk/io/gcp/datastore/DatastoreV1.java     |  65 +++-
 .../sdk/io/gcp/datastore/RampupThrottlingFn.java   |  25 +-
 .../beam/sdk/io/gcp/spanner/SpannerAccessor.java   | 101 +-----
 .../io/gcp/datastore/RampupThrottlingFnTest.java   |  14 +-
 .../runners/interactive/interactive_environment.py |  17 +
 .../interactive/interactive_environment_test.py    |  32 ++
 .../runners/interactive/sql/beam_sql_magics.py     | 187 ++++++++---
 .../interactive/sql/beam_sql_magics_test.py        |  28 +-
 .../runners/interactive/sql/sql_chain.py           | 226 +++++++++++++
 .../runners/interactive/sql/sql_chain_test.py      | 109 +++++++
 .../apache_beam/runners/interactive/sql/utils.py   | 354 +++++++++++++++++++--
 .../runners/interactive/sql/utils_test.py          |  50 ++-
 .../apache_beam/runners/interactive/utils.py       |  22 ++
 .../apache_beam/runners/interactive/utils_test.py  |   8 +
 sdks/python/apache_beam/transforms/external.py     |   2 +-
 sdks/python/setup.py                               |   1 +
 20 files changed, 1141 insertions(+), 228 deletions(-)
 create mode 100644 playground/playground/v1/playground.proto
 create mode 100644 sdks/python/apache_beam/runners/interactive/sql/sql_chain.py
 create mode 100644 sdks/python/apache_beam/runners/interactive/sql/sql_chain_test.py