You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2019/12/20 02:08:44 UTC
[beam] branch master updated (7c5fa73 -> 3174445)
This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 7c5fa73 [BEAM-8335] Background caching job (#10405)
add edff83f Makes environment ID a top level attribute of PTransform.
add 3174445 Merge pull request #10183: [BEAM-7850] Makes environment ID a top level attribute of PTransform.
No new revisions were added by this update.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 57 +-
.../core/construction/CombineTranslation.java | 14 +-
.../runners/core/construction/Environments.java | 111 +--
.../core/construction/ExternalTranslation.java | 2 +
.../construction/PCollectionViewTranslation.java | 14 +-
.../core/construction/PTransformTranslation.java | 19 +-
.../core/construction/ParDoTranslation.java | 61 +-
.../runners/core/construction/ReadTranslation.java | 32 +-
.../runners/core/construction/SplittableParDo.java | 3 +-
.../construction/WindowingStrategyTranslation.java | 69 +-
.../core/construction/WriteFilesTranslation.java | 29 +-
.../construction/graph/OutputDeduplicator.java | 1 +
.../graph/SplittableParDoExpander.java | 3 +
.../core/construction/CombineTranslationTest.java | 4 +-
.../core/construction/EnvironmentsTest.java | 155 +---
.../construction/graph/ExecutableStageTest.java | 10 +-
.../graph/GreedyPipelineFuserTest.java | 108 ++-
.../construction/graph/GreedyStageFuserTest.java | 107 ++-
.../graph/ImmutableExecutableStageTest.java | 2 +-
.../dataflow/PrimitiveParDoSingleFactory.java | 2 +-
...FetchAndFilterStreamingSideInputsOperation.java | 6 +-
.../dataflow/worker/FnApiWindowMappingFn.java | 11 +-
.../graph/CreateExecutableStageNodeFunction.java | 4 +-
...nsertFetchAndFilterStreamingSideInputNodes.java | 2 +-
.../beam/runners/dataflow/worker/graph/Nodes.java | 4 +-
.../worker/graph/RegisterNodeFunction.java | 4 +-
.../dataflow/worker/FnApiWindowMappingFnTest.java | 4 +-
...tFetchAndFilterStreamingSideInputNodesTest.java | 6 +-
.../runners/dataflow/worker/graph/NodesTest.java | 7 +-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 8 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 90 +--
.../beam/model/pipeline_v1/beam_runner_api.pb.go | 852 ++++++++++-----------
.../org/apache/beam/fn/harness/CombineRunners.java | 8 +-
.../beam/fn/harness/WindowMappingFnRunner.java | 5 +-
.../beam/fn/harness/WindowMergingFnRunner.java | 4 +-
.../harness/control/ProcessBundleHandlerTest.java | 11 +-
sdks/python/apache_beam/pipeline.py | 29 +-
sdks/python/apache_beam/pvalue.py | 24 +-
.../portability/fn_api_runner_transforms.py | 31 +-
.../apache_beam/runners/worker/bundle_processor.py | 16 +-
sdks/python/apache_beam/transforms/core.py | 13 +-
sdks/python/apache_beam/transforms/external.py | 3 +-
sdks/python/apache_beam/transforms/ptransform.py | 1 +
sdks/python/apache_beam/utils/urns.py | 25 +-
44 files changed, 848 insertions(+), 1123 deletions(-)