This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from bbe6c97 Merge pull request #4699: [BEAM-3182] [Nexmark][SQL]
Implement Query 7
add ee4c528 Add a multi-stage fuser
add 517a152 fixup! Add a multi-stage fuser
add 2949acb fixup! Add a multi-stage fuser
new c8ca899 Merge pull request #4647: Add a multi-stage fuser
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../core/construction/graph/ExecutableStage.java | 3 +
.../{PipelineNode.java => FusedPipeline.java} | 35 +-
.../graph/GreedilyFusedExecutableStage.java | 38 +
.../graph/GreedyPCollectionFusers.java | 19 +-
.../construction/graph/GreedyPipelineFuser.java | 321 ++++++++
.../core/construction/graph/QueryablePipeline.java | 12 +-
.../construction/graph/ExecutableStageMatcher.java | 100 +++
.../graph/GreedyPipelineFuserTest.java | 857 +++++++++++++++++++++
8 files changed, 1351 insertions(+), 34 deletions(-)
copy
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/{PipelineNode.java
=> FusedPipeline.java} (53%)
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPipelineFuser.java
create mode 100644
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/graph/ExecutableStageMatcher.java
create mode 100644
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/graph/GreedyPipelineFuserTest.java
--
To stop receiving notification emails like this one, please contact
[email protected].
