You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/05/26 07:26:33 UTC
[iotdb] branch last_query_api updated (3fafeb9dd0 -> 64fc00eb28)
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%)
[iotdb] 02/02: Support last query api in new cluster
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch last_query_api
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 64fc00eb284ac3b791d062ef067e926c4c539c81
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu May 26 15:25:48 2022 +0800
Support last query api in new cluster
---
.../org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
index 0798f18d1d..41c19df05c 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
@@ -96,7 +96,8 @@ public class StatementGenerator {
fromComponent.addPrefixPath(path);
}
selectComponent.addResultColumn(
- new ResultColumn(new TimeSeriesOperand(new PartialPath("")), ResultColumn.ColumnType.RAW));
+ new ResultColumn(
+ new TimeSeriesOperand(new PartialPath("", false)), ResultColumn.ColumnType.RAW));
// set query filter
GreaterEqualExpression leftPredicate =
@@ -132,7 +133,8 @@ public class StatementGenerator {
fromComponent.addPrefixPath(path);
}
selectComponent.addResultColumn(
- new ResultColumn(new TimeSeriesOperand(new PartialPath("")), ResultColumn.ColumnType.RAW));
+ new ResultColumn(
+ new TimeSeriesOperand(new PartialPath("", false)), ResultColumn.ColumnType.RAW));
// set query filter
GreaterEqualExpression predicate =
[iotdb] 01/02: Merge branch 'master' of https://github.com/apache/iotdb into last_query_api
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch last_query_api
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit df9e8cf48c22139f409fab570a13269dd46c87e2
Merge: 3fafeb9dd0 1a972e81e1
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu May 26 15:04:59 2022 +0800
Merge branch 'master' of https://github.com/apache/iotdb into last_query_api
.../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 +
.../consensus/request/write/CreateFunctionReq.java | 85 +++++++++
.../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 | 39 ++++
.../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/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 +
.../metadata/CreateFunctionStatement.java | 73 ++++++++
.../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 +-
51 files changed, 1599 insertions(+), 180 deletions(-)