You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/10/06 15:53:58 UTC
[3/3] beam git commit: This closes #3928
This closes #3928
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/63b54a5b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/63b54a5b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/63b54a5b
Branch: refs/heads/master
Commit: 63b54a5b0d64e5eb427fb249d5612d60d34e1741
Parents: ed00299 c18f15c
Author: Thomas Groh <tg...@google.com>
Authored: Fri Oct 6 08:48:19 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Fri Oct 6 08:48:19 2017 -0700
----------------------------------------------------------------------
pom.xml | 49 ++
runners/gcp/gcemd/Dockerfile | 30 +
runners/gcp/gcemd/main.go | 85 +++
runners/gcp/gcemd/pom.xml | 154 ++++
runners/gcp/gcsproxy/Dockerfile | 30 +
runners/gcp/gcsproxy/main.go | 91 +++
runners/gcp/gcsproxy/pom.xml | 154 ++++
runners/gcp/pom.xml | 38 +
runners/pom.xml | 1 +
.../src/main/proto/beam_provision_api.proto | 8 +-
.../src/main/proto/beam_artifact_api.proto | 10 +
sdks/go/BUILD.md | 63 ++
sdks/go/cmd/beamctl/artifact.go | 98 +++
sdks/go/cmd/beamctl/main.go | 64 ++
sdks/go/descriptor.xml | 29 +
sdks/go/pkg/beam/artifact/gcsproxy/retrieval.go | 155 ++++
sdks/go/pkg/beam/artifact/gcsproxy/staging.go | 200 +++++
sdks/go/pkg/beam/artifact/materialize.go | 240 ++++++
sdks/go/pkg/beam/artifact/materialize_test.go | 238 ++++++
sdks/go/pkg/beam/artifact/server_test.go | 212 ++++++
sdks/go/pkg/beam/artifact/stage.go | 238 ++++++
sdks/go/pkg/beam/artifact/stage_test.go | 98 +++
sdks/go/pkg/beam/model/gen.go | 21 +
.../beam_provision_api.pb.go | 219 ++++++
.../beam_artifact_api.pb.go | 729 +++++++++++++++++++
sdks/go/pkg/beam/provision/provision_test.go | 54 ++
sdks/go/pkg/beam/provision/provison.go | 80 ++
sdks/go/pkg/beam/util/errorx/guarded.go | 47 ++
sdks/go/pkg/beam/util/execx/exec.go | 33 +
sdks/go/pkg/beam/util/gcsx/gcs.go | 88 +++
sdks/go/pkg/beam/util/grpcx/dial.go | 37 +
sdks/go/pkg/beam/util/grpcx/metadata.go | 55 ++
sdks/go/pom.xml | 163 +++++
sdks/java/container/Dockerfile | 28 +
sdks/java/container/boot.go | 111 +++
sdks/java/container/pom.xml | 184 +++++
sdks/java/harness/pom.xml | 66 ++
sdks/java/pom.xml | 1 +
sdks/pom.xml | 1 +
39 files changed, 4201 insertions(+), 1 deletion(-)
----------------------------------------------------------------------