You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2022/10/31 07:59:49 UTC
[iotdb] branch beyyes/confignode_ratis_addNewNodeToExistedGroup updated (dcf7be8ce7 -> b97438bd6a)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/confignode_ratis_addNewNodeToExistedGroup
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dcf7be8ce7 add exception log message for ClusterIT
add a3e2b8eeab fix:增加write方法
add 5caefe60ba merge with master
add 7e882ce2a2 mvn spotless
add 346ef4eeac add buffer.position(buffer.limit()); before logWriter.write
add efcb6129fa fix:修改默认参数
add 8b0e15d194 adjust the method order in PartitionRegionStateMachine
add a62c78018e fix ratis init error
add c16bf02928 Merge branch 'master' into ljnBranch/master
add 3e1d3a4c04 merge with master
add d533765d51 Merge branch 'ljnBranch/master'
add 0ced2c9fb0 pull
add 81d9b5427a Merge branch 'master' into beyyes/confignode_ratis_addNewNodeToExistedGroup
add 0b004d7a0f Merge branch 'beyyes/confignode_ratis_addNewNodeToExistedGroup' of github.com:apache/iotdb into beyyes/confignode_ratis_addNewNodeToExistedGroup
add 9d9ef04b5a [IOTDB-3976] Support Drop Schema Template in cluster (#7769)
add 69582de2b5 [IOTDB-4787] Make Using clause in CREATE FUNCTION optional (ConfigNode) (#7785)
add 8cdfa446d7 [IOTDB-4743] OperatePipeProcedure support rollback (#7750)
add af1a000c91 [IOTDB-4782] Fix systemMetrics in confignode (#7768)
add 2ca857db14 [IOTDB-3936]Add an interface in IClientRPCService to directly return bytebuffer instead of TSQueryDataSet
add a78b9c2ee5 [IOTDB-4750] Refactor the configuration file structure (#7779)
add 561a4aaf64 [IOTDB-4788] Make Using clause in CREATE TRIGGER optional (ConfigNode) (#7788)
add aaf595de63 [IOTDB-3397] Support Template Session and Add Session IT (#7789)
add 9fb49a57b9 [IOTDB-4793] Prevent compatibility problems in ConfigNode (#7784)
add 9e48049e54 [IOTDB-4710] Update Keyword list (#7790)
add 1f151ba1cf SELECT INTO: implement explain & ignore ORDER BY (#7794)
add 9cc5e9ee98 [IOTDB-4763]Implement snapshot of UDFInfo (#7760)
add ca844c043a [IOTDB-4728] Unify APIs in session and sessionPool (#7707)
add 50e0139e7d [IOTDB-4728] Unify APIs in session and sessionPool (#7707)
add 04aebce3ef [IOTDB-4750] Refactor the configuration name (#7796)
add 093ae53c23 remove Ignore of UDFManagementIT
add a77f7bb3db [IOTDB-4137][IOTDB-4799] Update sync-tool docs and print more detailed pipe information in show pipe (#7797)
add 1fb1bdb1d7 Add UT for CreateCQProcedure (#7793)
add af05e0ba93 Merge branch 'master' of github.com:apache/iotdb
add 2e9fa3c91c [IOTDB-4796] Remove LoadStatistics consensus feature (#7799)
add bd907c0b79 [IOTDB-4741] [IOTDB-4767] Support fetching all connection info in Session & SessionPool (#7795)
add 8eaadfc497 Enable time partition by default (#7800)
add 76b947f56b Add built-in M4 UDF (#7755)
add a78cd55c89 Update download doc (#7801)
add 1e0f3300e0 Fix shell problem in start-confignode.sh/bat and start-datanode.sh/bat (#7811)
add caca66ada7 [IOTDB-2884]Redo Log for SchemaFile (#7726)
add 0e843a7614 Rename mpprest to rest (#7804)
add 21963788ad [IOTDB-4719] SchemaFile adaptation for cluster delete timeseries (#7709)
add a2ccdeb91d [IOTDB-4652] Add retry logic of borrow client in MultiLeaderImpl (#7741)
add 021056c1bd [IOTDB-4802] Optimize the logical plan of query with only time filter (#7805)
add 8f78e26799 Fix IoTDBConfigNodeSnapshotIT.testCreateUDF
add 2ee98de984 [IOTDB-4797] Supplement and improve the metedata plannode tostring function (#7786)
add a3df3a1b14 Rename time_partition to time_partition_interval_for_storage in system.properties file (#7810)
add 1fbe953c76 Merge branch 'master' of github.com:apache/iotdb
add b97438bd6a Merge branch 'master' into beyyes/confignode_ratis_addNewNodeToExistedGroup
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-python.yml | 2 +-
.gitignore | 1 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 21 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 1 -
.../java/org/apache/iotdb/cli/AbstractCli.java | 11 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 4 +-
client-py/setup.py | 2 +-
client-py/tests/test_template.py | 127 +--
confignode/pom.xml | 5 +
confignode/src/assembly/confignode.xml | 4 +
.../resources/conf/iotdb-confignode.properties | 364 +-----
.../assembly/resources/sbin/stop-confignode.bat | 10 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 6 +-
.../confignode/client/DataNodeRequestType.java | 1 +
.../client/async/AsyncDataNodeClientPool.java | 6 +
.../client/async/handlers/AsyncClientHandler.java | 13 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 39 +-
.../async/handlers/rpc/OperatePipeRPCHandler.java | 60 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 28 +-
.../confignode/conf/ConfigNodeDescriptor.java | 319 +++---
.../confignode/conf/ConfigNodeRemoveCheck.java | 2 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 2 +-
.../confignode/conf/SystemPropertiesUtils.java | 24 +-
.../consensus/request/ConfigPhysicalPlan.java | 203 ++--
.../consensus/request/ConfigPhysicalPlanType.java | 228 ++--
.../consensus/request/auth/AuthorPlan.java | 41 +-
.../GetDataNodeConfigurationPlan.java | 4 +-
.../read/{ => function}/GetFunctionTablePlan.java | 4 +-
.../read/{ => partition}/GetDataPartitionPlan.java | 4 +-
.../{ => partition}/GetNodePathsPartitionPlan.java | 4 +-
.../GetOrCreateDataPartitionPlan.java | 2 +-
.../GetOrCreateSchemaPartitionPlan.java | 2 +-
.../{ => partition}/GetSchemaPartitionPlan.java | 4 +-
.../{ => partition}/GetSeriesSlotListPlan.java | 4 +-
.../read/{ => partition}/GetTimeSlotListPlan.java | 4 +-
.../request/read/{ => region}/GetRegionIdPlan.java | 4 +-
.../read/{ => region}/GetRegionInfoListPlan.java | 4 +-
.../{ => storagegroup}/CountStorageGroupPlan.java | 4 +-
.../{ => storagegroup}/GetStorageGroupPlan.java | 2 +-
.../read/template/CheckTemplateSettablePlan.java | 2 +-
.../read/template/GetAllSchemaTemplatePlan.java | 2 +-
.../read/template/GetAllTemplateSetInfoPlan.java | 2 +-
.../read/template/GetPathsSetTemplatePlan.java | 2 +-
.../read/template/GetSchemaTemplatePlan.java | 2 +-
.../read/template/GetTemplateSetInfoPlan.java | 2 +-
.../{ => trigger}/GetTransferringTriggersPlan.java | 4 +-
.../read/{ => trigger}/GetTriggerJarPlan.java | 4 +-
.../read/{ => trigger}/GetTriggerLocationPlan.java | 4 +-
.../read/{ => trigger}/GetTriggerTablePlan.java | 4 +-
.../request/read/{ => udf}/GetUDFJarPlan.java | 4 +-
.../write/confignode/ApplyConfigNodePlan.java | 2 +-
.../write/confignode/RemoveConfigNodePlan.java | 2 +-
.../consensus/request/write/cq/ActiveCQPlan.java | 2 +-
.../consensus/request/write/cq/AddCQPlan.java | 2 +-
.../consensus/request/write/cq/DropCQPlan.java | 2 +-
.../consensus/request/write/cq/ShowCQPlan.java | 2 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 2 +-
.../write/datanode/RegisterDataNodePlan.java | 2 +-
.../request/write/datanode/RemoveDataNodePlan.java | 2 +-
.../request/write/datanode/UpdateDataNodePlan.java | 2 +-
.../request/write/function/CreateFunctionPlan.java | 2 +-
.../request/write/function/DropFunctionPlan.java | 2 +-
.../write/partition/CreateDataPartitionPlan.java | 2 +-
.../write/partition/CreateSchemaPartitionPlan.java | 2 +-
.../write/partition/UpdateRegionLocationPlan.java | 2 +-
.../write/procedure/DeleteProcedurePlan.java | 2 +-
.../write/procedure/UpdateProcedurePlan.java | 2 +-
.../write/region/CreateRegionGroupsPlan.java | 6 +-
.../write/region/OfferRegionMaintainTasksPlan.java | 2 +-
.../write/region/PollRegionMaintainTaskPlan.java | 2 +-
.../write/statistics/UpdateLoadStatisticsPlan.java | 162 ---
.../AdjustMaxRegionGroupCountPlan.java | 2 +-
.../write/storagegroup/DeleteStorageGroupPlan.java | 2 +-
.../storagegroup/PreDeleteStorageGroupPlan.java | 2 +-
.../storagegroup/SetDataReplicationFactorPlan.java | 2 +-
.../SetSchemaReplicationFactorPlan.java | 2 +-
.../write/storagegroup/SetStorageGroupPlan.java | 2 +-
.../request/write/storagegroup/SetTTLPlan.java | 2 +-
.../storagegroup/SetTimePartitionIntervalPlan.java | 2 +-
.../request/write/sync/CreatePipeSinkPlan.java | 2 +-
.../consensus/request/write/sync/DropPipePlan.java | 2 +-
.../request/write/sync/DropPipeSinkPlan.java | 2 +-
.../request/write/sync/GetPipeSinkPlan.java | 2 +-
.../request/write/sync/PreCreatePipePlan.java | 2 +-
.../request/write/sync/SetPipeStatusPlan.java | 2 +-
.../consensus/request/write/sync/ShowPipePlan.java | 2 +-
.../write/template/CreateSchemaTemplatePlan.java | 2 +-
.../template/DropSchemaTemplatePlan.java} | 26 +-
.../write/template/PreUnsetSchemaTemplatePlan.java | 2 +-
.../RollbackPreUnsetSchemaTemplatePlan.java | 2 +-
.../write/template/SetSchemaTemplatePlan.java | 2 +-
.../write/template/UnsetSchemaTemplatePlan.java | 2 +-
.../write/trigger/AddTriggerInTablePlan.java | 2 +-
.../write/trigger/DeleteTriggerInTablePlan.java | 2 +-
.../write/trigger/UpdateTriggerLocationPlan.java | 2 +-
.../trigger/UpdateTriggerStateInTablePlan.java | 2 +-
.../trigger/UpdateTriggersOnTransferNodesPlan.java | 2 +-
.../statemachine/PartitionRegionStateMachine.java | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 37 +-
.../iotdb/confignode/manager/ConfigManager.java | 36 +-
.../apache/iotdb/confignode/manager/IManager.java | 21 +-
.../iotdb/confignode/manager/ProcedureManager.java | 19 +-
.../iotdb/confignode/manager/SyncManager.java | 87 +-
.../iotdb/confignode/manager/TriggerManager.java | 19 +-
.../iotdb/confignode/manager/UDFManager.java | 15 +-
.../iotdb/confignode/manager/load/LoadManager.java | 133 ++-
.../manager/load/balancer/RouteBalancer.java | 53 +-
.../load/balancer/router/RegionRouteMap.java | 14 +-
.../iotdb/confignode/manager/node/NodeManager.java | 110 +-
.../node/{ => heartbeat}/BaseNodeCache.java | 68 +-
.../{ => heartbeat}/ConfigNodeHeartbeatCache.java | 36 +-
.../{ => heartbeat}/DataNodeHeartbeatCache.java | 11 +-
.../node/{ => heartbeat}/NodeHeartbeatSample.java | 2 +-
.../node/heartbeat}/NodeStatistics.java | 7 +-
.../manager/partition/PartitionManager.java | 73 +-
.../partition/{ => heartbeat}/RegionCache.java | 7 +-
.../{ => heartbeat}/RegionGroupCache.java | 84 +-
.../heartbeat}/RegionGroupStatistics.java | 28 +-
.../{ => heartbeat}/RegionHeartbeatSample.java | 2 +-
.../partition/heartbeat}/RegionStatistics.java | 7 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 28 +-
.../iotdb/confignode/persistence/UDFInfo.java | 93 +-
.../persistence/executor/ConfigPlanExecutor.java | 82 +-
.../confignode/persistence/node/NodeInfo.java | 64 +-
.../persistence/partition/PartitionInfo.java | 128 +--
.../persistence/partition/RegionGroup.java | 2 +-
.../partition/StorageGroupPartitionTable.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 32 +-
.../persistence/schema/TemplateTable.java | 15 +
.../procedure/env/ConfigNodeProcedureEnv.java | 10 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../procedure/impl/cq/CreateCQProcedure.java | 4 +-
.../impl/node/AddConfigNodeProcedure.java | 4 +-
.../impl/node/RemoveConfigNodeProcedure.java | 4 +-
.../impl/node/RemoveDataNodeProcedure.java | 4 +-
.../impl/schema/DeactivateTemplateProcedure.java | 5 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 4 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 4 +-
.../impl/schema/UnsetTemplateProcedure.java | 4 +-
.../statemachine/CreateRegionGroupsProcedure.java | 6 +-
.../impl/statemachine/RegionMigrateProcedure.java | 4 +-
.../procedure/impl/sync/CreatePipeProcedure.java | 71 +-
.../procedure/impl/sync/DropPipeProcedure.java | 43 +-
.../OperatePipeProcedureRollbackProcessor.java | 122 ++
.../procedure/impl/sync/StartPipeProcedure.java | 101 +-
.../procedure/impl/sync/StopPipeProcedure.java | 101 +-
.../impl/{ => trigger}/CreateTriggerProcedure.java | 17 +-
.../impl/{ => trigger}/DropTriggerProcedure.java | 6 +-
.../procedure/store/ConfigProcedureStore.java | 2 +-
.../procedure/store/ProcedureFactory.java | 41 +-
.../confignode/procedure/store/ProcedureType.java | 82 ++
.../iotdb/confignode/service/ConfigNode.java | 14 +-
.../service/thrift/ConfigNodeRPCService.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 32 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 111 +-
.../load/balancer/router/LeaderRouterTest.java | 8 +-
.../balancer/router/LoadScoreGreedyRouterTest.java | 8 +-
.../confignode/manager/node/NodeCacheTest.java | 17 +-
.../manager/partition/RegionGroupCacheTest.java | 33 +-
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 13 -
.../confignode/persistence/PartitionInfoTest.java | 45 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 82 ++
.../persistence/node/NodeStatisticsTest.java | 1 +
.../statistics/RegionGroupStatisticsTest.java | 2 +
.../partition/statistics/RegionStatisticsTest.java | 1 +
.../procedure/impl/CreateCQProcedureTest.java | 87 ++
.../impl/CreateRegionGroupsProcedureTest.java | 4 +-
.../procedure/impl/CreateTriggerProcedureTest.java | 1 +
.../impl/DeactivateTemplateProcedureTest.java | 5 +-
.../impl/DeleteTimeSeriesProcedureTest.java | 4 +-
.../procedure/impl/DropTriggerProcedureTest.java | 1 +
.../procedure/impl/OperatePipeProcedureTest.java | 52 +
.../procedure/impl/UnsetTemplateProcedureTest.java | 4 +-
.../impl/node/AddConfigNodeProcedureTest.java} | 22 +-
.../impl/node/RemoveConfigNodeProcedureTest.java} | 22 +-
.../impl/node/RemoveDataNodeProcedureTest.java} | 27 +-
.../statemachine/RegionMigrateProcedureTest.java | 65 ++
.../confignode1conf/iotdb-confignode.properties | 15 +-
.../confignode2conf/iotdb-confignode.properties | 15 +-
.../confignode3conf/iotdb-confignode.properties | 15 +-
.../multileader/logdispatcher/LogDispatcher.java | 3 +-
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/confignode.xml | 4 +
distribution/src/assembly/datanode.xml | 4 +
docker/src/main/Dockerfile-1c1d-influxdb | 2 +-
docs/Download/README.md | 148 ++-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 296 ++---
docs/UserGuide/Query-Data/Select-Expression.md | 155 +++
docs/UserGuide/Reference/Keywords.md | 52 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 169 +--
docs/UserGuide/UDF-Library/M4.md | 101 +-
docs/zh/Download/README.md | 143 ++-
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 332 ++----
docs/zh/UserGuide/Query-Data/Select-Expression.md | 156 +++
docs/zh/UserGuide/Reference/Keywords.md | 50 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 172 +--
docs/zh/UserGuide/UDF-Library/M4.md | 101 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
external-api/pom.xml | 8 +
.../external/api/thrift/JudgableServerContext.java | 28 +-
.../external/api/thrift/ServerContextFactory.java | 17 +-
integration-test/import-control.xml | 9 +-
integration-test/src/assembly/mpp-test.xml | 18 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 14 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 22 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 25 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 3 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 3 +-
...thorizeIT.java => IoTDBClusterAuthorityIT.java} | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 65 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 69 +-
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 3 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 3 -
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 5 -
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 1 -
.../schema/IoTDBDeleteTimeseriesSchemaFileIT.java | 49 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 14 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 2 -
...BSelectInto2IT.java => IoTDBSelectInto3IT.java} | 9 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 7 +-
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 126 +--
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 2 +-
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 10 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 7 +-
.../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 283 +++++
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 20 +-
.../db/it/udf/IoTDBUDFOtherWindowQueryIT.java | 3 -
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 2 -
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 3 -
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 3 -
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 2 -
.../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 2 -
.../iotdb/session/it/IoTDBConnectionInfoIT.java | 66 ++
...ertNulIT.java => IoTDBSessionInsertNullIT.java} | 4 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 10 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 223 ++++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 186 +---
.../iotdb/session/it/pool/SessionPoolIT.java | 90 +-
.../src/test/resources/udf-example.jar | Bin 0 -> 10018 bytes
.../iotdb/integration/env/ClusterEnvConfig.java | 3 +-
.../apache/iotdb/integration/env/ClusterNode.java | 4 +-
.../iotdb/db/integration/IoTDBTracingIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 4 +-
.../apache/iotdb/session/template/TemplateUT.java | 400 -------
jdbc/src/main/feature/feature.xml | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 843 ++++++++------
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 1163 +++++++++++++++++++-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 26 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 4 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 77 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 34 +-
.../resources/conf/iotdb-common.properties | 1103 ++++++++++---------
.../iotdb/commons/client/ClientPoolFactory.java | 24 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 30 +-
.../iotdb/commons/conf/CommonDescriptor.java | 23 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 18 +-
.../exception/sync/PipeSinkBeingUsedException.java | 2 +-
.../commons/executable/ExecutableManager.java | 16 +-
.../apache/iotdb/commons/service/ServiceType.java | 29 +-
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 6 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 44 +-
.../iotdb/commons/sync/pipe/TsFilePipeInfo.java | 8 +-
.../iotdb/commons/trigger/TriggerInformation.java | 12 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 2 +
.../apache/iotdb/commons/udf/UDFInformation.java | 39 +-
.../org/apache/iotdb/commons/udf/UDFTable.java | 37 +
.../BuiltinTimeSeriesGeneratingFunction.java | 3 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 311 ++++++
.../commons/udf/service/UDFManagementService.java | 21 +-
openapi/pom.xml | 26 -
.../resources/conf/schema-rocksdb.properties | 8 +-
.../rocksdb/mnode/RStorageGroupMNode.java | 2 +-
.../assembly/resources/conf/schema-tag.properties | 2 +-
.../resources/conf/iotdb-datanode.properties | 1097 +-----------------
.../src/assembly/resources/sbin/stop-datanode.bat | 10 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 6 +-
server/src/assembly/server.xml | 4 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 23 +-
.../iotdb/db/client/DataNodeInternalClient.java | 40 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 94 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 30 +-
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 47 -
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 74 --
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 99 --
.../iotdb/db/engine/cq/ContinuousQueryService.java | 305 -----
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 200 ----
.../engine/cq/ContinuousQueryTaskPoolManager.java | 107 --
.../SchemaFileLogCorruptedException.java | 17 +-
.../exception/query/PathNumOverLimitException.java | 2 +-
.../exception/sql/PathNumOverLimitException.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 2 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 2 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 30 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 53 +
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 8 +-
.../db/metadata/mtree/store/MemMTreeStore.java | 2 +-
.../mtree/store/disk/schemafile/ISchemaPage.java | 3 +
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 2 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 51 +-
.../store/disk/schemafile/SchemaFileConfig.java | 28 +-
.../mtree/store/disk/schemafile/SchemaPage.java | 14 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 7 +
.../disk/schemafile/log/SchemaFileLogReader.java | 112 ++
.../schemafile/log/SchemaFileLogSerializer.java | 18 +-
.../disk/schemafile/log/SchemaFileLogWriter.java | 68 ++
.../disk/schemafile/pagemgr/BTreePageManager.java | 7 +-
.../disk/schemafile/pagemgr/IPageManager.java | 2 +
.../store/disk/schemafile/pagemgr/PageManager.java | 146 ++-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 93 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 2 +
.../db/mpp/execution/exchange/ISourceHandle.java | 10 +
.../mpp/execution/exchange/LocalSourceHandle.java | 21 +
.../db/mpp/execution/exchange/SourceHandle.java | 22 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 15 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 23 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 6 +-
.../db/mpp/plan/execution/IQueryExecution.java | 3 +
.../db/mpp/plan/execution/QueryExecution.java | 33 +-
.../mpp/plan/execution/config/ConfigExecution.java | 18 +
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 41 +-
.../config/executor/IConfigTaskExecutor.java | 4 +
.../executor/StandaloneConfigTaskExecutor.java | 12 +
.../metadata/template/DropSchemaTemplateTask.java} | 39 +-
.../execution/config/sys/sync/ShowPipeTask.java | 3 +-
.../plan/execution/memory/MemorySourceHandle.java | 22 +
.../memory/StatementMemorySourceVisitor.java | 9 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 6 +
.../db/mpp/plan/parser/StatementGenerator.java | 14 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 53 +
.../metedata/read/AbstractSchemaMergeNode.java | 5 +
.../node/metedata/read/CountSchemaMergeNode.java | 5 +
.../plan/node/metedata/read/DevicesCountNode.java | 6 +
.../metedata/read/LevelTimeSeriesCountNode.java | 7 +
.../read/NodeManagementMemoryMergeNode.java | 5 +
.../node/metedata/read/NodePathsConvertNode.java | 5 +
.../node/metedata/read/NodePathsCountNode.java | 5 +
.../metedata/read/NodePathsSchemaScanNode.java | 7 +
.../metedata/read/PathsUsingTemplateScanNode.java | 7 +
.../node/metedata/read/SchemaFetchScanNode.java | 2 +-
.../node/metedata/read/SchemaQueryMergeNode.java | 2 +-
.../node/metedata/read/SchemaQueryScanNode.java | 2 +-
.../node/metedata/read/TimeSeriesCountNode.java | 7 +
.../db/mpp/plan/statement/StatementVisitor.java | 6 +
.../template/DropSchemaTemplateStatement.java | 55 +
.../db/protocol/influxdb/handler/QueryHandler.java | 498 ---------
.../influxdb/handler/QueryHandlerFactory.java | 2 +-
.../influxdb/meta/InfluxDBMetaManager.java | 221 ----
.../influxdb/meta/InfluxDBMetaManagerFactory.java | 2 +-
.../influxdb/meta/NewInfluxDBMetaManager.java | 6 +
.../iotdb/db/protocol/mpprest/MPPRestService.java | 162 ---
.../protocol/mpprest/filter/ApiOriginFilter.java | 45 -
.../mpprest/filter/AuthorizationFilter.java | 138 ---
.../mpprest/filter/BasicSecurityContext.java | 56 -
.../iotdb/db/protocol/mpprest/filter/User.java | 38 -
.../db/protocol/mpprest/filter/UserCache.java | 56 -
.../mpprest/handler/AuthorizationHandler.java | 47 -
.../protocol/mpprest/handler/ExceptionHandler.java | 86 --
.../mpprest/handler/QueryDataSetHandler.java | 279 -----
.../mpprest/handler/RequestValidationHandler.java | 53 -
.../mpprest/impl/GrafanaApiServiceImpl.java | 268 -----
.../protocol/mpprest/impl/PingApiServiceImpl.java | 51 -
.../protocol/mpprest/impl/RestApiServiceImpl.java | 203 ----
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 41 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 145 ---
.../apache/iotdb/db/protocol/rest/RestService.java | 1 +
.../rest/handler/AuthorizationHandler.java | 10 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 13 +-
.../handler/PhysicalPlanConstructionHandler.java | 163 ---
.../handler/PhysicalPlanValidationHandler.java | 81 --
.../protocol/rest/handler/QueryDataSetHandler.java | 331 +++---
.../handler/StatementConstructionHandler.java | 4 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 183 +--
.../db/protocol/rest/impl/RestApiServiceImpl.java | 152 ++-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 19 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 56 +-
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +-
.../apache/iotdb/db/qp/utils/DateTimeUtils.java | 4 +-
.../iotdb/db/query/context/QueryContext.java | 14 +-
.../db/query/control/QueryResourceManager.java | 11 +-
.../iotdb/db/query/control/QueryTimeManager.java | 46 +-
.../iotdb/db/query/control/SessionManager.java | 413 +++----
.../db/query/control/SessionManagerMBean.java | 20 +-
.../db/query/control/SessionTimeoutManager.java | 119 --
.../query/control/clientsession/ClientSession.java | 115 ++
.../control/clientsession/IClientSession.java | 137 +++
.../clientsession/InternalClientSession.java | 97 ++
.../control/clientsession/MqttClientSession.java | 82 ++
.../apache/iotdb/db/query/executor/fill/IFill.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 12 +-
.../org/apache/iotdb/db/service/MQTTService.java | 3 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 6 +-
.../iotdb/db/service/basic/ServiceProvider.java | 1 -
.../db/service/metrics/DataNodeMetricsHelper.java | 2 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 22 +-
.../thrift/handler/BaseServerContextHandler.java | 79 ++
.../handler/InfluxDBServiceThriftHandler.java | 11 +-
.../thrift/handler/RPCServiceThriftHandler.java | 19 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 826 ++++++++------
.../impl/DataNodeInternalRPCServiceImpl.java | 57 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 183 ---
.../db/service/thrift/impl/TSServiceImpl.java | 412 +++----
.../java/org/apache/iotdb/db/sync/SyncService.java | 109 +-
.../db/sync/receiver/load/DeletionLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 2 +-
.../db/sync/transport/server/ReceiverManager.java | 2 +-
.../trigger/service/TriggerManagementService.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 27 +
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 8 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 6 +-
.../engine/compaction/CompactionSchedulerTest.java | 3 +
.../inner/InnerCompactionMoreDataTest.java | 3 +
.../engine/modification/DeletionFileNodeTest.java | 433 --------
.../db/engine/modification/DeletionQueryTest.java | 362 ------
.../idtable/IDTableResourceControlTest.java | 167 ---
.../db/metadata/idtable/IDTableRestartTest.java | 205 ----
.../db/metadata/idtable/InsertWithIDTableTest.java | 759 -------------
.../QueryAlignedTimeseriesWithIDTableTest.java | 373 -------
.../db/metadata/idtable/QueryWithIDTableTest.java | 375 -------
.../mtree/schemafile/SchemaFileLogTest.java | 156 +++
.../metadata/mtree/schemafile/SchemaFileTest.java | 25 +-
.../schemaRegion/SchemaRegionBasicTest.java | 84 ++
.../db/mpp/plan/StandaloneCoordinatorTest.java | 14 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 11 +-
.../db/protocol/rest/GrafanaApiServiceTest.java | 3 +
.../db/protocol/rest/IoTDBRestServiceTest.java | 3 +
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 395 -------
.../db/qp/physical/InsertTabletMultiPlanTest.java | 300 -----
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 449 --------
.../dataset/EngineDataSetWithValueFilterTest.java | 159 ---
.../query/dataset/groupby/GroupByDataSetTest.java | 226 ----
.../dataset/groupby/GroupByFillDataSetTest.java | 194 ----
.../dataset/groupby/GroupByLevelDataSetTest.java | 161 ---
.../valuefilter/RawQueryWithValueFilterTest.java | 147 ---
.../sync/pipedata/BufferedPipeDataQueueTest.java | 3 +
.../iotdb/db/sync/pipedata/PipeDataTest.java | 21 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 9 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 47 +-
.../datanode1conf/iotdb-datanode.properties | 28 +-
.../datanode2conf/iotdb-datanode.properties | 28 +-
.../datanode3conf/iotdb-datanode.properties | 28 +-
.../src/test/resources/iotdb-datanode.properties | 10 +-
service-rpc/pom.xml | 8 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 345 +++---
.../apache/iotdb/rpc/TElasticFramedTransport.java | 4 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 8 +-
.../java/org/apache/iotdb/session/ISession.java | 5 +
.../java/org/apache/iotdb/session/Session.java | 14 +
.../apache/iotdb/session/SessionConnection.java | 43 +-
.../org/apache/iotdb/session/SessionDataSet.java | 29 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 315 +++++-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 4 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 2 +
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 1 +
.../src/test/resources/iotdb-datanode.properties | 2 +-
.../src/main/thrift/confignode.thrift | 8 +-
thrift/src/main/thrift/client.thrift | 39 +-
thrift/src/main/thrift/datanode.thrift | 6 +
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 28 +
470 files changed, 11479 insertions(+), 16373 deletions(-)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/OperatePipeRPCHandler.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => datanode}/GetDataNodeConfigurationPlan.java (93%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => function}/GetFunctionTablePlan.java (91%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => partition}/GetDataPartitionPlan.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => partition}/GetNodePathsPartitionPlan.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => partition}/GetOrCreateDataPartitionPlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => partition}/GetOrCreateSchemaPartitionPlan.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => partition}/GetSchemaPartitionPlan.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => partition}/GetSeriesSlotListPlan.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => partition}/GetTimeSlotListPlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => region}/GetRegionIdPlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => region}/GetRegionInfoListPlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => storagegroup}/CountStorageGroupPlan.java (95%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => storagegroup}/GetStorageGroupPlan.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => trigger}/GetTransferringTriggersPlan.java (91%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => trigger}/GetTriggerJarPlan.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => trigger}/GetTriggerLocationPlan.java (93%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => trigger}/GetTriggerTablePlan.java (93%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => udf}/GetUDFJarPlan.java (94%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/statistics/UpdateLoadStatisticsPlan.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/template/GetPathsSetTemplatePlan.java => write/template/DropSchemaTemplatePlan.java} (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/BaseNodeCache.java (54%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/ConfigNodeHeartbeatCache.java (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/DataNodeHeartbeatCache.java (88%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/NodeHeartbeatSample.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{persistence/node => manager/node/heartbeat}/NodeStatistics.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/{ => heartbeat}/RegionCache.java (87%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/{ => heartbeat}/RegionGroupCache.java (66%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{persistence/partition/statistics => manager/partition/heartbeat}/RegionGroupStatistics.java (85%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/{ => heartbeat}/RegionHeartbeatSample.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{persistence/partition/statistics => manager/partition/heartbeat}/RegionStatistics.java (94%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/OperatePipeProcedureRollbackProcessor.java
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/{ => trigger}/CreateTriggerProcedure.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/{ => trigger}/DropTriggerProcedure.java (96%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ProcedureType.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/UDFInfoTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateCQProcedureTest.java
copy confignode/src/test/java/org/apache/iotdb/confignode/{persistence/node/NodeStatisticsTest.java => procedure/impl/node/AddConfigNodeProcedureTest.java} (66%)
copy confignode/src/test/java/org/apache/iotdb/confignode/{persistence/node/NodeStatisticsTest.java => procedure/impl/node/RemoveConfigNodeProcedureTest.java} (65%)
copy confignode/src/test/java/org/apache/iotdb/confignode/{persistence/node/NodeStatisticsTest.java => procedure/impl/node/RemoveDataNodeProcedureTest.java} (60%)
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/statemachine/RegionMigrateProcedureTest.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetStorageGroupPlan.java => external-api/src/main/java/org/apache/iotdb/external/api/thrift/JudgableServerContext.java (59%)
copy node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeStatus.java => external-api/src/main/java/org/apache/iotdb/external/api/thrift/ServerContextFactory.java (78%)
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBClusterAuthorizeIT.java => IoTDBClusterAuthorityIT.java} (99%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDeleteTimeseriesSchemaFileIT.java
copy integration-test/src/test/java/org/apache/iotdb/db/it/selectinto/{IoTDBSelectInto2IT.java => IoTDBSelectInto3IT.java} (85%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionInfoIT.java
rename integration-test/src/test/java/org/apache/iotdb/session/it/{IoTDBSessionInsertNulIT.java => IoTDBSessionInsertNullIT.java} (99%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSchemaTemplateIT.java
rename integration/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java => integration-test/src/test/java/org/apache/iotdb/session/it/pool/SessionPoolIT.java (82%)
create mode 100644 integration-test/src/test/resources/udf-example.jar
delete mode 100644 integration/src/test/java/org/apache/iotdb/session/template/TemplateUT.java
copy server/src/assembly/resources/conf/iotdb-datanode.properties => node-commons/src/assembly/resources/conf/iotdb-common.properties (78%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFM4.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/CQLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/CQLogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQuerySchemaCheckTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQueryService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQueryTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQueryTaskPoolManager.java
copy node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkBeingUsedException.java => server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileLogCorruptedException.java (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogReader.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetStorageGroupPlan.java => server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogSerializer.java (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogWriter.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/{IQueryExecution.java => config/metadata/template/DropSchemaTemplateTask.java} (51%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/DropSchemaTemplateStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/QueryHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/InfluxDBMetaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/MPPRestService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/ApiOriginFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/AuthorizationFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/BasicSecurityContext.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/User.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/UserCache.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/AuthorizationHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/ExceptionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/QueryDataSetHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/RequestValidationHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/GrafanaApiServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/PingApiServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/RestApiServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mqtt/PublishHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/PhysicalPlanConstructionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/PhysicalPlanValidationHandler.java
rename server/src/main/java/org/apache/iotdb/db/protocol/{mpprest => rest}/handler/StatementConstructionHandler.java (98%)
copy node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeStatus.java => server/src/main/java/org/apache/iotdb/db/query/control/SessionManagerMBean.java (76%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/SessionTimeoutManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/ClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/IClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/InternalClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/MqttClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/handler/BaseServerContextHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InfluxDBServiceImpl.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionFileNodeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionQueryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableResourceControlTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableRestartTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/InsertWithIDTableTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/QueryAlignedTimeseriesWithIDTableTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/QueryWithIDTableTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SchemaFileLogTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertRowPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertTabletMultiPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertTabletPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithValueFilterTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByFillDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByLevelDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/valuefilter/RawQueryWithValueFilterTest.java