This is an automated email from the ASF dual-hosted git repository.
amaliujia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 5994182 Merge pull request #9379 from y1chi/BEAM-7804
add 68734a2 [BEAM-7832] Add ZetaSQL as a dialect in BeamSQL (#9210)
No new revisions were added by this update.
Summary of changes:
.../jenkins/job_PreCommit_BeamSQL_ZetaSQL.groovy | 34 +
build.gradle | 4 +
.../src/main/resources/beam/suppressions.xml | 4 +
sdks/java/extensions/sql/build.gradle | 34 +
.../extensions/sql/zetasql/BeamBuiltinMethods.java | 71 +
.../extensions/sql/zetasql/BeamCodegenUtils.java | 37 +
.../sdk/extensions/sql/zetasql/DateFunctions.java | 38 +
.../sdk/extensions/sql/zetasql/DateTimeUtils.java | 278 ++
.../sdk/extensions/sql/zetasql/QueryTrait.java | 76 +
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 278 ++
.../zetasql/SqlCaseWithValueOperatorRewriter.java | 77 +
.../sql/zetasql/SqlCoalesceOperatorRewriter.java | 67 +
.../SqlExtractTimestampOperatorRewriter.java | 47 +
.../sql/zetasql/SqlIfNullOperatorRewriter.java | 51 +
.../sql/zetasql/SqlNullIfOperatorRewriter.java | 53 +
.../sql/zetasql/SqlOperatorRewriter.java | 35 +
.../sdk/extensions/sql/zetasql/SqlOperators.java | 197 +
.../sql/zetasql/SqlStdOperatorMappingTable.java | 359 ++
.../extensions/sql/zetasql/StringFunctions.java | 182 +
.../extensions/sql/zetasql/TableResolution.java | 91 +
.../sql/zetasql/TableResolutionContext.java | 73 +
.../sdk/extensions/sql/zetasql/TableResolver.java | 36 +
.../extensions/sql/zetasql/TableResolverImpl.java | 61 +
.../beam/sdk/extensions/sql/zetasql/TestInput.java | 255 ++
.../extensions/sql/zetasql/TimestampFunctions.java | 48 +
.../beam/sdk/extensions/sql/zetasql/TypeUtils.java | 166 +
.../sql/zetasql/ZetaSQLCastFunctionImpl.java | 116 +
.../extensions/sql/zetasql/ZetaSQLPlannerImpl.java | 185 +
.../sql/zetasql/ZetaSQLQueryPlanner.java | 143 +
.../sdk/extensions/sql/zetasql/ZetaSqlIdUtils.java | 84 +
.../sdk/extensions/sql/zetasql/package-info.java | 20 +
.../translation/AggregateScanConverter.java | 230 ++
.../translation/ArrayScanToJoinConverter.java | 101 +
.../translation/ArrayScanToUncollectConverter.java | 62 +
.../sql/zetasql/translation/ConversionContext.java | 65 +
.../zetasql/translation/ExpressionConverter.java | 1019 ++++++
.../zetasql/translation/FilterScanConverter.java | 52 +
.../sql/zetasql/translation/JoinScanConverter.java | 101 +
.../translation/JoinScanWithRefConverter.java | 95 +
.../LimitOffsetScanToLimitConverter.java | 63 +
.../LimitOffsetScanToOrderByLimitConverter.java | 101 +
.../OrderByScanUnsupportedConverter.java | 39 +
.../zetasql/translation/ProjectScanConverter.java | 49 +
.../translation/QueryStatementConverter.java | 114 +
.../sql/zetasql/translation/RelConverter.java | 74 +
.../translation/SetOperationScanConverter.java | 114 +
.../translation/SingleRowScanConverter.java | 41 +
.../zetasql/translation/TableScanConverter.java | 131 +
.../zetasql/translation/WithRefScanConverter.java | 53 +
.../sql/zetasql/translation/WithScanConverter.java | 55 +
.../sql/zetasql/translation/package-info.java | 20 +
.../JoinCompoundIdentifiersTestZetaSQL.java | 342 ++
.../sql/zetasql/ZetaSQLDialectSpecTestZetaSQL.java | 3800 ++++++++++++++++++++
53 files changed, 9921 insertions(+)
create mode 100644 .test-infra/jenkins/job_PreCommit_BeamSQL_ZetaSQL.groovy
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamBuiltinMethods.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamCodegenUtils.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/DateFunctions.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/DateTimeUtils.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/QueryTrait.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlAnalyzer.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlCaseWithValueOperatorRewriter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlCoalesceOperatorRewriter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlExtractTimestampOperatorRewriter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlIfNullOperatorRewriter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlNullIfOperatorRewriter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlOperatorRewriter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlOperators.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlStdOperatorMappingTable.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/StringFunctions.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TableResolution.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TableResolutionContext.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TableResolver.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TableResolverImpl.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TestInput.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TimestampFunctions.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TypeUtils.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLCastFunctionImpl.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLPlannerImpl.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLQueryPlanner.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlIdUtils.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/package-info.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/AggregateScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ArrayScanToJoinConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ArrayScanToUncollectConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ConversionContext.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ExpressionConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/FilterScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/JoinScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/JoinScanWithRefConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/LimitOffsetScanToLimitConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/LimitOffsetScanToOrderByLimitConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/OrderByScanUnsupportedConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ProjectScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/QueryStatementConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/RelConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SetOperationScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SingleRowScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TableScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/WithRefScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/WithScanConverter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/package-info.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/zetasql/JoinCompoundIdentifiersTestZetaSQL.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLDialectSpecTestZetaSQL.java
