You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2020/04/08 19:51:14 UTC
[beam] branch master updated (76d7732 -> ba6feec)
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 76d7732 Merge pull request #11348 from ibzib/beam-9199-go
add 3f92f32 Update session.go
add f449dca Update stage.go
add 632535c Update server_test.go
add a4dcf29 Update materialize.go
add ca70ab8 Update materialize_test.go
add 4a378e9 Update stage_test.go
add b6e0584 Update artifact.go
add 209508c Update provision.go
add de68243 Update retrieval.go
add cf19153 Update staging.go
add 483a9c8 Update translate.go
add 11f086a Update datamgr.go
add 3c77761 Update datamgr_test.go
add 1894be7 Update logging.go
add 1378b31 Update logging_test.go
add e229c74 Update monitoring.go
add d9772ee Update session.go
add e1a2730 Update statemgr.go
add ca30a64 Update statemgr_test.go
add 1f0eb7c Update replace.go
add 46afdfd Update replace_test.go
add 68e369c Update provision.go
add c3b3c77 Update execute.go
add 532ea91 Update job.go
add a4d5648 Update translate.go
add 84ebc24 Update translate.go
add 54014d7 Update job.go
add eab9a0f Update materialize.go
add 2548664 Update translate.go
add 9da745e Update session.go
add ecb852b Update materialize_test.go
add ba6feec Merge pull request #11343 from apache/lostluck-protosuffix
No new revisions were added by this update.
Summary of changes:
sdks/go/cmd/beamctl/cmd/artifact.go | 8 +-
sdks/go/cmd/beamctl/cmd/provision.go | 6 +-
sdks/go/pkg/beam/artifact/gcsproxy/retrieval.go | 20 +-
sdks/go/pkg/beam/artifact/gcsproxy/staging.go | 20 +-
sdks/go/pkg/beam/artifact/materialize.go | 58 +++---
sdks/go/pkg/beam/artifact/materialize_test.go | 58 +++---
sdks/go/pkg/beam/artifact/server_test.go | 26 +--
sdks/go/pkg/beam/artifact/stage.go | 32 ++--
sdks/go/pkg/beam/artifact/stage_test.go | 12 +-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 16 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 204 ++++++++++-----------
sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 20 +-
.../pkg/beam/core/runtime/harness/datamgr_test.go | 12 +-
sdks/go/pkg/beam/core/runtime/harness/logging.go | 30 +--
.../pkg/beam/core/runtime/harness/logging_test.go | 6 +-
.../go/pkg/beam/core/runtime/harness/monitoring.go | 26 +--
sdks/go/pkg/beam/core/runtime/harness/session.go | 12 +-
sdks/go/pkg/beam/core/runtime/harness/statemgr.go | 46 ++---
.../pkg/beam/core/runtime/harness/statemgr_test.go | 48 ++---
sdks/go/pkg/beam/core/runtime/pipelinex/replace.go | 28 +--
.../beam/core/runtime/pipelinex/replace_test.go | 22 +--
sdks/go/pkg/beam/provision/provision.go | 20 +-
.../pkg/beam/runners/dataflow/dataflowlib/job.go | 4 +-
.../beam/runners/dataflow/dataflowlib/translate.go | 26 +--
sdks/go/pkg/beam/runners/session/session.go | 30 +--
.../beam/runners/universal/runnerlib/execute.go | 4 +-
.../go/pkg/beam/runners/universal/runnerlib/job.go | 4 +-
27 files changed, 401 insertions(+), 397 deletions(-)