This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from dcdb9e1 Merge pull request #6438 from apache/revert-6151-beam4780-2
add 2ca29ed Change Environment proto
add 3c38f86 Finalizing the Environment proto
add 171f7dc Adding URL back to environment for backward compatibility
add 7b4156b Merge pull request #6373: [BEAM-5288] Enhance Environment
proto to support different types of environments
No new revisions were added by this update.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 40 +-
.../runners/core/construction/Environments.java | 34 +-
.../runners/core/construction/SdkComponents.java | 5 +-
.../core/construction/graph/FusedPipeline.java | 2 +-
.../core/construction/CoderTranslationTest.java | 3 +-
.../core/construction/CombineTranslationTest.java | 7 +-
.../CreatePCollectionViewTranslationTest.java | 5 +-
.../core/construction/EnvironmentsTest.java | 12 +-
.../construction/PCollectionTranslationTest.java | 5 +-
.../PCollectionViewTranslationTest.java | 5 +-
.../core/construction/ParDoTranslationTest.java | 7 +-
.../core/construction/ReadTranslationTest.java | 5 +-
.../construction/RehydratedComponentsTest.java | 10 +-
.../construction/TestStreamTranslationTest.java | 5 +-
.../construction/WindowIntoTranslationTest.java | 3 +-
.../WindowingStrategyTranslationTest.java | 5 +-
.../construction/WriteFilesTranslationTest.java | 3 +-
.../construction/graph/ExecutableStageTest.java | 6 +-
.../graph/GreedyPipelineFuserTest.java | 22 +-
.../construction/graph/GreedyStageFuserTest.java | 39 +-
.../graph/ImmutableExecutableStageTest.java | 3 +-
.../BundleFactoryOutputReceiverFactoryTest.java | 4 +-
.../GroupByKeyOnlyEvaluatorFactoryTest.java | 4 +-
.../fnexecution/control/JobBundleFactoryBase.java | 2 +-
.../environment/DockerEnvironmentFactory.java | 16 +-
.../environment/EnvironmentFactory.java | 2 +-
.../environment/InProcessEnvironmentFactory.java | 4 +-
.../environment/ProcessEnvironmentFactory.java | 22 +-
.../control/DockerJobBundleFactoryTest.java | 5 +-
.../control/ProcessJobBundleFactoryTest.java | 5 +-
...gleEnvironmentInstanceJobBundleFactoryTest.java | 5 +-
.../environment/DockerEnvironmentFactoryTest.java | 8 +-
.../environment/ProcessEnvironmentFactoryTest.java | 17 +-
.../environment/RemoteEnvironmentTest.java | 3 +-
.../wire/LengthPrefixUnknownCodersTest.java | 4 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 11 +-
sdks/go/pkg/beam/core/runtime/pipelinex/util.go | 6 +-
.../beam/model/fnexecution_v1/beam_fn_api.pb.go | 1082 ++++++++------
.../model/fnexecution_v1/beam_provision_api.pb.go | 58 +-
.../model/jobmanagement_v1/beam_artifact_api.pb.go | 96 +-
.../beam/model/jobmanagement_v1/beam_job_api.pb.go | 100 +-
.../beam/model/pipeline_v1/beam_runner_api.pb.go | 1567 +++++++++++++-------
sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go | 38 +-
.../model/pipeline_v1/standard_window_fns.pb.go | 58 +-
.../beam/fn/harness/AssignWindowsRunnerTest.java | 8 +-
.../beam/fn/harness/WindowMappingFnRunnerTest.java | 4 +-
sdks/python/apache_beam/portability/common_urns.py | 3 +
.../python/apache_beam/runners/pipeline_context.py | 7 +-
48 files changed, 2013 insertions(+), 1352 deletions(-)
