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:14 UTC
[beam] 01/01: [BEAM-13099] Use RelMetadataQuery subclass rather
than calling RelNode.metadata (#15820)
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(-)