beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From danolive...@apache.org
Subject [beam] 01/01: Merge pull request #15323: [BEAM-5379] Go SDK modules support.
Date Wed, 18 Aug 2021 01:22:37 GMT
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 <daniel.o.programmer@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(-)

Mime
View raw message