You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lo...@apache.org on 2021/08/12 16:30:39 UTC

[beam] branch master updated (55f42a5 -> a440401)

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

lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 55f42a5  [GoSDK Infra] Limit simultaneous tests binaries to 3. (#15321)
     add a440401  [BEAM-6374] Emit PCollection metrics from GoSDK (#15289)

No new revisions were added by this update.

Summary of changes:
 sdks/go/pkg/beam/core/metrics/store.go             |  22 +++
 sdks/go/pkg/beam/core/runtime/exec/datasink.go     |  15 +-
 sdks/go/pkg/beam/core/runtime/exec/datasource.go   |  79 ++++++++---
 .../pkg/beam/core/runtime/exec/datasource_test.go  |  39 +++--
 sdks/go/pkg/beam/core/runtime/exec/pcollection.go  | 158 +++++++++++++++++++++
 .../pkg/beam/core/runtime/exec/pcollection_test.go | 154 ++++++++++++++++++++
 sdks/go/pkg/beam/core/runtime/exec/plan.go         |  75 +++++-----
 sdks/go/pkg/beam/core/runtime/exec/translate.go    |  38 +++--
 sdks/go/pkg/beam/core/runtime/harness/harness.go   |  29 ++--
 .../go/pkg/beam/core/runtime/harness/monitoring.go |  78 ++++++----
 sdks/go/pkg/beam/runners/direct/direct.go          |   3 +-
 11 files changed, 553 insertions(+), 137 deletions(-)
 create mode 100644 sdks/go/pkg/beam/core/runtime/exec/pcollection.go
 create mode 100644 sdks/go/pkg/beam/core/runtime/exec/pcollection_test.go