You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bh...@apache.org on 2021/10/28 18:07:13 UTC
[beam] branch master updated (4cdbe8d -> cd4b7f3)
This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4cdbe8d [BEAM-13130] Remove persistent references to stateKeyReaders (#15815)
add 0e5451f [BEAM-13099] Replace call to RelNode.metadata with BeamRelMetadataQuery
add 60eaa82 [BEAM-13099] Update all rels to use BeamRelMetadataQuery
new cd4b7f3 [BEAM-13099] Use RelMetadataQuery subclass rather than calling RelNode.metadata (#15820)
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:
.../extensions/sql/impl/CalciteQueryPlanner.java | 14 +++++---
.../BeamRelMetadataQuery.java} | 40 ++++++++++++----------
.../sql/impl/planner/RelMdNodeStats.java | 6 ++--
.../sql/impl/rel/AbstractBeamCalcRel.java | 5 +--
.../sql/impl/rel/BeamAggregationRel.java | 7 ++--
.../sdk/extensions/sql/impl/rel/BeamIOSinkRel.java | 6 ++--
.../extensions/sql/impl/rel/BeamIOSourceRel.java | 5 +--
.../extensions/sql/impl/rel/BeamIntersectRel.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamMatchRel.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamMinusRel.java | 6 ++--
.../sql/impl/rel/BeamPushDownIOSourceRel.java | 4 +--
.../sdk/extensions/sql/impl/rel/BeamRelNode.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 6 ++--
.../extensions/sql/impl/rel/BeamSqlRelUtils.java | 7 ++--
.../sql/impl/rel/BeamTableFunctionScanRel.java | 6 ++--
.../extensions/sql/impl/rel/BeamUncollectRel.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamUnionRel.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamUnnestRel.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamWindowRel.java | 6 ++--
.../extensions/sql/impl/planner/NodeStatsTest.java | 4 ++-
.../sql/impl/rel/BeamAggregationRelTest.java | 4 ++-
.../extensions/sql/impl/rel/BeamCalcRelTest.java | 21 ++++++++----
.../rel/BeamCoGBKJoinRelBoundedVsBoundedTest.java | 17 ++++++---
.../BeamCoGBKJoinRelUnboundedVsUnboundedTest.java | 11 ++++--
.../sql/impl/rel/BeamIOSourceRelTest.java | 9 +++--
.../sql/impl/rel/BeamIntersectRelTest.java | 5 ++-
.../extensions/sql/impl/rel/BeamMinusRelTest.java | 9 +++--
.../sql/impl/rel/BeamSideInputJoinRelTest.java | 11 ++++--
.../extensions/sql/impl/rel/BeamSortRelTest.java | 5 ++-
.../sql/impl/rel/BeamUncollectRelTest.java | 4 ++-
.../extensions/sql/impl/rel/BeamUnionRelTest.java | 9 +++--
.../extensions/sql/impl/rel/BeamValuesRelTest.java | 5 ++-
.../sql/zetasql/ZetaSQLQueryPlanner.java | 4 +++
.../zetasql/unnest/BeamZetaSqlUncollectRel.java | 6 ++--
.../sql/zetasql/unnest/BeamZetaSqlUnnestRel.java | 6 ++--
37 files changed, 183 insertions(+), 113 deletions(-)
copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/{rule/BeamIOSinkRule.java => planner/BeamRelMetadataQuery.java} (53%)
[beam] 01/01: [BEAM-13099] Use RelMetadataQuery subclass rather
than calling RelNode.metadata (#15820)
Posted by bh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit cd4b7f3b1af4f51bdab1a0b1a98f94b5288c09ec
Merge: 4cdbe8d 60eaa82
Author: Brian Hulette <bh...@google.com>
AuthorDate: Thu Oct 28 11:06:07 2021 -0700
[BEAM-13099] Use RelMetadataQuery subclass rather than calling RelNode.metadata (#15820)
[BEAM-13099] Use RelMetadataQuery subclass rather than calling RelNode.metadata
.../extensions/sql/impl/CalciteQueryPlanner.java | 14 +++++--
.../sql/impl/planner/BeamRelMetadataQuery.java | 46 ++++++++++++++++++++++
.../sql/impl/planner/RelMdNodeStats.java | 6 ++-
.../sql/impl/rel/AbstractBeamCalcRel.java | 5 ++-
.../sql/impl/rel/BeamAggregationRel.java | 7 ++--
.../sdk/extensions/sql/impl/rel/BeamIOSinkRel.java | 6 +--
.../extensions/sql/impl/rel/BeamIOSourceRel.java | 5 ++-
.../extensions/sql/impl/rel/BeamIntersectRel.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamMatchRel.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamMinusRel.java | 6 +--
.../sql/impl/rel/BeamPushDownIOSourceRel.java | 4 +-
.../sdk/extensions/sql/impl/rel/BeamRelNode.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 6 +--
.../extensions/sql/impl/rel/BeamSqlRelUtils.java | 7 ++--
.../sql/impl/rel/BeamTableFunctionScanRel.java | 6 +--
.../extensions/sql/impl/rel/BeamUncollectRel.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamUnionRel.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamUnnestRel.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 6 +--
.../sdk/extensions/sql/impl/rel/BeamWindowRel.java | 6 +--
.../extensions/sql/impl/planner/NodeStatsTest.java | 4 +-
.../sql/impl/rel/BeamAggregationRelTest.java | 4 +-
.../extensions/sql/impl/rel/BeamCalcRelTest.java | 21 +++++++---
.../rel/BeamCoGBKJoinRelBoundedVsBoundedTest.java | 17 +++++---
.../BeamCoGBKJoinRelUnboundedVsUnboundedTest.java | 11 ++++--
.../sql/impl/rel/BeamIOSourceRelTest.java | 9 ++++-
.../sql/impl/rel/BeamIntersectRelTest.java | 5 ++-
.../extensions/sql/impl/rel/BeamMinusRelTest.java | 9 ++++-
.../sql/impl/rel/BeamSideInputJoinRelTest.java | 11 ++++--
.../extensions/sql/impl/rel/BeamSortRelTest.java | 5 ++-
.../sql/impl/rel/BeamUncollectRelTest.java | 4 +-
.../extensions/sql/impl/rel/BeamUnionRelTest.java | 9 ++++-
.../extensions/sql/impl/rel/BeamValuesRelTest.java | 5 ++-
.../sql/zetasql/ZetaSQLQueryPlanner.java | 4 ++
.../zetasql/unnest/BeamZetaSqlUncollectRel.java | 6 +--
.../sql/zetasql/unnest/BeamZetaSqlUnnestRel.java | 6 +--
37 files changed, 208 insertions(+), 94 deletions(-)