You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by zy...@apache.org on 2022/07/26 03:23:02 UTC
[iotdb] branch master updated (f4d1323f11 -> c735a127b9)
This is an automated email from the ASF dual-hosted git repository.
zyk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f4d1323f11 [IOTDB-3938] Avoid performance decline caused by fsync twice (#6769)
add c735a127b9 [IOTDB-3578] Support core requirements of template (#6750)
No new revisions were added by this update.
Summary of changes:
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 17 ++
.../confignode/client/DataNodeRequestType.java | 4 +-
.../sync/datanode/SyncDataNodeClientPool.java | 3 +
.../consensus/request/ConfigPhysicalPlan.java | 24 ++-
.../consensus/request/ConfigPhysicalPlanType.java | 8 +-
.../template/CheckTemplateSettablePlan.java} | 14 +-
.../GetAllSchemaTemplatePlan.java} | 22 +--
.../GetAllTemplateSetInfoPlan.java} | 22 +--
.../{ => template}/GetPathsSetTemplatePlan.java | 2 +-
.../GetSchemaTemplatePlan.java} | 24 +--
.../{ => template}/CreateSchemaTemplatePlan.java | 27 ++-
.../{ => template}/SetSchemaTemplatePlan.java | 2 +-
...thInfoResp.java => AllTemplateSetInfoResp.java} | 24 +--
.../consensus/response/DataNodeRegisterResp.java | 6 +
.../confignode/manager/ClusterSchemaManager.java | 149 +++++++++++---
.../iotdb/confignode/manager/ConfigManager.java | 12 +-
.../persistence/executor/ConfigPlanExecutor.java | 22 ++-
.../{ => schema}/ClusterSchemaInfo.java | 136 +++++++++----
.../persistence/schema/TemplateTable.java | 64 +-----
.../request/ConfigPhysicalPlanSerDeTest.java | 45 +++--
.../persistence/ClusterSchemaInfoTest.java | 28 ++-
.../confignode/persistence/TemplateTableTest.java | 18 +-
.../Administration-Management/Administration.md | 4 +
.../Administration-Management/Administration.md | 4 +
.../iotdb/db/it/schema}/IoTDBSchemaTemplateIT.java | 121 +++++-------
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 18 --
.../iotdb/commons/auth/entity/PrivilegeType.java | 10 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 18 ++
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 11 ++
.../template/TemplateIsInUseException.java | 5 +-
.../exception/sql/StatementAnalyzeException.java | 4 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 1 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 12 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 128 +++++++++++-
.../db/metadata/mtree/traverser/Traverser.java | 59 +++++-
.../traverser/collector/MeasurementCollector.java | 4 +-
.../traverser/counter/MeasurementCounter.java | 2 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 9 +
.../schemaregion/SchemaRegionMemoryImpl.java | 64 +++++-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 18 ++
.../metadata/template/ClusterTemplateManager.java | 214 +++++++++++++++++----
.../db/metadata/template/ITemplateManager.java | 10 +
.../iotdb/db/metadata/template/Template.java | 72 ++++---
.../template/TemplateInternalRPCUpdateType.java | 68 +++++++
.../metadata/visitor/SchemaExecutionVisitor.java | 27 +++
.../iotdb/db/mpp/common/header/HeaderConstant.java | 12 +-
...or.java => PathsUsingTemplateScanOperator.java} | 48 ++---
.../operator/schema/SchemaFetchScanOperator.java | 8 +-
.../schema/TimeSeriesSchemaScanOperator.java | 12 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 24 +++
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 148 ++++++++++++++
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 113 +++++++++--
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 18 ++
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 9 +
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 17 ++
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 9 +-
.../memory/StatementMemorySourceVisitor.java | 11 ++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 55 +++---
.../db/mpp/plan/parser/StatementGenerator.java | 124 ++++++++++++
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 20 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 25 ++-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 32 ++-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 10 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
...ntNode.java => PathsUsingTemplateScanNode.java} | 44 ++---
.../node/metedata/read/SchemaFetchScanNode.java | 39 +++-
.../metedata/read/TimeSeriesSchemaScanNode.java | 71 ++++++-
...meSeriesNode.java => ActivateTemplateNode.java} | 101 +++++-----
.../db/mpp/plan/statement/StatementVisitor.java | 11 ++
.../statement/internal/SchemaFetchStatement.java | 10 +-
.../ActivateTemplateStatement.java} | 36 ++--
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../template/SetSchemaTemplateStatement.java | 22 +--
...t.java => ShowPathsUsingTemplateStatement.java} | 15 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 7 +-
.../sys/ActivateTemplateInClusterPlan.java | 110 +++++++++++
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 12 ++
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +
.../service/thrift/impl/ClientRPCServiceImpl.java | 195 ++++++++++++++++++-
.../impl/DataNodeInternalRPCServiceImpl.java | 16 ++
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 5 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 3 +-
.../schema/SchemaFetchScanOperatorTest.java | 2 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 4 +-
.../src/main/thrift/confignode.thrift | 1 +
thrift/src/main/thrift/datanode.thrift | 7 +
90 files changed, 2301 insertions(+), 682 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/SetSchemaTemplatePlan.java => read/template/CheckTemplateSettablePlan.java} (79%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetSchemaTemplatePlan.java => template/GetAllSchemaTemplatePlan.java} (71%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetSchemaTemplatePlan.java => template/GetAllTemplateSetInfoPlan.java} (71%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => template}/GetPathsSetTemplatePlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetNodesInSchemaTemplatePlan.java => template/GetSchemaTemplatePlan.java} (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{ => template}/CreateSchemaTemplatePlan.java (73%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{ => template}/SetSchemaTemplatePlan.java (96%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{PathInfoResp.java => AllTemplateSetInfoResp.java} (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/{ => schema}/ClusterSchemaInfo.java (85%)
copy {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it/schema}/IoTDBSchemaTemplateIT.java (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateInternalRPCUpdateType.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesSchemaScanOperator.java => PathsUsingTemplateScanOperator.java} (52%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{DevicesCountNode.java => PathsUsingTemplateScanNode.java} (57%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/{InternalCreateTimeSeriesNode.java => ActivateTemplateNode.java} (55%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{DropFunctionStatement.java => template/ActivateTemplateStatement.java} (66%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{ShowPathSetTemplateStatement.java => ShowPathsUsingTemplateStatement.java} (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ActivateTemplateInClusterPlan.java