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%)
