You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2020/11/24 18:49:28 UTC
[beam] branch master updated (ab1d27c -> 6a0fbe2)

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