You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2021/08/18 01:22:37 UTC
[beam] 01/01: Merge pull request #15323: [BEAM-5379] Go SDK modules
support.
This is an automated email from the ASF dual-hosted git repository.
danoliveira pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 410ad7699621e28433d81809f6b9c42fe7bd6a60
Merge: 216f0d9 c749613
Author: Daniel Oliveira <da...@gmail.com>
AuthorDate: Tue Aug 17 18:21:40 2021 -0700
Merge pull request #15323: [BEAM-5379] Go SDK modules support.
[BEAM-5379] Go SDK modules support.
build.gradle.kts | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../fn-execution/src/main/proto/beam_fn_api.proto | 2 +-
.../src/main/proto/beam_provision_api.proto | 2 +-
.../src/main/proto/beam_artifact_api.proto | 2 +-
.../src/main/proto/beam_expansion_api.proto | 2 +-
.../src/main/proto/beam_job_api.proto | 2 +-
.../pipeline/src/main/proto/beam_runner_api.proto | 2 +-
model/pipeline/src/main/proto/endpoints.proto | 2 +-
.../src/main/proto/external_transforms.proto | 2 +-
model/pipeline/src/main/proto/metrics.proto | 2 +-
model/pipeline/src/main/proto/schema.proto | 2 +-
.../src/main/proto/standard_window_fns.proto | 2 +-
sdks/go.mod | 52 +
sdks/go.sum | 648 ++++++++
sdks/go/BUILD.md | 2 +-
sdks/go/build.gradle | 11 +-
sdks/go/cmd/beamctl/cmd/artifact.go | 4 +-
sdks/go/cmd/beamctl/cmd/provision.go | 2 +-
sdks/go/cmd/beamctl/cmd/root.go | 2 +-
sdks/go/cmd/beamctl/main.go | 2 +-
sdks/go/cmd/specialize/main.go | 2 +-
sdks/go/cmd/starcgen/starcgen.go | 6 +-
sdks/go/cmd/starcgen/starcgen_test.go | 2 +-
sdks/go/cmd/symtab/main.go | 6 +-
sdks/go/container/boot.go | 8 +-
sdks/go/container/build.gradle | 14 +-
sdks/go/examples/build.gradle | 44 +-
.../examples/complete/autocomplete/autocomplete.go | 12 +-
sdks/go/examples/contains/contains.go | 12 +-
sdks/go/examples/cookbook/combine/combine.go | 10 +-
sdks/go/examples/cookbook/filter/filter.go | 12 +-
sdks/go/examples/cookbook/join/join.go | 12 +-
sdks/go/examples/cookbook/max/max.go | 12 +-
sdks/go/examples/cookbook/tornadoes/tornadoes.go | 12 +-
.../debugging_wordcount/debugging_wordcount.go | 12 +-
sdks/go/examples/forest/forest.go | 8 +-
sdks/go/examples/grades/grades.go | 12 +-
sdks/go/examples/kafka/taxi.go | 12 +-
.../minimal_wordcount/minimal_wordcount.go | 12 +-
sdks/go/examples/multiout/multiout.go | 8 +-
sdks/go/examples/pingpong/pingpong.go | 8 +-
sdks/go/examples/readavro/readavro.go | 8 +-
sdks/go/examples/snippets/01_03intro.go | 4 +-
sdks/go/examples/snippets/04transforms.go | 4 +-
sdks/go/examples/snippets/04transforms_test.go | 6 +-
sdks/go/examples/streaming_wordcap/wordcap.go | 16 +-
sdks/go/examples/stringsplit/stringsplit.go | 10 +-
.../windowed_wordcount/windowed_wordcount.go | 14 +-
sdks/go/examples/wordcount/wordcount.go | 8 +-
sdks/go/examples/xlang/cogroup_by/cogroup_by.go | 14 +-
sdks/go/examples/xlang/combine/combine.go | 14 +-
.../xlang/combine_globally/combine_globally.go | 14 +-
sdks/go/examples/xlang/flatten/flatten.go | 14 +-
sdks/go/examples/xlang/group_by/group_by.go | 14 +-
sdks/go/examples/xlang/multi_input_output/multi.go | 14 +-
sdks/go/examples/xlang/partition/partition.go | 14 +-
sdks/go/examples/xlang/transforms.go | 8 +-
sdks/go/examples/xlang/wordcount/wordcount.go | 14 +-
sdks/go/examples/yatzy/yatzy.go | 6 +-
sdks/go/gogradle.lock | 723 ---------
sdks/go/pkg/beam/artifact/gcsproxy/retrieval.go | 6 +-
sdks/go/pkg/beam/artifact/gcsproxy/staging.go | 6 +-
sdks/go/pkg/beam/artifact/materialize.go | 10 +-
sdks/go/pkg/beam/artifact/materialize_test.go | 8 +-
sdks/go/pkg/beam/artifact/server_test.go | 9 +-
sdks/go/pkg/beam/artifact/stage.go | 6 +-
sdks/go/pkg/beam/artifact/stage_test.go | 4 +-
sdks/go/pkg/beam/beam.shims.go | 10 +-
sdks/go/pkg/beam/coder.go | 14 +-
sdks/go/pkg/beam/coder_test.go | 2 +-
sdks/go/pkg/beam/combine.go | 6 +-
sdks/go/pkg/beam/combine_test.go | 2 +-
sdks/go/pkg/beam/core/funcx/fn.go | 8 +-
sdks/go/pkg/beam/core/funcx/fn_test.go | 6 +-
sdks/go/pkg/beam/core/funcx/output.go | 2 +-
sdks/go/pkg/beam/core/funcx/output_test.go | 2 +-
sdks/go/pkg/beam/core/funcx/sideinput.go | 4 +-
sdks/go/pkg/beam/core/funcx/sideinput_test.go | 2 +-
sdks/go/pkg/beam/core/funcx/signature.go | 6 +-
sdks/go/pkg/beam/core/funcx/signature_test.go | 4 +-
sdks/go/pkg/beam/core/graph/bind.go | 6 +-
sdks/go/pkg/beam/core/graph/bind_test.go | 8 +-
sdks/go/pkg/beam/core/graph/coder/bool.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/bool_test.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/bytes.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/coder.go | 8 +-
sdks/go/pkg/beam/core/graph/coder/coder_test.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/double.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/int.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/iterable.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/map_test.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/registry.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/registry_test.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/row.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/row_decoder.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/row_encoder.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/row_test.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/stringutf8.go | 2 +-
.../pkg/beam/core/graph/coder/testutil/testutil.go | 2 +-
.../core/graph/coder/testutil/testutil_test.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/time.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/time_test.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/varint.go | 4 +-
sdks/go/pkg/beam/core/graph/edge.go | 12 +-
sdks/go/pkg/beam/core/graph/fn.go | 10 +-
sdks/go/pkg/beam/core/graph/fn_test.go | 2 +-
sdks/go/pkg/beam/core/graph/graph.go | 6 +-
sdks/go/pkg/beam/core/graph/node.go | 6 +-
sdks/go/pkg/beam/core/graph/window/fn.go | 2 +-
sdks/go/pkg/beam/core/graph/window/windows.go | 4 +-
sdks/go/pkg/beam/core/graph/xlang.go | 2 +-
sdks/go/pkg/beam/core/metrics/dumper.go | 2 +-
sdks/go/pkg/beam/core/metrics/metrics.go | 2 +-
.../pkg/beam/core/runtime/coderx/coderx.shims.go | 8 +-
sdks/go/pkg/beam/core/runtime/coderx/doc.go | 2 +-
sdks/go/pkg/beam/core/runtime/coderx/float.go | 8 +-
sdks/go/pkg/beam/core/runtime/coderx/float_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/coderx/int.go | 4 +-
sdks/go/pkg/beam/core/runtime/coderx/string.go | 6 +-
sdks/go/pkg/beam/core/runtime/coderx/varint.go | 6 +-
.../go/pkg/beam/core/runtime/coderx/varint_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/coder.go | 12 +-
sdks/go/pkg/beam/core/runtime/exec/coder_test.go | 8 +-
sdks/go/pkg/beam/core/runtime/exec/cogbk.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/combine.go | 14 +-
sdks/go/pkg/beam/core/runtime/exec/combine_test.go | 14 +-
sdks/go/pkg/beam/core/runtime/exec/datasink.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 6 +-
.../pkg/beam/core/runtime/exec/datasource_test.go | 8 +-
sdks/go/pkg/beam/core/runtime/exec/decode.go | 2 +-
.../go/pkg/beam/core/runtime/exec/dynsplit_test.go | 16 +-
sdks/go/pkg/beam/core/runtime/exec/emit.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/encode.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/fn.go | 14 +-
sdks/go/pkg/beam/core/runtime/exec/fn_arity.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/fn_arity.tmpl | 4 +-
sdks/go/pkg/beam/core/runtime/exec/fn_test.go | 10 +-
sdks/go/pkg/beam/core/runtime/exec/fullvalue.go | 4 +-
.../pkg/beam/core/runtime/exec/fullvalue_test.go | 8 +-
sdks/go/pkg/beam/core/runtime/exec/hash.go | 6 +-
sdks/go/pkg/beam/core/runtime/exec/hash_test.go | 10 +-
sdks/go/pkg/beam/core/runtime/exec/input.go | 6 +-
.../beam/core/runtime/exec/optimized/callers.go | 4 +-
.../beam/core/runtime/exec/optimized/callers.tmpl | 2 +-
.../beam/core/runtime/exec/optimized/decoders.go | 4 +-
.../beam/core/runtime/exec/optimized/decoders.tmpl | 2 +-
.../beam/core/runtime/exec/optimized/emitters.go | 4 +-
.../beam/core/runtime/exec/optimized/emitters.tmpl | 4 +-
.../beam/core/runtime/exec/optimized/encoders.go | 4 +-
.../beam/core/runtime/exec/optimized/encoders.tmpl | 2 +-
.../pkg/beam/core/runtime/exec/optimized/inputs.go | 4 +-
.../beam/core/runtime/exec/optimized/inputs.tmpl | 4 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 16 +-
sdks/go/pkg/beam/core/runtime/exec/pardo_test.go | 10 +-
sdks/go/pkg/beam/core/runtime/exec/pcollection.go | 2 +-
.../pkg/beam/core/runtime/exec/pcollection_test.go | 6 +-
sdks/go/pkg/beam/core/runtime/exec/plan.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/reshuffle.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/sdf.go | 8 +-
sdks/go/pkg/beam/core/runtime/exec/sdf_invokers.go | 8 +-
.../beam/core/runtime/exec/sdf_invokers_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/sdf_test.go | 10 +-
sdks/go/pkg/beam/core/runtime/exec/sideinput.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 22 +-
sdks/go/pkg/beam/core/runtime/exec/unit_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/util.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/util_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/window.go | 6 +-
sdks/go/pkg/beam/core/runtime/exec/window_test.go | 6 +-
sdks/go/pkg/beam/core/runtime/genx/genx.go | 6 +-
sdks/go/pkg/beam/core/runtime/genx/genx_test.go | 6 +-
sdks/go/pkg/beam/core/runtime/graphx/coder.go | 14 +-
sdks/go/pkg/beam/core/runtime/graphx/coder_test.go | 12 +-
sdks/go/pkg/beam/core/runtime/graphx/cogbk.go | 12 +-
sdks/go/pkg/beam/core/runtime/graphx/dataflow.go | 14 +-
.../core/runtime/graphx/schema/logicaltypes.go | 4 +-
.../pkg/beam/core/runtime/graphx/schema/schema.go | 10 +-
.../beam/core/runtime/graphx/schema/schema_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/graphx/serialize.go | 20 +-
.../pkg/beam/core/runtime/graphx/serialize_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 16 +-
.../pkg/beam/core/runtime/graphx/translate_test.go | 16 +-
sdks/go/pkg/beam/core/runtime/graphx/tree.go | 2 +-
sdks/go/pkg/beam/core/runtime/graphx/user.go | 10 +-
sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto | 2 +-
sdks/go/pkg/beam/core/runtime/graphx/xlang.go | 6 +-
sdks/go/pkg/beam/core/runtime/graphx/xlang_test.go | 10 +-
sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 8 +-
.../pkg/beam/core/runtime/harness/datamgr_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 14 +-
.../pkg/beam/core/runtime/harness/harness_test.go | 6 +-
sdks/go/pkg/beam/core/runtime/harness/init/init.go | 6 +-
sdks/go/pkg/beam/core/runtime/harness/logging.go | 6 +-
.../pkg/beam/core/runtime/harness/logging_test.go | 4 +-
.../go/pkg/beam/core/runtime/harness/monitoring.go | 8 +-
.../beam/core/runtime/harness/monitoring_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/harness/session.go | 10 +-
.../go/pkg/beam/core/runtime/harness/session.proto | 2 +-
.../core/runtime/harness/session/session.pb.go | 2 +-
sdks/go/pkg/beam/core/runtime/harness/statemgr.go | 8 +-
.../pkg/beam/core/runtime/harness/statemgr_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/metricsx/metricsx.go | 6 +-
.../beam/core/runtime/metricsx/metricsx_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/metricsx/urns.go | 4 +-
sdks/go/pkg/beam/core/runtime/pipelinex/clone.go | 4 +-
.../pkg/beam/core/runtime/pipelinex/clone_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/pipelinex/replace.go | 6 +-
.../beam/core/runtime/pipelinex/replace_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/pipelinex/util.go | 2 +-
.../pkg/beam/core/runtime/pipelinex/util_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/symbols.go | 6 +-
sdks/go/pkg/beam/core/runtime/types.go | 2 +-
sdks/go/pkg/beam/core/runtime/types_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/xlangx/expand.go | 12 +-
sdks/go/pkg/beam/core/runtime/xlangx/namespace.go | 4 +-
.../pkg/beam/core/runtime/xlangx/namespace_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/xlangx/payload.go | 8 +-
sdks/go/pkg/beam/core/runtime/xlangx/resolve.go | 12 +-
sdks/go/pkg/beam/core/typex/class.go | 2 +-
sdks/go/pkg/beam/core/typex/class_test.go | 2 +-
sdks/go/pkg/beam/core/typex/fulltype.go | 2 +-
sdks/go/pkg/beam/core/typex/fulltype_test.go | 2 +-
sdks/go/pkg/beam/core/typex/special.go | 2 +-
sdks/go/pkg/beam/core/util/dot/dot.go | 4 +-
sdks/go/pkg/beam/core/util/hooks/hooks.go | 8 +-
sdks/go/pkg/beam/core/util/hooks/hooks_test.go | 2 +-
sdks/go/pkg/beam/core/util/ioutilx/read.go | 2 +-
sdks/go/pkg/beam/core/util/protox/any.go | 2 +-
sdks/go/pkg/beam/core/util/protox/base64.go | 2 +-
sdks/go/pkg/beam/core/util/reflectx/call.go | 2 +-
sdks/go/pkg/beam/core/util/reflectx/structs.go | 2 +-
sdks/go/pkg/beam/core/util/symtab/symtab.go | 2 +-
sdks/go/pkg/beam/core/util/symtab/symtab_test.go | 2 +-
sdks/go/pkg/beam/create.go | 2 +-
sdks/go/pkg/beam/create_test.go | 6 +-
sdks/go/pkg/beam/doc_test.go | 6 +-
sdks/go/pkg/beam/encoding.go | 10 +-
sdks/go/pkg/beam/encoding_test.go | 4 +-
sdks/go/pkg/beam/example_schema_test.go | 4 +-
sdks/go/pkg/beam/external.go | 6 +-
sdks/go/pkg/beam/external_test.go | 8 +-
sdks/go/pkg/beam/flatten.go | 4 +-
sdks/go/pkg/beam/forward.go | 10 +-
sdks/go/pkg/beam/gbk.go | 4 +-
sdks/go/pkg/beam/impulse.go | 2 +-
sdks/go/pkg/beam/io/avroio/avroio.go | 6 +-
sdks/go/pkg/beam/io/bigqueryio/bigquery.go | 6 +-
sdks/go/pkg/beam/io/databaseio/database.go | 6 +-
sdks/go/pkg/beam/io/databaseio/mapper.go | 2 +-
sdks/go/pkg/beam/io/databaseio/util.go | 2 +-
sdks/go/pkg/beam/io/databaseio/writer.go | 4 +-
sdks/go/pkg/beam/io/datastoreio/datastore.go | 8 +-
sdks/go/pkg/beam/io/filesystem/filesystem.go | 2 +-
sdks/go/pkg/beam/io/filesystem/gcs/gcs.go | 8 +-
sdks/go/pkg/beam/io/filesystem/local/local.go | 2 +-
sdks/go/pkg/beam/io/filesystem/memfs/memory.go | 2 +-
.../go/pkg/beam/io/filesystem/memfs/memory_test.go | 2 +-
sdks/go/pkg/beam/io/pubsubio/pubsubio.go | 12 +-
.../beam/io/rtrackers/offsetrange/offsetrange.go | 4 +-
sdks/go/pkg/beam/io/synthetic/source.go | 6 +-
sdks/go/pkg/beam/io/synthetic/step.go | 6 +-
sdks/go/pkg/beam/io/textio/sdf.go | 12 +-
sdks/go/pkg/beam/io/textio/sdf_test.go | 6 +-
sdks/go/pkg/beam/io/textio/textio.go | 6 +-
sdks/go/pkg/beam/io/textio/textio_test.go | 2 +-
sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go | 8 +-
sdks/go/pkg/beam/metrics.go | 2 +-
sdks/go/pkg/beam/metrics_test.go | 4 +-
sdks/go/pkg/beam/model/PROTOBUF.md | 50 +-
.../beam/model/fnexecution_v1/beam_fn_api.pb.go | 745 +---------
.../model/fnexecution_v1/beam_fn_api_grpc.pb.go | 802 ++++++++++
.../model/fnexecution_v1/beam_provision_api.pb.go | 112 +-
.../fnexecution_v1/beam_provision_api_grpc.pb.go | 120 ++
sdks/go/pkg/beam/model/gen.go | 8 +-
.../model/jobmanagement_v1/beam_artifact_api.pb.go | 577 +-------
.../jobmanagement_v1/beam_artifact_api_grpc.pb.go | 637 ++++++++
.../jobmanagement_v1/beam_expansion_api.pb.go | 104 +-
.../jobmanagement_v1/beam_expansion_api_grpc.pb.go | 118 ++
.../beam/model/jobmanagement_v1/beam_job_api.pb.go | 533 +------
.../model/jobmanagement_v1/beam_job_api_grpc.pb.go | 519 +++++++
.../beam/model/pipeline_v1/beam_runner_api.pb.go | 1541 ++++++++++----------
.../model/pipeline_v1/beam_runner_api_grpc.pb.go | 147 ++
sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go | 17 +-
.../model/pipeline_v1/external_transforms.pb.go | 24 +-
sdks/go/pkg/beam/model/pipeline_v1/metrics.pb.go | 51 +-
sdks/go/pkg/beam/model/pipeline_v1/schema.pb.go | 22 +-
.../model/pipeline_v1/standard_window_fns.pb.go | 56 +-
sdks/go/pkg/beam/options/gcpopts/options.go | 2 +-
sdks/go/pkg/beam/options/jobopts/options.go | 4 +-
sdks/go/pkg/beam/pardo.go | 8 +-
sdks/go/pkg/beam/pardo_test.go | 4 +-
sdks/go/pkg/beam/partition.go | 10 +-
sdks/go/pkg/beam/partition_test.go | 6 +-
sdks/go/pkg/beam/pcollection.go | 6 +-
sdks/go/pkg/beam/pipeline.go | 4 +-
sdks/go/pkg/beam/provision/provision.go | 6 +-
sdks/go/pkg/beam/runner.go | 2 +-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 22 +-
.../beam/runners/dataflow/dataflowlib/execute.go | 12 +-
.../pkg/beam/runners/dataflow/dataflowlib/fixup.go | 2 +-
.../pkg/beam/runners/dataflow/dataflowlib/job.go | 14 +-
.../beam/runners/dataflow/dataflowlib/messages.go | 4 +-
.../beam/runners/dataflow/dataflowlib/metrics.go | 4 +-
.../runners/dataflow/dataflowlib/metrics_test.go | 4 +-
.../pkg/beam/runners/dataflow/dataflowlib/stage.go | 8 +-
.../beam/runners/dataflow/dataflowlib/translate.go | 22 +-
sdks/go/pkg/beam/runners/direct/buffer.go | 6 +-
sdks/go/pkg/beam/runners/direct/direct.go | 18 +-
sdks/go/pkg/beam/runners/direct/gbk.go | 10 +-
sdks/go/pkg/beam/runners/direct/gbk_test.go | 4 +-
sdks/go/pkg/beam/runners/direct/impulse.go | 6 +-
sdks/go/pkg/beam/runners/dot/dot.go | 6 +-
sdks/go/pkg/beam/runners/flink/flink.go | 4 +-
sdks/go/pkg/beam/runners/samza/samza.go | 4 +-
sdks/go/pkg/beam/runners/session/session.go | 20 +-
sdks/go/pkg/beam/runners/spark/spark.go | 4 +-
.../beam/runners/universal/extworker/extworker.go | 10 +-
.../runners/universal/extworker/extworker_test.go | 4 +-
.../beam/runners/universal/runnerlib/compile.go | 4 +-
.../beam/runners/universal/runnerlib/execute.go | 14 +-
.../go/pkg/beam/runners/universal/runnerlib/job.go | 16 +-
.../pkg/beam/runners/universal/runnerlib/stage.go | 12 +-
sdks/go/pkg/beam/runners/universal/universal.go | 20 +-
.../pkg/beam/runners/vet/testpipeline/functions.go | 4 +-
.../beam/runners/vet/testpipeline/testpipeline.go | 2 +-
.../runners/vet/testpipeline/testpipeline.shims.go | 10 +-
sdks/go/pkg/beam/runners/vet/vet.go | 20 +-
sdks/go/pkg/beam/runners/vet/vet_test.go | 4 +-
sdks/go/pkg/beam/schema.go | 4 +-
sdks/go/pkg/beam/testing/passert/count.go | 6 +-
sdks/go/pkg/beam/testing/passert/count_test.go | 4 +-
sdks/go/pkg/beam/testing/passert/equals.go | 2 +-
sdks/go/pkg/beam/testing/passert/equals_test.go | 6 +-
sdks/go/pkg/beam/testing/passert/floats.go | 6 +-
sdks/go/pkg/beam/testing/passert/floats_test.go | 4 +-
sdks/go/pkg/beam/testing/passert/hash.go | 4 +-
sdks/go/pkg/beam/testing/passert/passert.go | 10 +-
sdks/go/pkg/beam/testing/passert/passert.shims.go | 10 +-
sdks/go/pkg/beam/testing/passert/passert_test.go | 4 +-
sdks/go/pkg/beam/testing/passert/sum.go | 4 +-
sdks/go/pkg/beam/testing/passert/sum_test.go | 4 +-
sdks/go/pkg/beam/testing/ptest/ptest.go | 6 +-
sdks/go/pkg/beam/testing/teststream/teststream.go | 10 +-
.../pkg/beam/testing/teststream/teststream_test.go | 2 +-
sdks/go/pkg/beam/transforms/filter/distinct.go | 2 +-
.../go/pkg/beam/transforms/filter/distinct_test.go | 6 +-
sdks/go/pkg/beam/transforms/filter/filter.go | 8 +-
sdks/go/pkg/beam/transforms/filter/filter.shims.go | 10 +-
sdks/go/pkg/beam/transforms/filter/filter_test.go | 6 +-
sdks/go/pkg/beam/transforms/stats/count.go | 4 +-
sdks/go/pkg/beam/transforms/stats/count_test.go | 6 +-
sdks/go/pkg/beam/transforms/stats/max.go | 2 +-
sdks/go/pkg/beam/transforms/stats/max_test.go | 6 +-
sdks/go/pkg/beam/transforms/stats/mean.go | 4 +-
sdks/go/pkg/beam/transforms/stats/mean_test.go | 6 +-
sdks/go/pkg/beam/transforms/stats/min.go | 2 +-
sdks/go/pkg/beam/transforms/stats/min_test.go | 6 +-
sdks/go/pkg/beam/transforms/stats/quantiles.go | 4 +-
.../go/pkg/beam/transforms/stats/quantiles_test.go | 8 +-
sdks/go/pkg/beam/transforms/stats/stats.shims.go | 8 +-
sdks/go/pkg/beam/transforms/stats/sum.go | 2 +-
sdks/go/pkg/beam/transforms/stats/sum_test.go | 6 +-
sdks/go/pkg/beam/transforms/stats/util.go | 4 +-
sdks/go/pkg/beam/transforms/stats/util_gen.go | 2 +-
sdks/go/pkg/beam/transforms/stats/util_gen.tmpl | 2 +-
sdks/go/pkg/beam/transforms/top/top.go | 14 +-
sdks/go/pkg/beam/transforms/top/top.shims.go | 8 +-
sdks/go/pkg/beam/transforms/top/top_test.go | 2 +-
sdks/go/pkg/beam/util.go | 2 +-
sdks/go/pkg/beam/util/gcsx/gcs.go | 2 +-
sdks/go/pkg/beam/util/gcsx/gcs_test.go | 2 +-
sdks/go/pkg/beam/util/grpcx/dial.go | 2 +-
sdks/go/pkg/beam/util/grpcx/hook.go | 2 +-
sdks/go/pkg/beam/util/grpcx/metadata.go | 2 +-
sdks/go/pkg/beam/util/pubsubx/pubsub.go | 4 +-
sdks/go/pkg/beam/util/shimx/generate.go | 10 +-
sdks/go/pkg/beam/util/starcgenx/starcgenx.go | 6 +-
sdks/go/pkg/beam/util/starcgenx/starcgenx_test.go | 6 +-
sdks/go/pkg/beam/util/syscallx/syscall.go | 2 +-
sdks/go/pkg/beam/validate.go | 4 +-
sdks/go/pkg/beam/windowing.go | 6 +-
sdks/go/pkg/beam/x/beamx/run.go | 22 +-
sdks/go/pkg/beam/x/debug/debug.shims.go | 10 +-
sdks/go/pkg/beam/x/debug/doc.go | 2 +-
sdks/go/pkg/beam/x/debug/head.go | 4 +-
sdks/go/pkg/beam/x/debug/print.go | 6 +-
sdks/go/pkg/beam/x/hooks/perf/perf.go | 4 +-
sdks/go/pkg/beam/xlang.go | 8 +-
sdks/go/test/build.gradle | 27 +-
sdks/go/test/integration/driver/driver.go | 14 +-
sdks/go/test/integration/integration.go | 2 +-
sdks/go/test/integration/io/xlang/kafka/kafka.go | 8 +-
.../test/integration/io/xlang/kafka/kafka_test.go | 12 +-
sdks/go/test/integration/primitives/cogbk.go | 4 +-
sdks/go/test/integration/primitives/cogbk_test.go | 4 +-
sdks/go/test/integration/primitives/flatten.go | 4 +-
.../go/test/integration/primitives/flatten_test.go | 4 +-
sdks/go/test/integration/primitives/pardo.go | 4 +-
sdks/go/test/integration/primitives/pardo_test.go | 4 +-
.../test/integration/primitives/primitives_test.go | 10 +-
sdks/go/test/integration/primitives/teststream.go | 6 +-
.../test/integration/primitives/teststream_test.go | 4 +-
sdks/go/test/integration/primitives/windowinto.go | 10 +-
.../test/integration/primitives/windowinto_test.go | 6 +-
sdks/go/test/integration/synthetic/synthetic.go | 6 +-
.../test/integration/synthetic/synthetic_test.go | 18 +-
sdks/go/test/integration/wordcount/wordcount.go | 8 +-
.../test/integration/wordcount/wordcount_test.go | 14 +-
sdks/go/test/integration/xlang/xlang_test.go | 18 +-
sdks/go/test/load/build.gradle | 17 +-
sdks/go/test/load/cogbk/cogbk.go | 10 +-
sdks/go/test/load/combine/combine.go | 12 +-
sdks/go/test/load/group_by_key/group_by_key.go | 10 +-
sdks/go/test/load/pardo/pardo.go | 10 +-
sdks/go/test/load/sideinput/sideinput.go | 10 +-
sdks/go/test/load/util.go | 4 +-
.../go/test/regression/coders/fromyaml/fromyaml.go | 12 +-
sdks/go/test/regression/lperror.go | 2 +-
sdks/go/test/regression/lperror_test.go | 16 +-
sdks/go/test/regression/pardo.go | 6 +-
sdks/go/test/regression/pardo_test.go | 12 +-
sdks/go/test/regression/regression_test.go | 2 +-
sdks/go/test/run_validatesrunner_tests.sh | 41 +-
sdks/java/container/boot.go | 14 +-
sdks/java/container/build.gradle | 10 +-
sdks/python/container/boot.go | 10 +-
sdks/python/container/build.gradle | 10 +-
sdks/python/container/piputil.go | 2 +-
429 files changed, 5307 insertions(+), 4984 deletions(-)