This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch last_query_api
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3fafeb9dd0 Support last query api in new cluster
add c36df17ac3 [IOTDB-3288] Fix user doc of auth module (#6020)
add d7d69709f1 [IOTDB-3227] UDF Management in MPP Cluster: CREATE FUNCTION
(#6014)
add 0f5ab7c02c Revert "[IOTDB-3286] False Carousel Ratio on Desktop
Version Homepage (#6012)" (#6022)
add 1f724c807d [IOTDB-3288] Fix single quotes to backtick. (#6023)
add 790e57ff71 [IOTDB-3283] Implement Analyzer & LogicalPlanner for last
query (#6017)
add 1a972e81e1 renew pictures of 'Structure of Apache IoTDB (#6018)
new df9e8cf48c Merge branch 'master' of https://github.com/apache/iotdb
into last_query_api
new 64fc00eb28 Support last query api in new cluster
The 2 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:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../resources/conf/iotdb-confignode.properties | 28 ++-
.../confignode/client/AsyncDataNodeClientPool.java | 16 ++
.../client/handlers/CreateFunctionHandler.java | 58 ++++++
.../iotdb/confignode/conf/ConfigNodeConf.java | 36 +++-
.../confignode/conf/ConfigNodeDescriptor.java | 5 +-
.../consensus/request/ConfigRequest.java | 4 +
.../consensus/request/ConfigRequestType.java | 1 +
.../{SetTTLReq.java => CreateFunctionReq.java} | 68 +++----
.../iotdb/confignode/manager/ConfigManager.java | 21 ++-
.../apache/iotdb/confignode/manager/Manager.java | 9 +
.../iotdb/confignode/manager/UDFManager.java | 119 +++++++++++++
.../iotdb/confignode/persistence/UDFInfo.java | 117 ++++++++++++
.../executor/ConfigRequestExecutor.java | 11 +-
.../iotdb/confignode/service/ConfigNode.java | 18 ++
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../Administration-Management/Administration.md | 60 +++----
docs/UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/zh/Community/About.md | 22 +--
.../Administration-Management/Administration.md | 60 +++----
.../UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../iotdb/commons/udf/service/SnapshotUtils.java | 96 ++++++++++
.../commons/udf/service/UDFClassLoaderManager.java | 8 +
.../commons/udf/service/UDFExecutableManager.java | 196 +++++++++++++++++++++
.../commons/udf/service/UDFExecutableResource.java | 24 ++-
.../iotdb/commons/udf/service/UDFLogWriter.java | 21 ++-
.../udf/service/UDFRegistrationInformation.java | 13 +-
.../udf/service/UDFRegistrationService.java | 127 +++++++++++--
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 9 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 19 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 59 +++++--
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../plan/execution/config/CreateFunctionTask.java | 117 ++++++++++++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 29 +++
.../db/mpp/plan/parser/StatementGenerator.java | 6 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 23 +++
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 6 +
.../plan/node/process/LastQueryMergeNode.java | 4 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 4 +-
.../plan/node/source/LastQueryScanNode.java | 6 +-
.../db/mpp/plan/statement/StatementVisitor.java | 6 +
...Statement.java => CreateFunctionStatement.java} | 44 ++---
.../java/org/apache/iotdb/db/service/DataNode.java | 30 ++--
.../service/thrift/impl/InternalServiceImpl.java | 20 +++
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 43 +++++
.../.vuepress/theme/global-components/IoTDB.vue | 43 +++--
.../.vuepress/theme/global-components/IoTDBZH.vue | 49 ++++--
.../src/main/thrift/confignode.thrift | 11 ++
thrift/src/main/thrift/mpp.thrift | 15 +-
52 files changed, 1481 insertions(+), 243 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/CreateFunctionHandler.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetTTLReq.java
=> CreateFunctionReq.java} (50%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/SnapshotUtils.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFExecutableManager.java
copy session/src/main/java/org/apache/iotdb/session/InsertConsumer.java =>
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFExecutableResource.java
(68%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/CreateFunctionTask.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{SetTTLStatement.java
=> CreateFunctionStatement.java} (67%)
