This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from a589b10 Merge pull request #16604: [BEAM-13714] Get rid of
unnecessary logs for BigQuery streaming writes
add cf79c26 [BEAM-12976] Implement Java projection pushdown optimizer.
(#16513)
No new revisions were added by this update.
Summary of changes:
.../graph/PCollectionOutputTagVisitor.java | 91 +++++
.../graph/ProjectionProducerVisitor.java | 6 +
.../graph/ProjectionPushdownOptimizer.java | 136 ++++++++
.../graph/ProjectionPushdownOptimizerTest.java | 366 +++++++++++++++++++++
4 files changed, 599 insertions(+)
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/PCollectionOutputTagVisitor.java
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/ProjectionPushdownOptimizer.java
create mode 100644
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/graph/ProjectionPushdownOptimizerTest.java
