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