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 <[email protected]> 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(-)
