This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 1730e000eeb Fix BE UT macOS compile (#29663)
add d2718747753 [Refactor](dialect) Add sql dialect converter plugins
(#28890)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/doris/common/Config.java | 3 +
fe/fe-core/pom.xml | 6 -
.../org/apache/doris/analysis/InlineViewRef.java | 11 +-
.../exceptions/DialectTransformException.java | 3 +-
.../exceptions/UnsupportedDialectException.java | 9 +-
.../nereids/parser/ComplexFnCallTransformer.java | 2 +-
.../org/apache/doris/nereids/parser/Dialect.java | 101 +++++++++++++
.../parser/LogicalPlanBuilderAssistant.java | 3 +-
.../apache/doris/nereids/parser/NereidsParser.java | 47 +++---
.../apache/doris/nereids/parser/ParseDialect.java | 129 -----------------
.../apache/doris/nereids/parser/ParserContext.java | 6 +-
.../doris/plugin/DialectConverterPlugin.java | 61 ++++++++
.../java/org/apache/doris/plugin/PluginInfo.java | 3 +-
.../java/org/apache/doris/plugin/PluginMgr.java | 68 ++++++---
.../org/apache/doris/qe/AuditEventProcessor.java | 2 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 31 +++-
.../java/org/apache/doris/qe/SessionVariable.java | 7 +-
.../doris/nereids/parser/NereidsParserTest.java | 52 -------
.../doris/nereids/parser/ParserTestBase.java | 4 -
.../nereids/util/TrinoDialectPlanParseChecker.java | 60 --------
.../org/apache/doris/plugin/DialectPluginTest.java | 76 ++++++++++
.../{PluginTest.java => TestDialectPlugin1.java} | 41 ++----
.../{PluginTest.java => TestDialectPlugin2.java} | 39 ++---
fe/pom.xml | 8 --
fe_plugins/http-dialect-converter/pom.xml | 119 +++++++++++++++
.../src/main/assembly/plugin.conf | 22 +++
.../src/main/assembly/plugin.properties | 23 +++
.../src/main/assembly/zip.xml | 0
.../dialect/http/HttpDialectConverterPlugin.java | 144 +++++++++++++++++++
.../plugin/dialect/http/HttpDialectUtils.java | 53 +------
.../plugin/dialect/http/HttpDialectUtilsTest.java | 68 ++++-----
.../plugin/dialect/http}/SimpleHttpServer.java | 2 +-
fe_plugins/pom.xml | 43 +++++-
fe_plugins/sparksql-converter/pom.xml | 132 +++++++++++++++++
.../src/main/assembly/plugin.conf | 18 +++
.../src/main/assembly/plugin.properties | 23 +++
.../src/main/assembly/zip.xml | 0
.../dialect}/spark/DateTruncFnCallTransformer.java | 8 +-
.../spark/SparkSql3FnCallTransformers.java | 6 +-
.../spark/SparkSql3LogicalPlanBuilder.java | 6 +-
.../spark/SparkSqlDialectConverterPlugin.java | 47 ++++++
.../plugin/dialect}/spark/FnTransformTest.java | 41 ++++--
.../doris/plugin/dialect/spark/ParserTest.java | 64 +++++++++
fe_plugins/trino-converter/pom.xml | 159 +++++++++++++++++++++
.../trino-converter/src/main/assembly/plugin.conf | 18 +++
.../src/main/assembly/plugin.properties | 23 +++
.../src/main/assembly/zip.xml | 0
.../dialect}/trino/DateDiffFnCallTransformer.java | 2 +-
.../dialect/trino/TrinoDialectConverterPlugin.java | 48 +++----
.../dialect}/trino/TrinoFnCallTransformers.java | 3 +-
.../dialect}/trino/TrinoLogicalPlanBuilder.java | 3 +-
.../doris/plugin/dialect}/trino/TrinoParser.java | 33 +++--
.../plugin/dialect}/trino/FnTransformTest.java | 41 +++++-
.../doris/plugin/dialect/trino/ParserTest.java | 34 ++++-
54 files changed, 1410 insertions(+), 545 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/parser/Dialect.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/parser/ParseDialect.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plugin/DialectConverterPlugin.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/util/TrinoDialectPlanParseChecker.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/plugin/DialectPluginTest.java
copy fe/fe-core/src/test/java/org/apache/doris/plugin/{PluginTest.java =>
TestDialectPlugin1.java} (54%)
copy fe/fe-core/src/test/java/org/apache/doris/plugin/{PluginTest.java =>
TestDialectPlugin2.java} (55%)
create mode 100644 fe_plugins/http-dialect-converter/pom.xml
create mode 100755
fe_plugins/http-dialect-converter/src/main/assembly/plugin.conf
create mode 100755
fe_plugins/http-dialect-converter/src/main/assembly/plugin.properties
copy fe_plugins/{auditloader =>
http-dialect-converter}/src/main/assembly/zip.xml (100%)
create mode 100644
fe_plugins/http-dialect-converter/src/main/java/org/apache/doris/plugin/dialect/http/HttpDialectConverterPlugin.java
rename
fe/fe-core/src/main/java/org/apache/doris/common/util/SQLDialectUtils.java =>
fe_plugins/http-dialect-converter/src/main/java/org/apache/doris/plugin/dialect/http/HttpDialectUtils.java
(77%)
rename
fe/fe-core/src/test/java/org/apache/doris/common/util/SQLDialectUtilsTest.java
=>
fe_plugins/http-dialect-converter/src/test/java/org/apache/doris/plugin/dialect/http/HttpDialectUtilsTest.java
(52%)
rename {fe/fe-core/src/test/java/org/apache/doris/utframe =>
fe_plugins/http-dialect-converter/src/test/java/org/apache/doris/plugin/dialect/http}/SimpleHttpServer.java
(98%)
create mode 100644 fe_plugins/sparksql-converter/pom.xml
create mode 100755 fe_plugins/sparksql-converter/src/main/assembly/plugin.conf
create mode 100755
fe_plugins/sparksql-converter/src/main/assembly/plugin.properties
copy fe_plugins/{auditloader => sparksql-converter}/src/main/assembly/zip.xml
(100%)
rename {fe/fe-core/src/main/java/org/apache/doris/nereids/parser =>
fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect}/spark/DateTruncFnCallTransformer.java
(95%)
rename {fe/fe-core/src/main/java/org/apache/doris/nereids/parser =>
fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect}/spark/SparkSql3FnCallTransformers.java
(93%)
rename {fe/fe-core/src/main/java/org/apache/doris/nereids/parser =>
fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect}/spark/SparkSql3LogicalPlanBuilder.java
(95%)
create mode 100644
fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect/spark/SparkSqlDialectConverterPlugin.java
rename {fe/fe-core/src/test/java/org/apache/doris/nereids/parser =>
fe_plugins/sparksql-converter/src/test/java/org/apache/doris/plugin/dialect}/spark/FnTransformTest.java
(77%)
create mode 100644
fe_plugins/sparksql-converter/src/test/java/org/apache/doris/plugin/dialect/spark/ParserTest.java
create mode 100644 fe_plugins/trino-converter/pom.xml
create mode 100755 fe_plugins/trino-converter/src/main/assembly/plugin.conf
create mode 100755
fe_plugins/trino-converter/src/main/assembly/plugin.properties
copy fe_plugins/{auditloader => trino-converter}/src/main/assembly/zip.xml
(100%)
rename {fe/fe-core/src/main/java/org/apache/doris/nereids/parser =>
fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect}/trino/DateDiffFnCallTransformer.java
(98%)
rename fe/fe-core/src/test/java/org/apache/doris/plugin/PluginTest.java =>
fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect/trino/TrinoDialectConverterPlugin.java
(50%)
rename {fe/fe-core/src/main/java/org/apache/doris/nereids/parser =>
fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect}/trino/TrinoFnCallTransformers.java
(95%)
rename {fe/fe-core/src/main/java/org/apache/doris/nereids/parser =>
fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect}/trino/TrinoLogicalPlanBuilder.java
(99%)
rename {fe/fe-core/src/main/java/org/apache/doris/nereids/parser =>
fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect}/trino/TrinoParser.java
(76%)
rename {fe/fe-core/src/test/java/org/apache/doris/nereids/parser =>
fe_plugins/trino-converter/src/test/java/org/apache/doris/plugin/dialect}/trino/FnTransformTest.java
(53%)
rename
fe/fe-core/src/test/java/org/apache/doris/nereids/parser/trino/QueryTest.java
=>
fe_plugins/trino-converter/src/test/java/org/apache/doris/plugin/dialect/trino/ParserTest.java
(54%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
