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 2020/12/11 02:56:24 UTC

[beam] tag nightly-master updated (d009fe9 -> 0424485)

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 d009fe9  (commit)
      to 0424485  (commit)
    from d009fe9  Merge pull request #13503: [BEAM-11415] In-progress Go ValidatesRunner framework.
     add cd2c312  [BEAM-11435] Reuse already set timers.
     add 744637d  Merge pull request #13522: [BEAM-11435] Reuse already set timers.
     add 190261a  Log exception caught during UnboundedSource#split
     add 76723d8  Merge pull request #13520: Log exception caught during UnboundedSource#split
     add 01a63c7  [BEAM-10556][BEAM-10402] Cleanup DoFnOperatorTest warnings.
     add 33b3ac4  Merge pull request #13521: [BEAM-10556][BEAM-10402] Cleanup DoFnOperatorTest warnings
     add 2356367  [BEAM-11425] Metrics extraction via Monitoring API (#13505)
     add aa1498c  [BEAM-11374] Add key regex filter to Bigtable for BeamSQL
     add d4e9171  Merge pull request #13495 from piotr-szuberski/bigtable-filters
     add 5e1c544  Add SDF capability_matrix.
     add 1481977  Merge pull request #13368 from [BEAM-10480] Add SDF capability_matrix.
     add 379d796  Add a small announcement for Splittable DoFn.
     add c4af7f9  Merge pull request #13456 from [BEAM-10480] Add a small announcement for Splittable DoFn.
     add 44fc9fe  [BEAM-10402] Supress nullness and keyfor DoFnOperatorTest warnings.
     add 0424485  Merge pull request #13525: [BEAM-10402] Supress nullness and keyfor DoFnOperatorTest warnings.

No new revisions were added by this update.

Summary of changes:
 .../wrappers/streaming/DoFnOperator.java           |  31 +-
 .../wrappers/streaming/DoFnOperatorTest.java       | 146 ++---
 sdks/go/pkg/beam/core/metrics/metrics.go           |  39 ++
 sdks/go/pkg/beam/core/runtime/metricsx/metricsx.go |  38 +-
 sdks/go/pkg/beam/pipeline.go                       |   1 +
 sdks/go/pkg/beam/runners/dataflow/dataflow.go      |   3 +-
 .../beam/runners/dataflow/dataflowlib/execute.go   |  57 +-
 .../pkg/beam/runners/dataflow/dataflowlib/job.go   |   6 +
 .../beam/runners/dataflow/dataflowlib/metrics.go   | 124 ++++
 .../runners/dataflow/dataflowlib/metrics_test.go   | 133 ++++
 .../beam/runners/universal/runnerlib/execute.go    |   8 +-
 .../src/main/java/org/apache/beam/sdk/io/Read.java |   1 +
 .../sql/meta/provider/bigtable/BigtableFilter.java | 136 ++++
 .../sql/meta/provider/bigtable/BigtableTable.java  |  47 +-
 .../BigtableFilterTest.java}                       |  45 +-
 .../provider/bigtable/BigtableTableFlatTest.java   |  40 +-
 .../apache/beam/sdk/io/gcp/bigtable/RowUtils.java  |  10 +
 .../beam/sdk/io/gcp/testing/BigtableTestUtils.java |   5 +-
 .../en/blog/splittable-do-fn-is-available.md       |  91 +++
 .../dsls/sql/extensions/create-external-table.md   |   4 +
 website/www/site/data/capability_matrix.yaml       | 714 +++++++++++++++++++--
 .../www/site/data/capability_matrix_snapshot.yaml  | 195 ++++++
 22 files changed, 1634 insertions(+), 240 deletions(-)
 create mode 100644 sdks/go/pkg/beam/runners/dataflow/dataflowlib/metrics.go
 create mode 100644 sdks/go/pkg/beam/runners/dataflow/dataflowlib/metrics_test.go
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableFilter.java
 copy sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/{mongodb/MongoDbFilterTest.java => bigtable/BigtableFilterTest.java} (70%)
 create mode 100644 website/www/site/content/en/blog/splittable-do-fn-is-available.md