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 e9e0508 Merge pull request #6476: [BEAM-5485] Fix time unit
discrepancies in windowing documentation
add 02b7c4f Add PortablePipelineOption for environment
add a8ae5e5 Lazy initializing JobBundleFactory supporting multiple type
of environments
add a899932 Adding environment to python portable options
add 0327dcc Go Changes for using configurable environment. Only docker is
supported at the moment.
add dc4830d Merge pull request #6441: [BEAM-5288] Support environment
pipeline option in Java and Python.
No new revisions were added by this update.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 2 +-
.../runners/core/construction/Environments.java | 97 +++++++--
.../runners/core/construction/SdkComponents.java | 6 +-
.../core/construction/EnvironmentsTest.java | 41 ++++
.../runners/direct/portable/ReferenceRunner.java | 22 +--
.../FlinkDefaultExecutableStageContext.java | 20 +-
.../beam/runners/flink/PortableExecutionTest.java | 54 ++---
...ctoryBase.java => DefaultJobBundleFactory.java} | 219 +++++++++++----------
.../control/DockerJobBundleFactory.java | 172 ----------------
.../control/ProcessJobBundleFactory.java | 84 --------
.../SingleEnvironmentInstanceJobBundleFactory.java | 2 +-
.../environment/DockerEnvironmentFactory.java | 117 +++++++++--
.../environment/EnvironmentFactory.java | 26 +++
.../environment/InProcessEnvironmentFactory.java | 27 +++
.../environment/ProcessEnvironmentFactory.java | 38 ++--
...yTest.java => DefaultJobBundleFactoryTest.java} | 169 +++++++++++++---
.../control/ProcessJobBundleFactoryTest.java | 196 ------------------
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 15 +-
.../pkg/beam/core/runtime/graphx/translate_test.go | 8 +-
sdks/go/pkg/beam/core/runtime/pipelinex/util.go | 2 +-
sdks/go/pkg/beam/options/jobopts/options.go | 42 +++-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 39 +++-
sdks/go/pkg/beam/runners/universal/universal.go | 28 ++-
sdks/go/test/run_integration_tests.sh | 3 +-
.../beam/sdk/options/PortablePipelineOptions.java | 28 ++-
.../python/apache_beam/options/pipeline_options.py | 17 +-
.../python/apache_beam/runners/pipeline_context.py | 13 +-
.../runners/portability/portable_runner.py | 41 +++-
.../runners/portability/portable_runner_test.py | 54 +++++
29 files changed, 846 insertions(+), 736 deletions(-)
rename
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/{JobBundleFactoryBase.java
=> DefaultJobBundleFactory.java} (68%)
delete mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DockerJobBundleFactory.java
delete mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessJobBundleFactory.java
rename
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/{DockerJobBundleFactoryTest.java
=> DefaultJobBundleFactoryTest.java} (50%)
delete mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/ProcessJobBundleFactoryTest.java
