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 2020/03/06 01:15:37 UTC
[beam] branch master updated (9a3ba93 -> 7097850)
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 9a3ba93 Merge pull request #10979 from [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK
add 7097850 Revert "[BEAM-6374] Emit PCollection metrics from GoSDK (#10942)" (#11061)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 77 +++--------
.../pkg/beam/core/runtime/exec/datasource_test.go | 39 ++----
sdks/go/pkg/beam/core/runtime/exec/pcollection.go | 153 --------------------
.../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 | 31 +----
sdks/go/pkg/beam/core/runtime/harness/harness.go | 24 +---
.../go/pkg/beam/core/runtime/harness/monitoring.go | 35 ++---
sdks/go/pkg/beam/runners/direct/direct.go | 3 +-
9 files changed, 100 insertions(+), 491 deletions(-)
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/pcollection.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/pcollection_test.go