This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch multitimeseries
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 79ef4a6e4a Support CreateMultiTimeseries in new cluster
add fa4fe21ea1 [IoTDB-3170] Add MemoryTable framework for MPP (#5890)
add 956165acdc [IOTDB-3175] Unable to find file when creating user with
AuthorInfo (#5867)
add 465b0cffbe [IOTDB-2919] Feature/Delete storage group (#5811)
new ad3a18461a Support CreateMultiTimeseries in new cluster
The 1 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:
confignode/pom.xml | 5 +
.../resources/conf/iotdb-confignode.properties | 31 ++-
.../iotdb/confignode/conf/ConfigNodeConf.java | 34 +++
.../confignode/conf/ConfigNodeDescriptor.java | 18 ++
.../consensus/request/ConfigRequest.java | 14 +-
.../consensus/request/ConfigRequestType.java | 2 +
.../{SetTTLReq.java => DeleteProcedureReq.java} | 41 ++-
.../request/write/DeleteStorageGroupReq.java | 14 +-
.../{SetTTLReq.java => UpdateProcedureReq.java} | 46 ++--
.../statemachine/PartitionRegionStateMachine.java | 34 ++-
.../confignode/manager/ClusterSchemaManager.java | 5 +
.../iotdb/confignode/manager/ConfigManager.java | 43 ++-
.../iotdb/confignode/manager/ConsensusManager.java | 7 +-
.../apache/iotdb/confignode/manager/Manager.java | 8 +
.../iotdb/confignode/manager/PartitionManager.java | 5 +
.../iotdb/confignode/manager/ProcedureManager.java | 183 +++++++++++++
.../iotdb/confignode/persistence/AuthorInfo.java | 6 +-
.../confignode/persistence/ClusterSchemaInfo.java | 32 ++-
.../confignode/persistence/PartitionInfo.java | 43 +++
.../confignode/persistence/ProcedureInfo.java | 115 ++++++++
.../executor/ConfigRequestExecutor.java | 10 +
.../confignode/procedure/ConfigProcedureStore.java | 146 +++++++++++
.../procedure/DeleteStorageGroupProcedure.java | 247 +++++++++++++++++
.../procedure/DeleteStorageGroupState.java | 13 +-
.../confignode/procedure/ProcedureFactory.java | 72 +++++
.../procedure/env/ConfigNodeProcedureEnv.java | 84 ++++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 14 +-
.../consensus/request/ConfigRequestSerDeTest.java | 63 ++++-
.../confignode/persistence/AuthorInfoTest.java | 292 +++++++++++++++++++++
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 37 +++
.../confignode1conf/iotdb-confignode.properties | 3 +-
.../confignode2conf/iotdb-confignode.properties | 3 +-
.../confignode3conf/iotdb-confignode.properties | 3 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 11 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 5 +
.../iotdb/commons/auth/user/IUserAccessor.java | 7 +
.../commons/auth/user/LocalFileUserAccessor.java | 12 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 11 +
.../iotdb/commons/conf/CommonDescriptor.java | 1 +
.../iotdb/procedure/CompletedProcedureCleaner.java | 17 +-
.../apache/iotdb/procedure/InternalProcedure.java | 4 +-
.../java/org/apache/iotdb/procedure/Procedure.java | 36 +--
.../apache/iotdb/procedure/ProcedureExecutor.java | 10 +-
.../iotdb/procedure/StateMachineProcedure.java | 8 +-
.../iotdb/procedure/service/ProcedureServer.java | 3 +-
.../service/ProcedureServerProcessor.java | 16 +-
.../iotdb/procedure/store/IProcedureFactory.java | 12 +-
.../iotdb/procedure/store/IProcedureStore.java | 1 +
.../iotdb/procedure/store/ProcedureStore.java | 17 +-
.../apache/iotdb/procedure/store/ProcedureWAL.java | 11 +-
.../iotdb/procedure/entity/IncProcedure.java | 7 +
.../procedure/entity/SimpleLockProcedure.java | 2 +
.../iotdb/procedure/entity/SleepProcedure.java | 7 +
.../iotdb/procedure/entity/StuckProcedure.java | 4 +-
.../iotdb/procedure/entity/StuckSTMProcedure.java | 5 +-
.../procedure/entity/TestProcedureFactory.java | 76 ++++++
.../procedure/service/TestProcedureService.java | 2 +
.../iotdb/procedure/store/TestProcedureStore.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 1 -
.../apache/iotdb/db/auth}/AuthorizerManager.java | 10 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 6 +-
.../consensus/statemachine/BaseStateMachine.java | 2 +-
.../statemachine/DataRegionStateMachine.java | 33 ++-
.../apache/iotdb/db/engine/StorageEngineV2.java | 4 +
.../metadata/visitor/SchemaExecutionVisitor.java | 14 +
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 14 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 2 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 33 +++
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 5 +
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 3 +
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 3 +
.../db/mpp/plan/analyze/IPartitionFetcher.java | 2 +
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 2 +
.../plan/analyze/StandalonePartitionFetcher.java | 3 +
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 3 +
.../db/mpp/plan/execution/QueryExecution.java | 21 +-
.../plan/execution/config/ConfigTaskVisitor.java | 6 +
...SetTTLTask.java => DeleteStorageGroupTask.java} | 57 ++--
.../plan/execution/memory/MemorySourceHandle.java} | 69 ++---
.../StatementMemorySource.java} | 33 +--
.../memory/StatementMemorySourceContext.java} | 23 +-
.../StatementMemorySourceVisitor.java} | 30 +--
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 13 +
.../db/mpp/plan/planner/plan/FragmentInstance.java | 18 +-
.../plan/planner/plan/node/DeleteRegionNode.java | 109 ++++++++
.../db/mpp/plan/planner/plan/node/PlanNode.java | 2 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 5 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 4 +
.../db/mpp/plan/statement/StatementVisitor.java | 10 +-
...ement.java => DeleteStorageGroupStatement.java} | 39 ++-
.../db/protocol/mqtt/BrokerAuthenticator.java | 4 +-
.../protocol/rest/filter/AuthorizationFilter.java | 4 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +-
.../iotdb/db/query/control/SessionManager.java | 2 +-
.../service/thrift/impl/InternalServiceImpl.java | 40 +++
.../db/service/thrift/impl/TSServiceImpl.java | 9 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 3 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 12 +-
.../execution/memory/MemorySourceHandleTest.java} | 53 ++--
.../plan/node/write/DeleteRegionNodeSerdeTest.java | 60 +++++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../src/main/thrift/confignode.thrift | 8 +-
thrift/src/main/thrift/mpp.thrift | 28 ++
103 files changed, 2374 insertions(+), 400 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetTTLReq.java
=> DeleteProcedureReq.java} (63%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetTTLReq.java
=> UpdateProcedureReq.java} (63%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/ProcedureInfo.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/ConfigProcedureStore.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/DeleteStorageGroupProcedure.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/DeleteStorageGroupState.java
(80%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureFactory.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/persistence/AuthorInfoTest.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/common/cache/Cache.java =>
procedure/src/main/java/org/apache/iotdb/procedure/store/IProcedureFactory.java
(79%)
create mode 100644
procedure/src/test/java/org/apache/iotdb/procedure/entity/TestProcedureFactory.java
rename {node-commons/src/main/java/org/apache/iotdb/commons/auth/authorizer =>
server/src/main/java/org/apache/iotdb/db/auth}/AuthorizerManager.java (95%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{SetTTLTask.java
=> DeleteStorageGroupTask.java} (57%)
copy
server/src/{test/java/org/apache/iotdb/db/mpp/execution/datatransfer/StubSinkHandle.java
=>
main/java/org/apache/iotdb/db/mpp/plan/execution/memory/MemorySourceHandle.java}
(54%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/{IQueryExecution.java
=> memory/StatementMemorySource.java} (67%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/{planner/plan/node/WritePlanNode.java
=> execution/memory/StatementMemorySourceContext.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/{IQueryExecution.java
=> memory/StatementMemorySourceVisitor.java} (62%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/DeleteRegionNode.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{ShowStorageGroupStatement.java
=> DeleteStorageGroupStatement.java} (68%)
copy
server/src/{main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterNullOperator.java
=>
test/java/org/apache/iotdb/db/mpp/execution/memory/MemorySourceHandleTest.java}
(55%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/DeleteRegionNodeSerdeTest.java
