This is an automated email from the ASF dual-hosted git repository.
robinyqiu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from ab1d27c [BEAM-10124] Announce ContextualTextIO in Beam 2.26.0.
(#13402)
add 6a0fbe2 [BEAM-10896] Support ZetaSQL UNNEST syntax on array of struct
type (#13377)
No new revisions were added by this update.
Summary of changes:
.../sql/zetasql/ZetaSQLQueryPlanner.java | 8 ++
.../translation/ArrayScanColumnRefToUncollect.java | 4 +-
.../ArrayScanLiteralToUncollectConverter.java | 4 +-
.../translation/ArrayScanToJoinConverter.java | 5 +-
.../zetasql/unnest/BeamZetaSqlUncollectRel.java} | 30 +++--
.../zetasql/unnest/BeamZetaSqlUncollectRule.java} | 27 ++--
.../sql/zetasql/unnest/BeamZetaSqlUnnestRel.java} | 48 +++----
.../sql/zetasql/unnest/BeamZetaSqlUnnestRule.java} | 30 +++--
.../sql/zetasql/unnest/ZetaSqlUnnest.java | 140 +++++++++++++++++++++
.../sql/zetasql/unnest}/package-info.java | 4 +-
.../beam/sdk/extensions/sql/zetasql/TestInput.java | 66 ++++++++--
.../sql/zetasql/ZetaSqlDialectSpecTest.java | 101 ++++++++++++++-
.../extensions/sql/zetasql/ZetaSqlTestBase.java | 8 +-
13 files changed, 391 insertions(+), 84 deletions(-)
copy
sdks/java/extensions/sql/{src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUncollectRel.java
=>
zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUncollectRel.java}
(81%)
copy
sdks/java/extensions/sql/{src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUncollectRule.java
=>
zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUncollectRule.java}
(62%)
copy
sdks/java/extensions/sql/{src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUnnestRel.java
=>
zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUnnestRel.java}
(82%)
copy
sdks/java/extensions/sql/{src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUnnestRule.java
=>
zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUnnestRule.java}
(81%)
create mode 100644
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/ZetaSqlUnnest.java
copy
sdks/java/extensions/sql/{datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog
=>
zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest}/package-info.java
(85%)
