You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/07/06 09:29:56 UTC
[iotdb] branch tsfile_name updated (8c812e827f -> 1ba3f11060)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch tsfile_name
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 8c812e827f Update filename when upgrading from old version (#6601)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/tsfile_name (1ba3f11060)
\
O -- O -- O (8c812e827f)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it.yml | 79 -
.github/workflows/cluster.yml | 52 +
.github/workflows/main-unix.yml | 3 +-
.github/workflows/main-win.yml | 14 +-
.github/workflows/sonar-coveralls.yml | 2 +-
.github/workflows/standalone-it-for-mpp.yml | 81 -
README.md | 18 +-
README_ZH.md | 17 +-
RELEASE_NOTES.md | 132 -
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 7 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 32 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 26 +-
checkstyle.xml | 30 +-
client-cpp/README.md | 2 +-
client-cpp/pom.xml | 4 +-
client-cpp/src/main/Session.cpp | 4 +-
client-cpp/src/main/Session.h | 8 +-
client-py/README.md | 236 -
client-py/SessionExample.py | 98 -
client-py/iotdb/Session.py | 314 +-
client-py/iotdb/dbapi/Connection.py | 91 -
client-py/iotdb/dbapi/Cursor.py | 288 -
client-py/iotdb/dbapi/Exceptions.py | 61 -
client-py/iotdb/dbapi/__init__.py | 26 -
client-py/iotdb/dbapi/tests/__init__.py | 17 -
client-py/iotdb/dbapi/tests/test_connection.py | 57 -
client-py/iotdb/dbapi/tests/test_cursor.py | 123 -
client-py/iotdb/sqlalchemy/IoTDBDialect.py | 136 -
.../iotdb/sqlalchemy/IoTDBIdentifierPreparer.py | 27 -
client-py/iotdb/sqlalchemy/IoTDBSQLCompiler.py | 243 -
client-py/iotdb/sqlalchemy/IoTDBTypeCompiler.py | 45 -
client-py/iotdb/sqlalchemy/__init__.py | 17 -
client-py/iotdb/sqlalchemy/tests/__init__.py | 17 -
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 92 -
client-py/iotdb/template/InternalNode.py | 41 -
client-py/iotdb/template/MeasurementNode.py | 56 -
client-py/iotdb/template/Template.py | 87 -
client-py/iotdb/template/TemplateNode.py | 47 -
client-py/iotdb/template/TemplateQueryType.py | 39 -
client-py/iotdb/template/__init__.py | 17 -
client-py/iotdb/tsfile/__init__.py | 17 -
client-py/iotdb/tsfile/common/__init__.py | 17 -
.../iotdb/tsfile/common/constant/TsFileConstant.py | 36 -
client-py/iotdb/tsfile/common/constant/__init__.py | 17 -
client-py/iotdb/tsfile/utils/Pair.py | 24 -
client-py/iotdb/tsfile/utils/ReadWriteIOUtils.py | 77 -
client-py/iotdb/tsfile/utils/__init__.py | 17 -
client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +-
client-py/requirements.txt | 5 +-
client-py/setup.py | 7 -
client-py/tests/test_dataframe.py | 2 -
client-py/tests/test_one_device.py | 1 -
client-py/tests/test_tablet.py | 2 -
client-py/tests/test_template.py | 195 -
client-py/tests/test_todf.py | 3 -
cluster/pom.xml | 228 +
cluster/src/assembly/cluster.xml | 35 +
.../resources/conf/iotdb-cluster.properties | 200 +
cluster/src/assembly/resources/sbin/add-node.bat | 133 +
cluster/src/assembly/resources/sbin/add-node.sh | 95 +
cluster/src/assembly/resources/sbin/nodetool.bat | 58 +
cluster/src/assembly/resources/sbin/nodetool.sh | 48 +
.../src/assembly/resources/sbin/remove-node.bat | 110 +
cluster/src/assembly/resources/sbin/remove-node.sh | 72 +
cluster/src/assembly/resources/sbin/start-node.bat | 136 +
cluster/src/assembly/resources/sbin/start-node.sh | 97 +
cluster/src/assembly/resources/sbin/stop-node.bat | 27 +
cluster/src/assembly/resources/sbin/stop-node.sh | 39 +
.../java/org/apache/iotdb/cluster/ClientMain.java | 469 ++
.../iotdb/cluster/ClusterFileFlushPolicy.java | 75 +
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 672 ++
.../apache/iotdb/cluster/ClusterIoTDBMBean.java | 36 +
.../cluster/ClusterIoTDBServerCommandLine.java | 94 +
.../apache/iotdb/cluster/RemoteTsFileResource.java | 150 +
.../apache/iotdb/cluster/client/BaseFactory.java | 54 +
.../iotdb/cluster/client/ClientCategory.java | 38 +
.../apache/iotdb/cluster/client/ClientManager.java | 223 +
.../iotdb/cluster/client/ClientPoolFactory.java | 101 +
.../iotdb/cluster/client/IClientManager.java | 35 +
.../cluster/client/async/AsyncBaseFactory.java | 68 +
.../cluster/client/async/AsyncDataClient.java | 218 +
.../cluster/client/async/AsyncMetaClient.java | 178 +
.../cluster/client/sync/SyncClientAdaptor.java | 527 ++
.../iotdb/cluster/client/sync/SyncDataClient.java | 154 +
.../iotdb/cluster/client/sync/SyncMetaClient.java | 144 +
.../apache/iotdb/cluster/config/ClusterConfig.java | 584 ++
.../iotdb/cluster/config/ClusterConstant.java | 144 +
.../iotdb/cluster/config/ClusterDescriptor.java | 418 ++
.../iotdb/cluster/config/ConsistencyLevel.java | 67 +
.../iotdb/cluster/coordinator/Coordinator.java | 807 +++
.../iotdb/cluster/exception/AddSelfException.java | 28 +
.../exception/BadSeedUrlFormatException.java | 30 +
.../exception/ChangeMembershipException.java | 28 +
.../exception/CheckConsistencyException.java | 37 +
.../exception/ConfigInconsistentException.java | 29 +
.../cluster/exception/EmptyIntervalException.java | 28 +
.../cluster/exception/EntryCompactedException.java | 30 +
.../exception/EntryUnavailableException.java | 28 +
.../GetEntriesWrongParametersException.java | 27 +
.../cluster/exception/LeaderUnknownException.java | 31 +
.../cluster/exception/LogExecutionException.java | 27 +
.../cluster/exception/MemberReadOnlyException.java | 33 +
.../cluster/exception/NoHeaderNodeException.java | 31 +
.../cluster/exception/NotInSameGroupException.java | 32 +
.../cluster/exception/NotManagedSlotException.java | 33 +
.../PartitionTableUnavailableException.java | 30 +
.../iotdb/cluster/exception/PullFileException.java | 34 +
.../cluster/exception/QueryTimeOutException.java | 27 +
.../cluster/exception/ReaderNotFoundException.java | 27 +
.../cluster/exception/RequestTimeOutException.java | 34 +
.../exception/SnapshotInstallationException.java | 37 +
.../exception/StartUpCheckFailureException.java | 31 +
.../exception/TruncateCommittedEntryException.java | 30 +
.../cluster/exception/UnknownLogTypeException.java | 28 +
.../exception/UnsupportedPlanException.java | 29 +
.../iotdb/cluster/log/CommitLogCallback.java | 48 +
.../apache/iotdb/cluster/log/CommitLogTask.java | 65 +
.../org/apache/iotdb/cluster/log/HardState.java | 114 +
.../java/org/apache/iotdb/cluster/log/Log.java | 145 +
.../org/apache/iotdb/cluster/log/LogApplier.java | 35 +
.../apache/iotdb/cluster/log/LogDispatcher.java | 461 ++
.../org/apache/iotdb/cluster/log/LogParser.java | 110 +
.../org/apache/iotdb/cluster/log/Snapshot.java | 75 +
.../iotdb/cluster/log/StableEntryManager.java | 61 +
.../cluster/log/applier/AsyncDataLogApplier.java | 302 +
.../iotdb/cluster/log/applier/BaseApplier.java | 263 +
.../iotdb/cluster/log/applier/DataLogApplier.java | 185 +
.../iotdb/cluster/log/applier/MetaLogApplier.java | 90 +
.../iotdb/cluster/log/catchup/CatchUpTask.java | 403 ++
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 350 +
.../cluster/log/catchup/SnapshotCatchUpTask.java | 159 +
.../iotdb/cluster/log/logtypes/AddNodeLog.java | 136 +
.../iotdb/cluster/log/logtypes/CloseFileLog.java | 124 +
.../cluster/log/logtypes/EmptyContentLog.java | 63 +
.../iotdb/cluster/log/logtypes/LargeTestLog.java | 78 +
.../cluster/log/logtypes/PhysicalPlanLog.java | 115 +
.../iotdb/cluster/log/logtypes/RemoveNodeLog.java | 131 +
.../cluster/log/manage/CommittedEntryManager.java | 301 +
.../manage/FilePartitionedSnapshotLogManager.java | 259 +
.../log/manage/MetaSingleSnapshotLogManager.java | 93 +
.../log/manage/PartitionedSnapshotLogManager.java | 137 +
.../iotdb/cluster/log/manage/RaftLogManager.java | 1035 +++
.../log/manage/UnCommittedEntryManager.java | 276 +
.../log/manage/serializable/LogManagerMeta.java | 143 +
.../serializable/SyncLogDequeSerializer.java | 1407 ++++
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 641 ++
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 342 +
.../cluster/log/snapshot/PartitionedSnapshot.java | 223 +
.../cluster/log/snapshot/PullSnapshotTask.java | 269 +
.../log/snapshot/PullSnapshotTaskDescriptor.java | 135 +
.../cluster/log/snapshot/SnapshotFactory.java | 28 +
.../cluster/log/snapshot/SnapshotInstaller.java | 33 +
.../log/snapshot/TimeseriesSchemaSnapshot.java | 31 +
.../iotdb/cluster/metadata/CSchemaProcessor.java | 1741 +++++
.../apache/iotdb/cluster/metadata/MetaPuller.java | 452 ++
.../cluster/partition/NodeAdditionResult.java | 37 +
.../iotdb/cluster/partition/NodeRemovalResult.java | 61 +
.../iotdb/cluster/partition/PartitionGroup.java | 109 +
.../iotdb/cluster/partition/PartitionTable.java | 154 +
.../partition/balancer/DefaultSlotBalancer.java | 121 +
.../cluster/partition/balancer/SlotBalancer.java | 43 +
.../iotdb/cluster/partition/slot/SlotManager.java | 402 ++
.../partition/slot/SlotNodeAdditionResult.java | 40 +
.../partition/slot/SlotNodeRemovalResult.java | 79 +
.../cluster/partition/slot/SlotPartitionTable.java | 611 ++
.../iotdb/cluster/partition/slot/SlotStrategy.java | 48 +
.../partition/slot/SlotTimePartitionFilter.java | 56 +
.../cluster/query/ClusterDataQueryExecutor.java | 325 +
.../cluster/query/ClusterPhysicalGenerator.java | 106 +
.../iotdb/cluster/query/ClusterPlanExecutor.java | 923 +++
.../iotdb/cluster/query/ClusterPlanRouter.java | 507 ++
.../apache/iotdb/cluster/query/ClusterPlanner.java | 35 +
.../iotdb/cluster/query/ClusterQueryRouter.java | 109 +
.../cluster/query/ClusterUDTFQueryExecutor.java | 103 +
.../iotdb/cluster/query/LocalQueryExecutor.java | 1066 +++
.../iotdb/cluster/query/RemoteQueryContext.java | 73 +
.../query/aggregate/ClusterAggregateExecutor.java | 107 +
.../cluster/query/aggregate/ClusterAggregator.java | 292 +
.../cluster/query/fill/ClusterFillExecutor.java | 104 +
.../cluster/query/fill/ClusterLinearFill.java | 80 +
.../cluster/query/fill/ClusterPreviousFill.java | 269 +
.../cluster/query/fill/PreviousFillArguments.java | 70 +
.../iotdb/cluster/query/filter/SlotSgFilter.java | 47 +
.../cluster/query/filter/SlotTsFileFilter.java | 69 +
.../groupby/ClusterGroupByNoVFilterDataSet.java | 61 +
.../groupby/ClusterGroupByVFilterDataSet.java | 75 +
.../query/groupby/MergeGroupByExecutor.java | 143 +
.../query/groupby/RemoteGroupByExecutor.java | 176 +
.../query/last/ClusterLastQueryExecutor.java | 296 +
.../cluster/query/manage/ClusterQueryManager.java | 129 +
.../query/manage/ClusterSessionManager.java | 138 +
.../cluster/query/manage/QueryCoordinator.java | 66 +
.../cluster/query/reader/ClusterReaderFactory.java | 1229 ++++
.../cluster/query/reader/ClusterTimeGenerator.java | 217 +
.../iotdb/cluster/query/reader/DataSourceInfo.java | 272 +
.../iotdb/cluster/query/reader/EmptyReader.java | 172 +
.../reader/ManagedDescPriorityMergeReader.java | 96 +
.../query/reader/ManagedPriorityMergeReader.java | 94 +
.../cluster/query/reader/MergedReaderByTime.java | 47 +
.../reader/RemoteSeriesReaderByTimestamp.java | 122 +
.../query/reader/RemoteSimpleSeriesReader.java | 167 +
.../query/reader/mult/AbstractMultPointReader.java | 70 +
.../mult/AssignPathAscPriorityMergeReader.java | 49 +
.../mult/AssignPathDescPriorityMergeReader.java | 49 +
.../reader/mult/AssignPathManagedMergeReader.java | 121 +
.../mult/IAssignPathPriorityMergeReader.java | 47 +
.../query/reader/mult/IMultBatchReader.java | 31 +
.../cluster/query/reader/mult/MultBatchReader.java | 74 +
.../query/reader/mult/MultDataSourceInfo.java | 270 +
.../cluster/query/reader/mult/MultElement.java | 49 +
.../cluster/query/reader/mult/MultEmptyReader.java | 52 +
.../reader/mult/MultSeriesRawDataPointReader.java | 55 +
.../query/reader/mult/RemoteMultSeriesReader.java | 227 +
.../iotdb/cluster/server/ClusterRPCService.java | 110 +
.../cluster/server/ClusterRPCServiceMBean.java | 35 +
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 47 +
.../iotdb/cluster/server/HardLinkCleaner.java | 110 +
.../apache/iotdb/cluster/server/NodeCharacter.java | 28 +
.../cluster/server/PullSnapshotHintService.java | 179 +
.../org/apache/iotdb/cluster/server/Response.java | 63 +
.../iotdb/cluster/server/StoppedMemberManager.java | 160 +
.../server/basic/ClusterServiceProvider.java | 95 +
.../server/clusterinfo/ClusterInfoServer.java | 90 +
.../server/clusterinfo/ClusterInfoServerMBean.java | 22 +
.../server/clusterinfo/ClusterInfoServiceImpl.java | 71 +
.../ClusterInfoServiceThriftHandler.java | 55 +
.../handlers/caller/AppendGroupEntryHandler.java | 157 +
.../handlers/caller/AppendNodeEntryHandler.java | 187 +
.../server/handlers/caller/ElectionHandler.java | 167 +
.../server/handlers/caller/GenericHandler.java | 94 +
.../caller/GetChildNodeNextLevelHandler.java | 59 +
.../caller/GetChildNodeNextLevelPathHandler.java | 60 +
.../server/handlers/caller/GetDevicesHandler.java | 60 +
.../handlers/caller/GetNodesListHandler.java | 59 +
.../caller/GetTimeseriesSchemaHandler.java | 59 +
.../server/handlers/caller/HeartbeatHandler.java | 156 +
.../server/handlers/caller/JoinClusterHandler.java | 65 +
.../server/handlers/caller/LogCatchUpHandler.java | 115 +
.../handlers/caller/LogCatchUpInBatchHandler.java | 111 +
.../server/handlers/caller/NodeStatusHandler.java | 59 +
.../handlers/caller/PreviousFillHandler.java | 101 +
.../caller/PullMeasurementSchemaHandler.java | 78 +
.../handlers/caller/PullSnapshotHandler.java | 81 +
.../caller/PullTimeseriesSchemaHandler.java | 73 +
.../handlers/caller/ShowTimeSeriesHandler.java | 121 +
.../handlers/caller/SnapshotCatchUpHandler.java | 61 +
.../server/handlers/caller/package-info.java | 21 +
.../handlers/forwarder/ForwardPlanHandler.java | 68 +
.../server/heartbeat/DataHeartbeatThread.java | 68 +
.../cluster/server/heartbeat/HeartbeatThread.java | 443 ++
.../server/heartbeat/MetaHeartbeatThread.java | 96 +
.../cluster/server/member/DataGroupMember.java | 1164 ++++
.../server/member/DataGroupMemberMBean.java | 25 +
.../cluster/server/member/MetaGroupMember.java | 1954 ++++++
.../server/member/MetaGroupMemberMBean.java | 35 +
.../iotdb/cluster/server/member/RaftMember.java | 2219 +++++++
.../cluster/server/member/RaftMemberMBean.java | 53 +
.../iotdb/cluster/server/member/package-info.java | 24 +
.../iotdb/cluster/server/monitor/NodeReport.java | 268 +
.../iotdb/cluster/server/monitor/NodeStatus.java | 118 +
.../cluster/server/monitor/NodeStatusManager.java | 183 +
.../apache/iotdb/cluster/server/monitor/Peer.java | 70 +
.../apache/iotdb/cluster/server/monitor/Timer.java | 337 +
.../server/raft/AbstractDataRaftService.java | 54 +
.../server/raft/AbstractMetaRaftService.java | 52 +
.../cluster/server/raft/AbstractRaftService.java | 76 +
.../server/raft/DataRaftHeartBeatService.java | 62 +
.../server/raft/DataRaftHeartBeatServiceMBean.java | 22 +
.../iotdb/cluster/server/raft/DataRaftService.java | 59 +
.../cluster/server/raft/DataRaftServiceMBean.java | 22 +
.../server/raft/MetaRaftHeartBeatService.java | 62 +
.../server/raft/MetaRaftHeartBeatServiceMBean.java | 22 +
.../iotdb/cluster/server/raft/MetaRaftService.java | 59 +
.../cluster/server/raft/MetaRaftServiceMBean.java | 22 +
.../cluster/server/raft/RaftServiceHandler.java | 43 +
.../cluster/server/service/BaseAsyncService.java | 176 +
.../cluster/server/service/BaseSyncService.java | 181 +
.../cluster/server/service/DataAsyncService.java | 503 ++
.../cluster/server/service/DataGroupEngine.java | 510 ++
.../server/service/DataGroupEngineMBean.java | 31 +
.../server/service/DataGroupServiceImpls.java | 749 +++
.../cluster/server/service/DataSyncService.java | 458 ++
.../cluster/server/service/MetaAsyncService.java | 255 +
.../cluster/server/service/MetaSyncService.java | 253 +
.../iotdb/cluster/server/service/package-info.java | 24 +
.../apache/iotdb/cluster/utils/ClientUtils.java | 66 +
.../iotdb/cluster/utils/ClusterConsistent.java | 30 +
.../apache/iotdb/cluster/utils/ClusterNode.java | 86 +
.../iotdb/cluster/utils/ClusterQueryUtils.java | 84 +
.../apache/iotdb/cluster/utils/ClusterUtils.java | 376 ++
.../org/apache/iotdb/cluster/utils/IOUtils.java | 88 +
.../iotdb/cluster/utils/NodeSerializeUtils.java | 92 +
.../apache/iotdb/cluster/utils/PartitionUtils.java | 184 +
.../apache/iotdb/cluster/utils/PlanSerializer.java | 59 +
.../apache/iotdb/cluster/utils/StatusUtils.java | 228 +
.../cluster/utils/nodetool/ClusterMonitor.java | 323 +
.../utils/nodetool/ClusterMonitorMBean.java | 85 +
.../iotdb/cluster/utils/nodetool/NodeTool.java | 52 +
.../iotdb/cluster/utils/nodetool/Printer.java | 38 +
.../cluster/utils/nodetool/function/Header.java | 60 +
.../cluster/utils/nodetool/function/LogView.java | 88 +
.../cluster/utils/nodetool/function/Migration.java | 59 +
.../utils/nodetool/function/NodeToolCmd.java | 145 +
.../cluster/utils/nodetool/function/Partition.java | 102 +
.../cluster/utils/nodetool/function/Ring.java | 50 +
.../cluster/utils/nodetool/function/Slot.java | 63 +
.../cluster/utils/nodetool/function/Status.java | 63 +
.../iotdb/cluster/client/BaseClientTest.java | 156 +
.../iotdb/cluster/client/ClientManagerTest.java | 212 +
.../cluster/client/ClientPoolFactoryTest.java | 293 +
.../iotdb/cluster/client/MockClientManager.java | 47 +
.../cluster/client/async/AsyncDataClientTest.java | 79 +
.../cluster/client/async/AsyncMetaClientTest.java | 78 +
.../cluster/client/sync/SyncClientAdaptorTest.java | 464 ++
.../cluster/client/sync/SyncDataClientTest.java | 110 +
.../cluster/client/sync/SyncMetaClientTest.java | 110 +
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 176 +
.../iotdb/cluster/common/TestAsyncClient.java | 53 +
.../iotdb/cluster/common/TestAsyncDataClient.java | 304 +
.../iotdb/cluster/common/TestAsyncMetaClient.java | 50 +
.../iotdb/cluster/common/TestDataGroupMember.java | 45 +
.../apache/iotdb/cluster/common/TestException.java | 27 +
.../org/apache/iotdb/cluster/common/TestLog.java | 67 +
.../iotdb/cluster/common/TestLogApplier.java | 66 +
.../iotdb/cluster/common/TestLogManager.java | 39 +
.../cluster/common/TestManagedSeriesReader.java | 96 +
.../iotdb/cluster/common/TestMetaGroupMember.java | 39 +
.../cluster/common/TestPartitionedLogManager.java | 54 +
.../apache/iotdb/cluster/common/TestSnapshot.java | 110 +
.../iotdb/cluster/common/TestSyncClient.java | 47 +
.../org/apache/iotdb/cluster/common/TestUtils.java | 439 ++
.../cluster/integration/BaseSingleNodeTest.java | 90 +
.../iotdb/cluster/integration/SingleNodeTest.java | 131 +
.../iotdb/cluster/log/CommitLogCallbackTest.java | 53 +
.../iotdb/cluster/log/CommitLogTaskTest.java | 78 +
.../apache/iotdb/cluster/log/HardStateTest.java | 49 +
.../iotdb/cluster/log/LogDispatcherTest.java | 269 +
.../apache/iotdb/cluster/log/LogParserTest.java | 122 +
.../log/applier/AsyncDataLogApplierTest.java | 174 +
.../cluster/log/applier/DataLogApplierTest.java | 499 ++
.../cluster/log/applier/MetaLogApplierTest.java | 135 +
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 398 ++
.../cluster/log/catchup/LogCatchUpTaskTest.java | 301 +
.../log/catchup/SnapshotCatchUpTaskTest.java | 282 +
.../cluster/log/logtypes/SerializeLogTest.java | 146 +
.../log/manage/CommittedEntryManagerTest.java | 625 ++
.../FilePartitionedSnapshotLogManagerTest.java | 117 +
.../manage/MetaSingleSnapshotLogManagerTest.java | 93 +
.../cluster/log/manage/RaftLogManagerTest.java | 1889 ++++++
.../log/manage/UnCommittedEntryManagerTest.java | 695 ++
.../serializable/SyncLogDequeSerializerTest.java | 612 ++
.../cluster/log/snapshot/DataSnapshotTest.java | 196 +
.../cluster/log/snapshot/FileSnapshotTest.java | 310 +
.../log/snapshot/MetaSimpleSnapshotTest.java | 346 +
.../log/snapshot/PartitionedSnapshotTest.java | 204 +
.../snapshot/PullSnapshotTaskDescriptorTest.java | 64 +
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 337 +
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 132 +
.../cluster/partition/SchemaProcessorWhiteBox.java | 54 +
.../iotdb/cluster/partition/SlotManagerTest.java | 155 +
.../cluster/partition/SlotPartitionTableTest.java | 546 ++
.../apache/iotdb/cluster/query/BaseQueryTest.java | 125 +
.../query/ClusterAggregateExecutorTest.java | 145 +
.../query/ClusterDataQueryExecutorTest.java | 240 +
.../query/ClusterPhysicalGeneratorTest.java | 72 +
.../cluster/query/ClusterPlanExecutorTest.java | 112 +
.../iotdb/cluster/query/ClusterPlannerTest.java | 55 +
.../cluster/query/ClusterQueryRouterTest.java | 324 +
.../query/ClusterUDTFQueryExecutorTest.java | 121 +
.../iotdb/cluster/query/LoadConfigurationTest.java | 124 +
.../query/fill/ClusterFillExecutorTest.java | 170 +
.../ClusterGroupByNoVFilterDataSetTest.java | 90 +
.../groupby/ClusterGroupByVFilterDataSetTest.java | 102 +
.../query/groupby/MergeGroupByExecutorTest.java | 117 +
.../query/groupby/RemoteGroupByExecutorTest.java | 171 +
.../query/last/ClusterLastQueryExecutorTest.java | 95 +
.../query/manage/ClusterQueryManagerTest.java | 182 +
.../cluster/query/manage/QueryCoordinatorTest.java | 121 +
.../query/reader/ClusterReaderFactoryTest.java | 85 +
.../query/reader/ClusterTimeGeneratorTest.java | 134 +
.../cluster/query/reader/DatasourceInfoTest.java | 112 +
.../reader/RemoteSeriesReaderByTimestampTest.java | 269 +
.../query/reader/RemoteSimpleSeriesReaderTest.java | 243 +
.../mult/AssignPathManagedMergeReaderTest.java | 208 +
.../mult/MultSeriesRawDataPointReaderTest.java | 67 +
.../reader/mult/RemoteMultSeriesReaderTest.java | 346 +
.../server/clusterinfo/ClusterInfoServerTest.java | 99 +
.../clusterinfo/ClusterInfoServiceImplTest.java | 100 +
.../caller/AppendGroupEntryHandlerTest.java | 188 +
.../caller/AppendNodeEntryHandlerTest.java | 175 +
.../handlers/caller/ElectionHandlerTest.java | 178 +
.../server/handlers/caller/GenericHandlerTest.java | 58 +
.../handlers/caller/HeartbeatHandlerTest.java | 121 +
.../handlers/caller/JoinClusterHandlerTest.java | 67 +
.../handlers/caller/LogCatchUpHandlerTest.java | 128 +
.../caller/PullMeasurementSchemaHandlerTest.java | 92 +
.../handlers/caller/PullSnapshotHandlerTest.java | 84 +
.../caller/SnapshotCatchUpHandlerTest.java | 58 +
.../handlers/forwarder/ForwardPlanHandlerTest.java | 59 +
.../server/heartbeat/DataHeartbeatThreadTest.java | 160 +
.../server/heartbeat/HeartbeatThreadTest.java | 244 +
.../server/heartbeat/MetaHeartbeatThreadTest.java | 244 +
.../iotdb/cluster/server/member/BaseMember.java | 328 +
.../cluster/server/member/DataGroupMemberTest.java | 1255 ++++
.../cluster/server/member/MetaGroupMemberTest.java | 1488 +++++
.../cluster/server/member/RaftMemberTest.java | 246 +
.../org/apache/iotdb/cluster/utils/Constants.java | 24 +
.../cluster/utils/CreateTemplatePlanUtil.java | 74 +
.../iotdb/cluster/utils/SerializeUtilTest.java | 210 +
cluster/src/test/resources/logback-test.xml | 41 +
.../resources/node1conf/iotdb-cluster.properties | 37 +
.../resources/node1conf/iotdb-engine.properties | 30 +
.../src/test/resources/node1conf/iotdb-metric.yml | 21 +
cluster/src/test/resources/node1conf/logback.xml | 282 +
.../resources/node2conf/iotdb-cluster.properties | 37 +
.../resources/node2conf/iotdb-engine.properties | 30 +
.../src/test/resources/node2conf/iotdb-metric.yml | 21 +
cluster/src/test/resources/node2conf/logback.xml | 282 +
.../resources/node3conf/iotdb-cluster.properties | 37 +
.../resources/node3conf/iotdb-engine.properties | 30 +
.../src/test/resources/node3conf/iotdb-metric.yml | 21 +
cluster/src/test/resources/node3conf/logback.xml | 282 +
confignode/pom.xml | 44 +-
confignode/src/assembly/confignode.xml | 4 -
.../src/assembly/resources/conf/confignode-env.bat | 8 +-
.../resources/conf/iotdb-confignode.properties | 93 +-
confignode/src/assembly/resources/conf/logback.xml | 2 +-
.../assembly/resources/sbin/remove-confignode.sh | 79 -
.../assembly/resources/sbin/stop-confignode.bat | 10 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 6 +-
.../client/AsyncConfigNodeClientPool.java | 72 -
.../confignode/client/AsyncDataNodeClientPool.java | 65 +-
.../client/ConfigNodeClientPoolFactory.java | 4 +-
.../client/SyncConfigNodeClientPool.java | 119 +-
.../confignode/client/SyncDataNodeClientPool.java | 43 +-
.../handlers/ConfigNodeHeartbeatHandler.java | 57 -
.../client/handlers/DataNodeHeartbeatHandler.java | 81 -
.../confignode/client/handlers/FlushHandler.java | 66 -
.../client/handlers/FunctionManagementHandler.java | 4 +-
.../client/handlers/HeartbeatHandler.java | 49 +
.../confignode/client/handlers/SetTTLHandler.java | 58 -
.../iotdb/confignode/conf/ConfigNodeConf.java | 451 ++
.../iotdb/confignode/conf/ConfigNodeConfig.java | 431 --
.../iotdb/confignode/conf/ConfigNodeConstant.java | 8 +
.../confignode/conf/ConfigNodeDescriptor.java | 73 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 104 -
.../confignode/conf/ConfigNodeStartupCheck.java | 297 +-
.../confignode/conf/SystemPropertiesUtils.java | 270 -
.../consensus/request/ConfigPhysicalPlan.java | 219 -
.../consensus/request/ConfigPhysicalPlanType.java | 70 -
.../consensus/request/ConfigRequest.java | 212 +
.../consensus/request/ConfigRequestType.java | 65 +
.../consensus/request/auth/AuthorPlan.java | 256 -
.../consensus/request/auth/AuthorReq.java | 248 +
.../request/read/CountStorageGroupPlan.java | 88 -
.../request/read/CountStorageGroupReq.java | 86 +
.../request/read/GetDataNodeInfoPlan.java | 70 -
.../consensus/request/read/GetDataNodeInfoReq.java | 68 +
.../request/read/GetDataPartitionPlan.java | 153 -
.../request/read/GetDataPartitionReq.java | 146 +
.../request/read/GetNodePathsPartitionPlan.java | 84 -
.../request/read/GetNodePathsPartitionReq.java | 83 +
.../request/read/GetOrCreateDataPartitionPlan.java | 28 -
.../request/read/GetOrCreateDataPartitionReq.java | 28 +
.../read/GetOrCreateSchemaPartitionPlan.java | 28 -
.../read/GetOrCreateSchemaPartitionReq.java | 28 +
.../request/read/GetRegionInfoListPlan.java | 62 -
.../request/read/GetSchemaPartitionPlan.java | 105 -
.../request/read/GetSchemaPartitionReq.java | 103 +
.../request/read/GetStorageGroupPlan.java | 34 -
.../consensus/request/read/GetStorageGroupReq.java | 34 +
.../request/write/ActivateDataNodePlan.java | 71 -
.../write/AdjustMaxRegionGroupCountPlan.java | 89 -
.../request/write/ApplyConfigNodePlan.java | 73 -
.../request/write/ApplyConfigNodeReq.java | 71 +
.../request/write/CreateDataPartitionPlan.java | 99 -
.../request/write/CreateDataPartitionReq.java | 130 +
.../request/write/CreateFunctionPlan.java | 86 -
.../consensus/request/write/CreateFunctionReq.java | 85 +
.../request/write/CreateRegionGroupsPlan.java | 102 -
.../consensus/request/write/CreateRegionsReq.java | 98 +
.../request/write/CreateSchemaPartitionPlan.java | 101 -
.../request/write/CreateSchemaPartitionReq.java | 100 +
.../request/write/DeleteProcedurePlan.java | 69 -
.../request/write/DeleteProcedureReq.java | 68 +
.../consensus/request/write/DeleteRegionsPlan.java | 93 -
.../consensus/request/write/DeleteRegionsReq.java | 79 +
.../request/write/DeleteStorageGroupPlan.java | 70 -
.../request/write/DeleteStorageGroupReq.java | 69 +
.../consensus/request/write/DropFunctionPlan.java | 57 -
.../consensus/request/write/DropFunctionReq.java | 56 +
.../request/write/PreDeleteStorageGroupPlan.java | 87 -
.../request/write/PreDeleteStorageGroupReq.java | 86 +
.../request/write/RegisterDataNodePlan.java | 71 -
.../request/write/RegisterDataNodeReq.java | 69 +
.../request/write/RemoveConfigNodePlan.java | 77 -
.../write/SetDataReplicationFactorPlan.java | 81 -
.../request/write/SetDataReplicationFactorReq.java | 80 +
.../write/SetSchemaReplicationFactorPlan.java | 81 -
.../write/SetSchemaReplicationFactorReq.java | 80 +
.../request/write/SetStorageGroupPlan.java | 72 -
.../request/write/SetStorageGroupReq.java | 71 +
.../consensus/request/write/SetTTLPlan.java | 80 -
.../consensus/request/write/SetTTLReq.java | 79 +
.../write/SetTimePartitionIntervalPlan.java | 81 -
.../request/write/SetTimePartitionIntervalReq.java | 80 +
.../request/write/UpdateProcedurePlan.java | 74 -
.../request/write/UpdateProcedureReq.java | 73 +
.../consensus/response/DataNodeInfosResp.java | 11 -
.../consensus/response/DataPartitionResp.java | 77 +-
.../consensus/response/RegionInfoListResp.java | 49 -
.../response/SchemaNodeManagementResp.java | 48 +-
.../consensus/response/SchemaPartitionResp.java | 57 +-
.../statemachine/PartitionRegionStateMachine.java | 36 +-
.../confignode/exception/AddPeerException.java | 28 -
.../exception/StorageGroupNotExistsException.java | 26 -
.../confignode/exception/TimeoutException.java | 26 -
.../physical/UnknownPhysicalPlanTypeException.java | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 274 +-
.../iotdb/confignode/manager/ConfigManager.java | 558 +-
.../iotdb/confignode/manager/ConsensusManager.java | 185 +-
.../apache/iotdb/confignode/manager/IManager.java | 267 -
.../apache/iotdb/confignode/manager/Manager.java | 225 +
.../iotdb/confignode/manager/NodeManager.java | 254 +-
.../iotdb/confignode/manager/PartitionManager.java | 581 +-
.../confignode/manager/PermissionManager.java | 62 +-
.../iotdb/confignode/manager/ProcedureManager.java | 31 +-
.../iotdb/confignode/manager/UDFManager.java | 46 +-
.../iotdb/confignode/manager/load/LoadManager.java | 403 +-
.../manager/load/balancer/PartitionBalancer.java | 71 -
.../manager/load/balancer/RegionBalancer.java | 62 +-
.../manager/load/balancer/RouteBalancer.java | 66 -
.../load/balancer/SeriesPartitionSlotBalancer.java | 21 +
.../balancer/allocator/CopySetRegionAllocator.java | 168 +
.../load/balancer/allocator/IRegionAllocator.java | 44 +
.../partition/GreedyPartitionAllocator.java | 124 -
.../balancer/partition/IPartitionAllocator.java | 53 -
.../balancer/region/CopySetRegionAllocator.java | 159 -
.../load/balancer/region/IRegionAllocator.java | 48 -
.../manager/load/balancer/router/IRouter.java | 43 -
.../manager/load/balancer/router/LeaderRouter.java | 94 -
.../balancer/router/LoadScoreGreedyRouter.java | 80 -
.../load/heartbeat/ConfigNodeHeartbeatCache.java | 97 -
.../load/heartbeat/DataNodeHeartbeatCache.java | 104 -
.../manager/load/heartbeat/HeartbeatCache.java | 51 +
.../manager/load/heartbeat/HeartbeatPackage.java | 1 -
.../manager/load/heartbeat/HeartbeatWindow.java | 51 +
.../load/heartbeat/IHeartbeatStatistic.java | 19 +-
.../manager/load/heartbeat/IRegionGroupCache.java | 37 -
.../manager/load/heartbeat/RegionGroupCache.java | 47 -
.../confignode/partition/DataPartitionRule.java | 50 +
.../iotdb/confignode/persistence/AuthorInfo.java | 59 +-
.../confignode/persistence/ClusterSchemaInfo.java | 300 +-
.../iotdb/confignode/persistence/NodeInfo.java | 250 +-
.../confignode/persistence/PartitionInfo.java | 645 ++
.../confignode/persistence/ProcedureInfo.java | 12 +-
.../iotdb/confignode/persistence/UDFInfo.java | 12 +-
.../persistence/executor/ConfigPlanExecutor.java | 318 -
.../executor/ConfigRequestExecutor.java | 310 +
.../persistence/partition/PartitionInfo.java | 762 ---
.../persistence/partition/RegionGroup.java | 94 -
.../partition/StorageGroupPartitionTable.java | 475 --
.../procedure/CompletedProcedureRecycler.java | 3 +
.../confignode/procedure/InternalProcedure.java | 3 +
.../iotdb/confignode/procedure/Procedure.java | 47 +-
.../confignode/procedure/ProcedureExecutor.java | 12 +
.../procedure/StateMachineProcedure.java | 9 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 83 +-
.../procedure/impl/AddConfigNodeProcedure.java | 193 -
.../impl/DeleteStorageGroupProcedure.java | 20 +-
.../procedure/state/AddConfigNodeState.java | 27 -
.../procedure/store/ConfigProcedureStore.java | 16 +-
.../procedure/store/ProcedureFactory.java | 9 +-
.../confignode/procedure/store/ProcedureWAL.java | 12 +-
.../iotdb/confignode/service/ConfigNode.java | 212 +-
.../confignode/service/ConfigNodeCommandLine.java | 11 +-
.../service/thrift/ConfigNodeRPCService.java | 12 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 277 +-
.../iotdb/confignode/cli/TemporaryClientDemo.java | 76 +
.../request/ConfigPhysicalPlanSerDeTest.java | 600 --
.../consensus/request/ConfigRequestSerDeTest.java | 636 ++
.../hash/DeviceGroupHashExecutorManualTest.java | 2 +-
.../confignode/persistence/AuthorInfoTest.java | 180 +-
.../persistence/ClusterSchemaInfoTest.java | 12 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 22 +-
.../confignode/persistence/PartitionInfoTest.java | 194 +-
.../confignode/procedure/entity/IncProcedure.java | 8 +-
.../procedure/entity/SleepProcedure.java | 8 +-
.../procedure/entity/StuckSTMProcedure.java | 9 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 158 +-
.../confignode1conf/iotdb-confignode.properties | 6 +-
.../resources/confignode1conf/iotdb-metric.yml | 53 -
.../confignode2conf/iotdb-confignode.properties | 6 +-
.../resources/confignode2conf/iotdb-metric.yml | 53 -
.../confignode3conf/iotdb-confignode.properties | 6 +-
.../resources/confignode3conf/iotdb-metric.yml | 53 -
consensus/pom.xml | 67 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 11 +-
.../org/apache/iotdb/consensus/IConsensus.java | 2 -
.../org/apache/iotdb/consensus/common/Peer.java | 7 +-
.../common/request/ByteBufferConsensusRequest.java | 4 +-
.../common/request/IConsensusRequest.java | 15 +-
.../common/request/IndexedConsensusRequest.java | 19 +-
.../iotdb/consensus/config/ConsensusConfig.java | 97 -
.../iotdb/consensus/config/MultiLeaderConfig.java | 299 -
.../apache/iotdb/consensus/config/RatisConfig.java | 695 --
.../multileader/MultiLeaderConsensus.java | 49 +-
.../multileader/MultiLeaderServerImpl.java | 89 +-
.../multileader/client/DispatchLogHandler.java | 7 +-
.../client/MultiLeaderConsensusClientPool.java | 16 +-
.../conf/MultiLeaderConsensusConfig.java | 40 +
.../multileader/logdispatcher/IndexController.java | 67 +-
.../multileader/logdispatcher/LogDispatcher.java | 167 +-
.../multileader/logdispatcher/SyncStatus.java | 8 +-
.../multileader/service/MultiLeaderRPCService.java | 27 +-
.../service/MultiLeaderRPCServiceProcessor.java | 59 +-
.../multileader/wal/ConsensusReqReader.java | 6 +-
.../multileader/wal/GetConsensusReqReaderPlan.java | 5 +-
.../ratis/ApplicationStateMachineProxy.java | 10 +-
.../ratis/FileInfoWithDelayedMd5Computing.java | 75 -
.../apache/iotdb/consensus/ratis/RatisClient.java | 49 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 76 +-
.../iotdb/consensus/ratis/RequestMessage.java | 18 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 65 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 65 -
.../consensus/standalone/StandAloneConsensus.java | 23 +-
.../consensus/standalone/StandAloneServerImpl.java | 2 -
.../apache/iotdb/consensus/EmptyStateMachine.java | 53 -
.../multileader/MultiLeaderConsensusTest.java | 211 +-
.../iotdb/consensus/multileader/RecoveryTest.java | 96 -
.../logdispatcher/IndexControllerTest.java | 38 +-
.../multileader/logdispatcher/SyncStatusTest.java | 87 +-
.../multileader/util/FakeConsensusReqReader.java | 111 -
.../consensus/multileader/util/RequestSets.java | 55 -
.../consensus/multileader/util/TestEntry.java | 74 -
.../multileader/util/TestStateMachine.java | 93 -
.../iotdb/consensus/ratis/RatisConsensusTest.java | 128 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 11 +-
.../consensus/standalone/EmptyStateMachine.java | 54 +
.../iotdb/consensus/standalone/RecoveryTest.java | 8 +-
.../standalone/StandAloneConsensusTest.java | 16 +-
distribution/pom.xml | 6 +-
distribution/src/assembly/all.xml | 20 +-
distribution/src/assembly/confignode.xml | 4 -
distribution/src/assembly/datanode.xml | 88 -
distribution/src/assembly/server.xml | 88 +
docker/src/main/Dockerfile-cluster | 44 +
docker/src/main/Dockerfile-single | 4 +-
docker/src/main/Dockerfile-single-influxdb | 6 +-
docker/src/main/Dockerfile-single-tc | 4 +-
docs/Development/ContributeGuide.md | 14 +
docs/Development/HowtoContributeCode.md | 160 -
docs/Download/README.md | 58 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 8 +-
docs/UserGuide/API/Programming-MQTT.md | 15 +-
.../UserGuide/API/Programming-Python-Native-API.md | 236 -
.../Administration-Management/Administration.md | 298 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 101 -
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 293 +
docs/UserGuide/Cluster/Cluster-Setup.md | 406 +-
docs/UserGuide/Data-Concept/Data-Type.md | 2 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Ecosystem Integration/Grafana Plugin.md | 21 +-
.../Ecosystem Integration/Writing Data on HDFS.md | 2 +-
.../Integration-Test-refactoring-tutorial.md | 311 +-
docs/UserGuide/Maintenance-Tools/JMX-Tool.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 168 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 107 +-
.../Maintenance-Tools/Monitor-and-Log-Tools.md | 2 +-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 4 +-
docs/UserGuide/Maintenance-Tools/Watermark-Tool.md | 4 +-
.../Operate-Metadata/Auto-Create-MetaData.md | 28 +-
docs/UserGuide/Process-Data/Triggers.md | 110 +-
.../Process-Data/UDF-User-Defined-Function.md | 60 +-
docs/UserGuide/Query-Data/Query-Filter.md | 25 +-
docs/UserGuide/Query-Data/Select-Expression.md | 39 +-
docs/UserGuide/Query-Data/Without-Null.md | 19 +
docs/UserGuide/QuickStart/QuickStart.md | 10 +-
docs/UserGuide/QuickStart/ServerFileList.md | 4 +-
docs/UserGuide/Reference/Config-Manual.md | 1145 ++++
.../Reference/ConfigNode-Config-Manual.md | 283 -
docs/UserGuide/Reference/DataNode-Config-Manual.md | 1261 ----
docs/UserGuide/Reference/Keywords.md | 24 +
docs/UserGuide/Reference/Syntax-Conventions.md | 24 +-
docs/UserGuide/UDF-Library/String-Processing.md | 656 +-
.../Write-And-Delete-Data/Load-External-Tsfile.md | 2 +-
docs/zh/Development/HowtoContributeCode.md | 154 -
docs/zh/Download/README.md | 49 +-
.../UserGuide/API/Programming-Java-Native-API.md | 8 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 13 +-
.../UserGuide/API/Programming-Python-Native-API.md | 232 -
.../Administration-Management/Administration.md | 297 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 102 -
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 298 +
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 394 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 2 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Ecosystem Integration/Grafana Plugin.md | 18 +-
.../Ecosystem Integration/Writing Data on HDFS.md | 2 +-
.../Integration-Test-refactoring-tutorial.md | 316 +-
docs/zh/UserGuide/Maintenance-Tools/JMX-Tool.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 164 -
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 105 +-
.../Maintenance-Tools/Monitor-and-Log-Tools.md | 2 +-
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 6 +-
.../UserGuide/Maintenance-Tools/Watermark-Tool.md | 4 +-
.../Operate-Metadata/Auto-Create-MetaData.md | 30 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 113 +-
.../Process-Data/UDF-User-Defined-Function.md | 63 +-
docs/zh/UserGuide/Query-Data/Query-Filter.md | 30 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 38 +-
docs/zh/UserGuide/Query-Data/Without-Null.md | 19 +
docs/zh/UserGuide/QuickStart/QuickStart.md | 4 +-
docs/zh/UserGuide/QuickStart/ServerFileList.md | 4 +-
docs/zh/UserGuide/Reference/Config-Manual.md | 1724 +++++
.../Reference/ConfigNode-Config-Manual.md | 278 -
.../UserGuide/Reference/DataNode-Config-Manual.md | 1810 -----
docs/zh/UserGuide/Reference/Keywords.md | 24 +
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 29 +-
docs/zh/UserGuide/UDF-Library/String-Processing.md | 652 +-
.../Write-And-Delete-Data/Load-External-Tsfile.md | 2 +-
example/client-cpp-example/README.md | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 161 -
example/mqtt-customize/README.md | 4 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
example/mqtt/README.md | 2 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 7 -
example/rest-java-example/pom.xml | 49 -
.../main/java/org/apache/iotdb/HttpExample.java | 141 -
.../main/java/org/apache/iotdb/HttpsExample.java | 144 -
.../src/main/java/org/apache/iotdb/SSLClient.java | 83 -
.../iotdb/SyntaxConventionRelatedExample.java | 145 -
.../java/org/apache/iotdb/udf/UDTFExample.java | 22 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 1 -
.../iotdb/web/grafana/conf/MyConfiguration.java | 15 +-
.../web/grafana/interceptor/LoginInterceptor.java | 61 -
.../Apache IoTDB Dashboard v0.13.1.json | 0
.../Apache IoTDB Dashboard v0.14.0.json | 1527 +++++
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 1172 ----
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 1536 -----
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 1519 -----
grafana-plugin/backend-compile.sh | 1 +
grafana-plugin/pkg/plugin/plugin.go | 4 +-
grafana-plugin/src/ConfigEditor.tsx | 1 -
grafana-plugin/src/QueryEditor.tsx | 52 +-
grafana-plugin/src/datasource.ts | 2 +-
grafana-plugin/src/types.ts | 4 +-
integration-test/README.md | 88 -
integration-test/checkstyle.xml | 42 -
integration-test/import-control.xml | 35 -
integration-test/pom.xml | 243 -
integration-test/src/assembly/mpp-share.xml | 33 -
integration-test/src/assembly/mpp-test.xml | 74 -
.../iotdb/db/query/udf/example/Accumulator.java | 102 -
.../apache/iotdb/db/query/udf/example/Adder.java | 92 -
.../apache/iotdb/db/query/udf/example/Counter.java | 88 -
.../db/query/udf/example/ExampleUDFConstant.java | 31 -
.../org/apache/iotdb/db/query/udf/example/Max.java | 74 -
.../iotdb/db/query/udf/example/Multiplier.java | 63 -
.../SlidingSizeWindowConstructorTester0.java | 59 -
.../SlidingSizeWindowConstructorTester1.java | 64 -
.../SlidingTimeWindowConstructionTester.java | 72 -
.../db/query/udf/example/TerminateTester.java | 67 -
.../iotdb/db/query/udf/example/ValidateTester.java | 44 -
.../iotdb/db/query/udf/example/WindowStartEnd.java | 66 -
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 355 -
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 357 -
.../java/org/apache/iotdb/it/env/Cluster1Env.java | 38 -
.../org/apache/iotdb/it/env/ConfigFactory.java | 60 -
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 95 -
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 91 -
.../java/org/apache/iotdb/it/env/EnvFactory.java | 59 -
.../org/apache/iotdb/it/env/IoTDBTestRunner.java | 49 -
.../java/org/apache/iotdb/it/env/MppConfig.java | 201 -
.../apache/iotdb/it/env/RemoteServerConfig.java | 23 -
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 116 -
.../iotdb/it/env/StandaloneDataNodeWrapper.java | 32 -
.../apache/iotdb/it/env/StandaloneOnMppEnv.java | 52 -
.../apache/iotdb/itbase/category/ClusterIT.java | 21 -
.../iotdb/itbase/category/LocalStandaloneIT.java | 21 -
.../org/apache/iotdb/itbase/category/RemoteIT.java | 21 -
.../constant/BuiltinAggregationFunctionEnum.java | 58 -
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 87 -
.../apache/iotdb/itbase/constant/TestConstant.java | 146 -
.../iotdb/itbase/constant/UDFTestConstant.java | 31 -
.../org/apache/iotdb/itbase/env/BaseConfig.java | 172 -
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 43 -
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 46 -
.../exception/InconsistentDataException.java | 28 -
.../exception/ParallelRequestTimeoutException.java | 25 -
.../itbase/runtime/ClusterResultSetMetaData.java | 239 -
.../itbase/runtime/ClusterTestConnection.java | 337 -
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 1178 ----
.../iotdb/itbase/runtime/ClusterTestStatement.java | 326 -
.../iotdb/itbase/runtime/NodeConnection.java | 85 -
.../itbase/runtime/ParallelRequestDelegate.java | 70 -
.../iotdb/itbase/runtime/RequestDelegate.java | 132 -
.../iotdb/itbase/runtime/RequestThreadPool.java | 49 -
.../itbase/runtime/SerialRequestDelegate.java | 49 -
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 112 -
.../iotdb/db/it/IoTDBCreateTimeseriesIT.java | 257 -
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 68 -
.../apache/iotdb/db/it/IoTDBFilterBetweenIT.java | 179 -
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 131 -
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 667 --
.../org/apache/iotdb/db/it/IoTDBQuotedPathIT.java | 118 -
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 994 ---
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 705 --
.../org/apache/iotdb/db/it/IoTDBTimeZoneIT.java | 156 -
.../it/aggregation/IoTDBAggregationByLevelIT.java | 686 --
.../it/aggregation/IoTDBAggregationDeleteIT.java | 93 -
.../db/it/aggregation/IoTDBAggregationIT.java | 1010 ---
.../aggregation/IoTDBAggregationLargeDataIT.java | 935 ---
.../aggregation/IoTDBAggregationSmallDataIT.java | 786 ---
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 1071 ---
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 148 -
.../aligned/IoTDBAggregationWithDeletion2IT.java | 78 -
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 522 --
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 61 -
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 61 -
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 6970 --------------------
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 224 -
...GroupByQueryWithValueFilterWithDeletion2IT.java | 75 -
...BGroupByQueryWithValueFilterWithDeletionIT.java | 764 ---
...upByQueryWithoutValueFilterWithDeletion2IT.java | 76 -
...oupByQueryWithoutValueFilterWithDeletionIT.java | 755 ---
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 120 -
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 121 -
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 78 -
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 294 -
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 77 -
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 323 -
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 63 -
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 333 -
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 81 -
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 80 -
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 80 -
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 564 --
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 97 -
.../iotdb/db/it/env/StandaloneEnvConfig.java | 229 -
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 531 --
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 246 -
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 132 -
.../org/apache/iotdb/db/it/query/IoTDBAliasIT.java | 384 --
.../iotdb/db/it/query/IoTDBNullValueFillIT.java | 392 --
.../iotdb/db/it/query/IoTDBPaginationIT.java | 152 -
.../query/IoTDBQueryWithComplexValueFilterIT.java | 118 -
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 131 -
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 338 -
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 803 ---
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 842 ---
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 1239 ----
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 256 -
.../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 350 -
.../org/apache/iotdb/db/it/utils/TestUtils.java | 251 -
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 246 -
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 233 -
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 1643 -----
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 1564 -----
.../src/test/resources/iotdb-engine.properties | 21 -
.../src/test/resources/logback-test.xml | 58 -
integration/checkstyle.xml | 217 -
integration/import-control.xml | 29 -
integration/pom.xml | 5 +
.../iotdb/db/query/udf/example/Accumulator.java | 28 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 26 +-
.../apache/iotdb/db/query/udf/example/Counter.java | 22 +-
.../org/apache/iotdb/db/query/udf/example/Max.java | 22 +-
.../iotdb/db/query/udf/example/Multiplier.java | 22 +-
.../SlidingSizeWindowConstructorTester0.java | 16 +-
.../SlidingSizeWindowConstructorTester1.java | 22 +-
.../SlidingTimeWindowConstructionTester.java | 22 +-
.../db/query/udf/example/TerminateTester.java | 18 +-
.../iotdb/db/query/udf/example/ValidateTester.java | 20 +-
.../iotdb/db/query/udf/example/WindowStartEnd.java | 18 +-
.../apache/iotdb/integration/env/ClusterNode.java | 8 +-
.../db/engine/trigger/example/Accumulator.java | 0
.../iotdb/db/engine/trigger/example/Counter.java | 0
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 6 -
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 396 ++
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 1099 +++
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 564 ++
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 10 +-
.../db/integration/IoTDBCreateTimeseriesIT.java | 314 +
.../iotdb/db/integration/IoTDBLimitSlimitIT.java | 204 +
.../db/integration/IoTDBLoadExternalTsfileIT.java | 8 +-
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 138 -
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 52 +-
.../iotdb/db/integration/IoTDBNumberPathIT.java | 483 ++
.../db/integration/IoTDBPathNumOverLimitIT.java | 74 +
.../IoTDBQueryWithComplexValueFilterIT.java | 113 +
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 125 +
.../db/integration/IoTDBResultMetadataIT.java | 89 +
.../iotdb/db/integration/IoTDBResultSetIT.java | 134 +
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 5 +-
.../integration/IoTDBSizeTieredCompactionIT.java | 22 +-
.../IoTDBSyntaxConventionIdentifierIT.java | 9 +-
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 158 +
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 3 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 398 ++
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 1038 +++
.../db/integration/IoTDBWithoutAllNullIT.java | 257 +
.../db/integration/IoTDBWithoutAnyNullIT.java | 249 +
.../aggregation/IoTDBAggregationByLevelIT.java | 693 ++
.../aggregation/IoTDBAggregationDeleteIT.java | 94 +
.../aggregation/IoTDBAggregationIT.java | 1064 +++
.../aggregation/IoTDBAggregationLargeDataIT.java | 1010 +++
.../aggregation/IoTDBAggregationSmallDataIT.java | 799 +++
.../aligned/IoTDBAggregationGroupByLevelIT.java | 302 +
.../IoTDBAggregationWithValueFilter2IT.java | 65 +
.../aligned/IoTDBAggregationWithValueFilterIT.java | 264 +
...BAggregationWithValueFilterWithDeletion2IT.java | 85 +
...DBAggregationWithValueFilterWithDeletionIT.java | 221 +
.../IoTDBAggregationWithoutValueFilter2IT.java | 65 +
.../IoTDBAggregationWithoutValueFilterIT.java | 456 ++
...gregationWithoutValueFilterWithDeletion2IT.java | 82 +
...ggregationWithoutValueFilterWithDeletionIT.java | 453 ++
.../integration/aligned/IoTDBAlignByDevice2IT.java | 67 +
.../integration/aligned/IoTDBAlignByDeviceIT.java | 1623 +++++
.../db/integration/aligned/IoTDBEmptyDataIT.java | 78 -
.../IoTDBGroupByQueryWithValueFilter2IT.java | 65 +
.../IoTDBGroupByQueryWithValueFilterIT.java | 1094 +++
...GroupByQueryWithValueFilterWithDeletion2IT.java | 76 +
...BGroupByQueryWithValueFilterWithDeletionIT.java | 826 +++
.../IoTDBGroupByQueryWithoutValueFilter2IT.java | 65 +
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 1128 ++++
...upByQueryWithoutValueFilterWithDeletion2IT.java | 77 +
...oupByQueryWithoutValueFilterWithDeletionIT.java | 818 +++
...GroupBySlidingWindowQueryWithValueFilterIT.java | 951 +++
...upBySlidingWindowQueryWithoutValueFilterIT.java | 947 +++
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 ++
.../db/integration/aligned/IoTDBLastQuery2IT.java | 65 +
.../db/integration/aligned/IoTDBLastQueryIT.java | 376 ++
.../aligned/IoTDBLastQueryWithDeletion2IT.java | 80 +
.../aligned/IoTDBLastQueryWithDeletionIT.java | 379 ++
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 68 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 381 ++
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 85 +
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 383 ++
.../IoTDBRawQueryWithoutValueFilter2IT.java | 66 +
.../IoTDBRawQueryWithoutValueFilter3IT.java | 63 +
.../aligned/IoTDBRawQueryWithoutValueFilterIT.java | 633 ++
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 83 +
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 611 ++
.../db/integration/groupby/IOTDBGroupByIT.java | 996 +++
.../groupby/IOTDBGroupByInnerIntervalIT.java | 342 +
.../groupby/IoTDBGroupByMonthFillIT.java | 272 +
.../integration/groupby/IoTDBGroupByMonthIT.java | 366 +
.../groupby/IoTDBGroupByNaturalMonthFillIT.java | 273 -
.../integration/groupby/IoTDBGroupByUnseqIT.java | 185 +
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 -
.../IoTDBWithoutNullAllFilterIT.java | 1973 ++++++
.../IoTDBWithoutNullAnyFilterIT.java | 1866 ++++++
.../session/IoTDBSessionDisableMemControlIT.java | 16 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 8 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 8 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 6 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 6 -
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 50 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 25 -
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 66 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 6 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 4 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 13 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 18 -
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 4 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 16 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 4 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 4 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
.../org/apache/iotdb/library/anomaly/UDTFIQR.java | 23 +-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 21 +-
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 23 +-
.../iotdb/library/anomaly/UDTFMissDetect.java | 21 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 21 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 21 +-
.../iotdb/library/anomaly/util/MissDetector.java | 4 +-
.../iotdb/library/anomaly/util/WindowDetect.java | 4 +-
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 26 +-
.../org/apache/iotdb/library/dmatch/UDAFDtw.java | 26 +-
.../apache/iotdb/library/dmatch/UDAFPearson.java | 26 +-
.../apache/iotdb/library/dmatch/UDTFPtnSym.java | 23 +-
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 24 +-
.../iotdb/library/dprofile/UDAFIntegral.java | 20 +-
.../iotdb/library/dprofile/UDAFIntegralAvg.java | 23 +-
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 28 +-
.../apache/iotdb/library/dprofile/UDAFMedian.java | 28 +-
.../apache/iotdb/library/dprofile/UDAFMode.java | 17 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 25 +-
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 25 +-
.../apache/iotdb/library/dprofile/UDAFSkew.java | 23 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 25 +-
.../apache/iotdb/library/dprofile/UDAFStddev.java | 23 +-
.../org/apache/iotdb/library/dprofile/UDTFACF.java | 23 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 26 +-
.../iotdb/library/dprofile/UDTFHistogram.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFMinMax.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 25 +-
.../apache/iotdb/library/dprofile/UDTFPACF.java | 23 +-
.../org/apache/iotdb/library/dprofile/UDTFQLB.java | 23 +-
.../iotdb/library/dprofile/UDTFResample.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFSegment.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFSpline.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFZScore.java | 23 +-
.../dprofile/util/ExactOrderStatistics.java | 41 +-
.../iotdb/library/dquality/UDTFCompleteness.java | 18 +-
.../iotdb/library/dquality/UDTFConsistency.java | 18 +-
.../iotdb/library/dquality/UDTFTimeliness.java | 18 +-
.../iotdb/library/dquality/UDTFValidity.java | 18 +-
.../library/dquality/util/TimeSeriesQuality.java | 4 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 19 +-
.../iotdb/library/drepair/UDTFValueFill.java | 19 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 19 +-
.../apache/iotdb/library/drepair/util/ARFill.java | 4 +-
.../iotdb/library/drepair/util/LikelihoodFill.java | 2 +-
.../iotdb/library/drepair/util/LinearFill.java | 2 +-
.../iotdb/library/drepair/util/LsGreedy.java | 2 +-
.../apache/iotdb/library/drepair/util/MAFill.java | 2 +-
.../iotdb/library/drepair/util/MeanFill.java | 2 +-
.../iotdb/library/drepair/util/PreviousFill.java | 2 +-
.../apache/iotdb/library/drepair/util/Screen.java | 2 +-
.../iotdb/library/drepair/util/ScreenFill.java | 4 +-
.../library/drepair/util/TimestampRepair.java | 4 +-
.../iotdb/library/drepair/util/ValueFill.java | 6 +-
.../iotdb/library/drepair/util/ValueRepair.java | 4 +-
.../apache/iotdb/library/frequency/UDTFConv.java | 26 +-
.../apache/iotdb/library/frequency/UDTFDWT.java | 23 +-
.../apache/iotdb/library/frequency/UDTFDeconv.java | 26 +-
.../apache/iotdb/library/frequency/UDTFFFT.java | 23 +-
.../iotdb/library/frequency/UDTFHighPass.java | 23 +-
.../apache/iotdb/library/frequency/UDTFIDWT.java | 23 +-
.../apache/iotdb/library/frequency/UDTFIFFT.java | 23 +-
.../iotdb/library/frequency/UDTFLowPass.java | 23 +-
.../iotdb/library/frequency/util/FFTUtil.java | 2 +-
.../library/series/UDTFConsecutiveSequences.java | 20 +-
.../library/series/UDTFConsecutiveWindows.java | 20 +-
.../iotdb/library/series/util/ConsecutiveUtil.java | 4 +-
.../iotdb/library/string/UDTFRegexMatch.java | 22 +-
.../iotdb/library/string/UDTFRegexReplace.java | 22 +-
.../iotdb/library/string/UDTFRegexSplit.java | 22 +-
.../iotdb/library/string/UDTFStrReplace.java | 22 +-
.../iotdb/library/util/LinearRegression.java | 2 +-
.../java/org/apache/iotdb/library/util/Util.java | 4 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 27 +-
.../metrics/config/MetricConfigDescriptor.java | 15 +-
.../iotdb/metrics/config/MetricConstant.java | 2 -
.../apache/iotdb/metrics/utils/MetricsUtils.java | 16 +-
.../reporter/MicrometerPrometheusReporter.java | 1 -
.../micrometer/MicrometerMetricManagerTest.java | 12 -
metrics/pom.xml | 41 -
node-commons/pom.xml | 10 -
.../commons/client/ClientFactoryProperty.java | 2 +-
.../apache/iotdb/commons/client/ClientManager.java | 2 +-
.../async/AsyncConfigNodeIServiceClient.java | 4 +-
.../async/AsyncDataNodeDataBlockServiceClient.java | 146 +
.../async/AsyncDataNodeInternalServiceClient.java | 4 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 146 -
.../client/sync/SyncConfigNodeIServiceClient.java | 4 +-
.../sync/SyncDataNodeDataBlockServiceClient.java | 132 +
.../sync/SyncDataNodeInternalServiceClient.java | 4 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 132 -
.../apache/iotdb/commons/cluster/NodeStatus.java | 37 -
.../apache/iotdb/commons/cluster/RegionStatus.java | 36 -
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../threadpool/ScheduledExecutorUtil.java | 188 -
.../WrappedScheduledExecutorService.java | 2 -
.../WrappedSingleThreadScheduledExecutor.java | 2 -
.../apache/iotdb/commons/conf/IoTDBConstant.java | 17 +-
.../iotdb/commons/partition/DataPartition.java | 207 +-
.../commons/partition/DataPartitionTable.java | 183 -
.../iotdb/commons/partition/SchemaPartition.java | 171 +-
.../commons/partition/SchemaPartitionTable.java | 177 -
.../commons/partition/SeriesPartitionTable.java | 192 -
.../org/apache/iotdb/commons/path/PartialPath.java | 49 -
.../org/apache/iotdb/commons/path/PathType.java | 10 +-
.../service/AbstractThriftServiceThread.java | 34 +-
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../iotdb/commons/service/ThriftServiceThread.java | 4 -
.../java/org/apache/iotdb/commons/udf/api/UDF.java | 40 +
.../org/apache/iotdb/commons/udf/api/UDTF.java | 120 +
.../apache/iotdb/commons/udf/api/access/Row.java | 130 +
.../iotdb/commons/udf/api/access/RowIterator.java | 47 +
.../iotdb/commons/udf/api/access/RowWindow.java | 102 +
.../commons/udf/api/collector/PointCollector.java | 137 +
.../api/customizer/config/UDFConfigurations.java | 37 +
.../api/customizer/config/UDTFConfigurations.java | 105 +
.../parameter/UDFParameterValidator.java | 211 +
.../api/customizer/parameter/UDFParameters.java | 147 +
.../api/customizer/strategy/AccessStrategy.java | 57 +
.../strategy/RowByRowAccessStrategy.java | 61 +
.../strategy/SlidingSizeWindowAccessStrategy.java | 123 +
.../strategy/SlidingTimeWindowAccessStrategy.java | 230 +
.../UDFAttributeNotProvidedException.java | 27 +
.../commons/udf/api/exception/UDFException.java | 31 +
.../UDFInputSeriesDataTypeNotValidException.java | 43 +
.../UDFInputSeriesIndexNotValidException.java | 30 +
.../UDFInputSeriesNumberNotValidException.java | 38 +
.../UDFOutputSeriesDataTypeNotValidException.java | 30 +
.../exception/UDFParameterNotValidException.java | 27 +
.../api/exception/UDFRegistrationException.java | 32 +
.../BuiltinTimeSeriesGeneratingFunction.java | 21 -
.../commons/udf/builtin/String/UDTFConcat.java | 74 -
.../commons/udf/builtin/String/UDTFEndsWith.java | 51 -
.../commons/udf/builtin/String/UDTFLower.java | 48 -
.../commons/udf/builtin/String/UDTFStartsWith.java | 50 -
.../commons/udf/builtin/String/UDTFStrCompare.java | 55 -
.../commons/udf/builtin/String/UDTFStrLength.java | 48 -
.../commons/udf/builtin/String/UDTFStrLocate.java | 60 -
.../commons/udf/builtin/String/UDTFSubstr.java | 70 -
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 48 -
.../commons/udf/builtin/String/UDTFUpper.java | 48 -
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 28 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 17 +-
.../apache/iotdb/commons/udf/builtin/UDTFCast.java | 28 +-
.../commons/udf/builtin/UDTFCommonDerivative.java | 16 +-
.../udf/builtin/UDTFCommonValueDifference.java | 16 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 24 +-
.../iotdb/commons/udf/builtin/UDTFConstE.java | 18 +-
.../iotdb/commons/udf/builtin/UDTFConstPi.java | 18 +-
.../iotdb/commons/udf/builtin/UDTFContains.java | 24 +-
.../udf/builtin/UDTFContinuouslySatisfy.java | 47 +-
.../iotdb/commons/udf/builtin/UDTFDerivative.java | 21 +-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 29 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 28 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 32 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 26 +-
.../udf/builtin/UDTFEqualSizeBucketSample.java | 14 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 36 +-
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 64 +-
.../iotdb/commons/udf/builtin/UDTFMatches.java | 24 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 36 +-
.../udf/builtin/UDTFNonNegativeDerivative.java | 16 +-
.../builtin/UDTFNonNegativeValueDifference.java | 16 +-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 35 +-
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 58 +-
.../commons/udf/builtin/UDTFTimeDifference.java | 18 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 17 +-
.../commons/udf/builtin/UDTFValueDifference.java | 19 +-
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 24 +-
.../commons/udf/service/UDFClassLoaderManager.java | 4 +-
.../udf/service/UDFRegistrationInformation.java | 2 +-
.../udf/service/UDFRegistrationService.java | 4 +-
.../commons/udf/utils/UDFBinaryTransformer.java | 37 -
.../commons/udf/utils/UDFDataTypeTransformer.java | 77 -
.../org/apache/iotdb/commons/utils/AuthUtils.java | 37 -
.../commons/utils/BasicStructureSerDeUtil.java | 86 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 14 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 6 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 4 -
.../commons/utils/ThriftCommonsSerDeUtils.java | 34 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 10 -
.../apache/iotdb/commons/ClientManagerTest.java | 477 ++
.../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 4 +-
.../iotdb/commons/client/ClientManagerTest.java | 454 --
.../client/mock/MockInternalRPCService.java | 92 -
.../client/mock/MockInternalRPCServiceMBean.java | 22 -
.../commons/partition/DataPartitionTableTest.java | 124 -
.../iotdb/commons/partition/DataPartitionTest.java | 69 +
.../partition/SchemaPartitionTableTest.java | 101 -
.../commons/partition/SchemaPartitionTest.java | 65 +
.../iotdb/commons/partition/SerializeTest.java | 101 +
.../partition/SeriesPartitionTableTest.java | 111 -
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 8 +-
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 102 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 17 +-
openapi/pom.xml | 26 -
pom.xml | 30 +-
schema-engine-rocksdb/README.md | 2 +-
.../resources/conf/schema-rocksdb.properties | 8 +-
.../schemaregion/rocksdb/RSchemaConfLoader.java | 4 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 14 +
.../schemaregion/rocksdb/mnode/RMNode.java | 7 -
.../rocksdb/mnode/RMeasurementMNode.java | 10 +
server/file-changelists/conf-changelist.md | 3 -
server/pom.xml | 4 -
.../src/assembly/resources/conf/datanode-env.bat | 146 -
server/src/assembly/resources/conf/datanode-env.sh | 264 -
.../resources/conf/iotdb-datanode.properties | 1078 ---
.../resources/conf/iotdb-engine.properties | 1056 +++
server/src/assembly/resources/conf/iotdb-env.bat | 146 +
server/src/assembly/resources/conf/iotdb-env.sh | 264 +
.../assembly/resources/conf/iotdb-rest.properties | 3 -
server/src/assembly/resources/conf/logback.xml | 2 +-
.../src/assembly/resources/sbin/start-datanode.bat | 14 +-
.../src/assembly/resources/sbin/start-datanode.sh | 77 +-
.../assembly/resources/sbin/start-new-server.bat | 126 -
.../assembly/resources/sbin/start-new-server.sh | 151 -
.../src/assembly/resources/sbin/start-server.bat | 6 +-
server/src/assembly/resources/sbin/start-server.sh | 71 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 19 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 26 +-
server/src/assembly/resources/sbin/stop-server.bat | 4 +-
server/src/assembly/resources/sbin/stop-server.sh | 2 +-
.../assembly/resources/tools/rocksdb-transfer.bat | 6 +-
.../assembly/resources/tools/rocksdb-transfer.sh | 8 +-
.../assembly/resources/tools/start-WalChecker.sh | 6 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityFetcher.java | 182 +
.../apache/iotdb/db/auth/AuthorizerManager.java | 218 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 364 -
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 39 -
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 131 -
.../apache/iotdb/db/client/ConfigNodeClient.java | 141 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 30 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 237 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 152 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 63 +-
.../db/conf/directories/DirectoryManager.java | 6 -
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 11 -
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 3 -
.../db/consensus/DataRegionConsensusImpl.java | 80 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 51 +-
.../consensus/statemachine/BaseStateMachine.java | 18 +-
.../statemachine/DataRegionStateMachine.java | 14 +-
.../statemachine/SchemaRegionStateMachine.java | 4 +-
.../statemachine/visitor/DataExecutionVisitor.java | 61 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 121 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 250 +-
.../compaction/CompactionMetricsManager.java | 171 +
.../db/engine/compaction/CompactionScheduler.java | 12 +-
.../engine/compaction/CompactionTaskManager.java | 253 +-
.../db/engine/compaction/CompactionWorker.java | 117 -
.../DefaultCompactionTaskComparatorImpl.java | 17 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 49 +-
.../rewrite/CrossSpaceCompactionResource.java | 8 +
.../RewriteCrossSpaceCompactionSelector.java | 4 +-
.../rewrite/task/ReadPointPerformerSubTask.java | 26 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 90 +-
.../utils/AlignedSeriesCompactionExecutor.java | 32 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 3 -
.../utils/SingleSeriesCompactionExecutor.java | 44 +-
.../compaction/performer/ICompactionPerformer.java | 3 -
.../impl/ReadChunkCompactionPerformer.java | 27 +-
.../impl/ReadPointCompactionPerformer.java | 111 +-
.../compaction/task/AbstractCompactionTask.java | 71 +-
.../compaction/task/CompactionTaskSummary.java | 51 +-
.../writer/AbstractCompactionWriter.java | 4 +-
.../iotdb/db/engine/cq/ContinuousQueryService.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 43 +-
.../engine/memtable/AlignedWritableMemChunk.java | 26 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 2 +-
.../querycontext/AlignedReadOnlyMemChunk.java | 13 +-
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 144 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 105 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 247 +-
.../db/engine/storagegroup/TsFileManager.java | 20 +-
.../db/engine/storagegroup/TsFileResource.java | 9 +-
.../dataregion/StorageGroupManager.java | 23 +-
.../db/engine/trigger/builtin/ForwardTrigger.java | 12 +-
.../forward/http/HTTPForwardConfiguration.java | 47 -
.../sink/forward/http/HTTPForwardEvent.java | 30 -
.../sink/forward/http/HTTPForwardHandler.java | 133 -
.../forward/mqtt/MQTTForwardConfiguration.java | 137 -
.../sink/forward/mqtt/MQTTForwardEvent.java | 30 -
.../sink/forward/mqtt/MQTTForwardHandler.java | 97 -
.../sink/http/HTTPForwardConfiguration.java | 47 +
.../engine/trigger/sink/http/HTTPForwardEvent.java | 30 +
.../trigger/sink/http/HTTPForwardHandler.java | 133 +
.../sink/mqtt/MQTTForwardConfiguration.java | 137 +
.../engine/trigger/sink/mqtt/MQTTForwardEvent.java | 30 +
.../trigger/sink/mqtt/MQTTForwardHandler.java | 97 +
.../iotdb/db/exception/BatchProcessException.java | 5 -
.../metadata/DataTypeMismatchException.java | 20 +-
.../metadata/MeasurementAlreadyExistException.java | 42 -
.../metadata/SeriesOverflowException.java | 2 +-
.../exception/query/PathNumOverLimitException.java | 3 +-
.../runtime/SerializationRunTimeException.java | 27 -
.../sql/MeasurementNotExistException.java | 27 -
.../exception/sql/PathNumOverLimitException.java | 33 -
.../iotdb/db/localconfignode/LocalConfigNode.java | 520 +-
.../localconfignode/LocalDataPartitionTable.java | 58 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 5 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 20 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 31 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 32 +-
.../idtable/entry/InsertMeasurementMNode.java | 16 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 6 -
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 3 -
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 4 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 6 -
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 16 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 6 -
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 6 -
.../db/metadata/mnode/visitor/MNodeVisitor.java | 39 -
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 36 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 1 -
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 49 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 359 -
.../db/metadata/mtree/store/CachedMTreeStore.java | 7 -
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 4 -
.../db/metadata/mtree/store/MemMTreeStore.java | 18 -
.../apache/iotdb/db/metadata/path/AlignedPath.java | 29 -
.../iotdb/db/metadata/path/MeasurementPath.java | 44 +-
.../iotdb/db/metadata/rescon/MemoryStatistics.java | 2 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 6 +
.../db/metadata/schemaregion/SchemaEngine.java | 157 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 327 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 14 +
.../metadata/schemaregion/SchemaRegionUtils.java | 13 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 19 -
.../db/metadata/upgrade/MetadataUpgrader.java | 4 +-
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 6 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 22 -
.../db/metadata/utils/TimeseriesVersionUtil.java | 28 +
.../metadata/visitor/SchemaExecutionVisitor.java | 182 +-
.../iotdb/db/mpp/aggregation/Accumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 9 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 65 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 30 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 65 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 113 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 48 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 101 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 60 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 16 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 15 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 65 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 18 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 13 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 65 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 65 +-
.../slidingwindow/SlidingWindowAggregator.java | 3 +-
.../TimeRangeIteratorFactory.java | 14 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 14 +-
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 9 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 6 -
.../iotdb/db/mpp/common/header/ColumnHeader.java | 6 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 18 +-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 91 -
.../db/mpp/common/schematree/PathPatternNode.java | 13 -
.../db/mpp/common/schematree/PathPatternTree.java | 272 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 47 +-
.../common/schematree/node/SchemaEntityNode.java | 22 +-
.../common/schematree/node/SchemaInternalNode.java | 27 +-
.../schematree/node/SchemaMeasurementNode.java | 34 +-
.../db/mpp/common/schematree/node/SchemaNode.java | 7 +-
.../visitor/SchemaTreeMeasurementVisitor.java | 8 +-
.../execution/datatransfer/DataBlockManager.java | 476 ++
.../execution/datatransfer/DataBlockService.java | 137 +
.../datatransfer/DataBlockServiceMBean.java | 34 +
.../DataBlockServiceThriftHandler.java | 44 +
.../execution/datatransfer/IDataBlockManager.java | 85 +
.../datatransfer/IDataBlockManagerCallback.java | 24 +
.../db/mpp/execution/datatransfer/ISinkHandle.java | 73 +
.../mpp/execution/datatransfer/ISourceHandle.java | 57 +
.../execution/datatransfer/LocalSinkHandle.java | 146 +
.../execution/datatransfer/LocalSourceHandle.java | 125 +
.../execution/datatransfer/SharedTsBlockQueue.java | 152 +
.../db/mpp/execution/datatransfer/SinkHandle.java | 374 ++
.../mpp/execution/datatransfer/SourceHandle.java | 430 ++
.../datatransfer/TsBlockSerdeFactory.java | 31 +
.../iotdb/db/mpp/execution/driver/DataDriver.java | 4 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 24 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 4 +-
.../db/mpp/execution/driver/SchemaDriver.java | 4 +-
.../exchange/IMPPDataExchangeManager.java | 85 -
.../exchange/IMPPDataExchangeManagerCallback.java | 24 -
.../db/mpp/execution/exchange/ISinkHandle.java | 73 -
.../db/mpp/execution/exchange/ISourceHandle.java | 57 -
.../db/mpp/execution/exchange/LocalSinkHandle.java | 176 -
.../mpp/execution/exchange/LocalSourceHandle.java | 162 -
.../execution/exchange/MPPDataExchangeManager.java | 508 --
.../execution/exchange/MPPDataExchangeService.java | 145 -
.../exchange/MPPDataExchangeServiceMBean.java | 34 -
.../MPPDataExchangeServiceThriftHandler.java | 44 -
.../mpp/execution/exchange/SharedTsBlockQueue.java | 175 -
.../db/mpp/execution/exchange/SinkHandle.java | 370 --
.../db/mpp/execution/exchange/SourceHandle.java | 440 --
.../execution/exchange/TsBlockSerdeFactory.java | 31 -
.../fragment/FragmentInstanceExecution.java | 37 +-
.../fragment/FragmentInstanceManager.java | 82 +-
.../execution/fragment/FragmentInstanceState.java | 4 +-
.../fragment/FragmentInstanceStateMachine.java | 7 +-
.../iotdb/db/mpp/execution/operator/Operator.java | 4 +-
.../operator/process/AggregationOperator.java | 28 +-
.../operator/process/DeviceMergeOperator.java | 15 +-
.../operator/process/DeviceViewOperator.java | 7 +-
.../execution/operator/process/FillOperator.java | 2 +-
.../operator/process/FilterNullOperator.java | 57 +
.../execution/operator/process/FilterOperator.java | 137 +-
.../operator/process/LastQueryMergeOperator.java | 9 +-
.../execution/operator/process/LimitOperator.java | 2 +-
.../operator/process/LinearFillOperator.java | 2 +-
.../execution/operator/process/OffsetOperator.java | 2 +-
.../process/RawDataAggregationOperator.java | 80 +-
.../process/SlidingWindowAggregationOperator.java | 50 +-
.../execution/operator/process/SortOperator.java | 2 +-
.../operator/process/TimeJoinOperator.java | 11 +-
.../operator/process/TransformOperator.java | 161 +-
.../operator/process/UpdateLastCacheOperator.java | 2 +-
.../process/fill/linear/DoubleLinearFill.java | 5 -
.../process/fill/linear/FloatLinearFill.java | 5 -
.../process/fill/linear/IntLinearFill.java | 5 -
.../operator/process/fill/linear/LinearFill.java | 27 +-
.../process/fill/linear/LongLinearFill.java | 5 -
.../operator/process/merge/AscTimeComparator.java | 5 -
.../operator/process/merge/DescTimeComparator.java | 5 -
.../operator/process/merge/TimeComparator.java | 5 -
.../operator/schema/CountMergeOperator.java | 11 +-
.../schema/NodeManageMemoryMergeOperator.java | 9 +-
.../operator/schema/NodePathsConvertOperator.java | 7 +-
.../operator/schema/NodePathsCountOperator.java | 38 +-
.../operator/schema/SchemaFetchMergeOperator.java | 54 +-
.../operator/schema/SchemaFetchScanOperator.java | 23 +-
.../operator/schema/SchemaQueryMergeOperator.java | 45 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 76 +-
.../operator/sink/FragmentSinkOperator.java | 66 +
.../AlignedSeriesAggregationScanOperator.java | 147 +-
.../operator/source/ExchangeOperator.java | 6 +-
.../source/SeriesAggregationScanOperator.java | 134 +-
.../execution/schedule/AbstractDriverThread.java | 13 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 139 +-
.../mpp/execution/schedule/DriverTaskThread.java | 8 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 4 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 75 +-
.../org/apache/iotdb/db/mpp/plan/StepTracker.java | 80 -
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 320 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 389 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 217 +-
.../plan/analyze/ColumnPaginationController.java | 12 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 331 +-
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 78 -
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 79 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 8 +-
.../mpp/plan/analyze/GroupByLevelController.java | 74 +-
.../db/mpp/plan/analyze/IPartitionFetcher.java | 3 -
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 22 +-
.../plan/analyze/StandalonePartitionFetcher.java | 157 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 229 +-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 10 -
.../db/mpp/plan/constant/DataNodeEndPoints.java | 39 -
.../iotdb/db/mpp/plan/constant/StatementType.java | 3 +-
.../db/mpp/plan/execution/IQueryExecution.java | 2 -
.../db/mpp/plan/execution/QueryExecution.java | 230 +-
.../execution/config/AuthorizerConfigTask.java | 87 +
.../mpp/plan/execution/config/AuthorizerTask.java | 48 -
.../mpp/plan/execution/config/ConfigExecution.java | 47 +-
.../plan/execution/config/ConfigTaskVisitor.java | 35 +-
.../execution/config/CountStorageGroupTask.java | 51 +-
.../plan/execution/config/CreateFunctionTask.java | 74 +-
.../execution/config/DeleteStorageGroupTask.java | 69 +-
.../plan/execution/config/DropFunctionTask.java | 65 +-
.../db/mpp/plan/execution/config/FlushTask.java | 66 -
.../db/mpp/plan/execution/config/IConfigTask.java | 7 +-
.../plan/execution/config/SetStorageGroupTask.java | 66 +-
.../db/mpp/plan/execution/config/SetTTLTask.java | 58 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 95 -
.../plan/execution/config/ShowDataNodesTask.java | 78 -
.../plan/execution/config/ShowFunctionsTask.java | 150 -
.../mpp/plan/execution/config/ShowRegionTask.java | 86 -
.../execution/config/ShowStorageGroupTask.java | 64 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 85 +-
.../config/executor/ClusterConfigTaskExecutor.java | 367 --
.../config/executor/IConfigTaskExecutor.java | 67 -
.../executor/StandaloneConfigTaskExecutor.java | 297 -
.../plan/execution/memory/MemorySourceHandle.java | 8 +-
.../memory/StatementMemorySourceVisitor.java | 52 -
.../iotdb/db/mpp/plan/expression/Expression.java | 28 +-
.../db/mpp/plan/expression/ExpressionType.java | 15 +-
.../plan/expression/binary/BinaryExpression.java | 7 -
.../mpp/plan/expression/leaf/ConstantOperand.java | 7 -
.../plan/expression/leaf/TimeSeriesOperand.java | 6 -
.../mpp/plan/expression/leaf/TimestampOperand.java | 6 -
.../plan/expression/multi/FunctionExpression.java | 28 +-
.../plan/expression/ternary/BetweenExpression.java | 110 -
.../plan/expression/ternary/TernaryExpression.java | 336 -
.../db/mpp/plan/expression/unary/InExpression.java | 36 +-
.../plan/expression/unary/IsNullExpression.java | 88 -
.../mpp/plan/expression/unary/LikeExpression.java | 14 +-
.../plan/expression/unary/RegularExpression.java | 12 +-
.../mpp/plan/expression/unary/UnaryExpression.java | 6 -
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 179 +-
.../db/mpp/plan/parser/StatementGenerator.java | 1 -
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 149 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 222 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 208 +-
.../distribution/DistributionPlanContext.java | 17 -
.../planner/distribution/DistributionPlanner.java | 7 +-
.../planner/distribution/ExchangeNodeAdder.java | 37 +-
.../SimpleFragmentParallelPlanner.java | 4 +-
.../plan/planner/distribution/SourceRewriter.java | 220 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 61 +-
.../db/mpp/plan/planner/plan/PlanFragment.java | 16 +-
.../plan/planner/plan/node/DeleteRegionNode.java | 109 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 178 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 44 +-
.../db/mpp/plan/planner/plan/node/PlanNodeId.java | 8 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 23 +-
.../mpp/plan/planner/plan/node/PlanNodeUtil.java | 9 -
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 11 +-
.../node/metedata/read/CountSchemaMergeNode.java | 7 -
.../plan/node/metedata/read/DevicesCountNode.java | 9 -
.../node/metedata/read/DevicesSchemaScanNode.java | 17 -
.../metedata/read/LevelTimeSeriesCountNode.java | 10 -
.../read/NodeManagementMemoryMergeNode.java | 12 -
.../node/metedata/read/NodePathsConvertNode.java | 7 -
.../node/metedata/read/NodePathsCountNode.java | 7 -
.../metedata/read/NodePathsSchemaScanNode.java | 9 -
.../node/metedata/read/SchemaFetchMergeNode.java | 9 +-
.../node/metedata/read/SchemaFetchScanNode.java | 19 -
.../node/metedata/read/SchemaQueryMergeNode.java | 7 -
.../metedata/read/SchemaQueryOrderByHeatNode.java | 40 +-
.../node/metedata/read/SchemaQueryScanNode.java | 8 -
.../node/metedata/read/TimeSeriesCountNode.java | 9 -
.../metedata/read/TimeSeriesSchemaScanNode.java | 15 -
.../node/metedata/write/AlterTimeSeriesNode.java | 51 +-
.../write/CreateAlignedTimeSeriesNode.java | 86 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 25 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 75 +-
.../node/metedata/write/DeleteTimeSeriesNode.java | 11 -
.../write/InternalCreateTimeSeriesNode.java | 155 -
.../metedata/write/InvalidateSchemaCacheNode.java | 16 -
.../plan/node/metedata/write/MeasurementGroup.java | 82 +-
.../planner/plan/node/process/AggregationNode.java | 20 +-
.../planner/plan/node/process/DeviceMergeNode.java | 13 -
.../planner/plan/node/process/DeviceViewNode.java | 25 -
.../planner/plan/node/process/ExchangeNode.java | 15 -
.../plan/planner/plan/node/process/FillNode.java | 39 +-
.../plan/planner/plan/node/process/FilterNode.java | 33 +-
.../planner/plan/node/process/FilterNullNode.java | 8 -
.../plan/node/process/GroupByLevelNode.java | 18 -
.../plan/node/process/LastQueryMergeNode.java | 16 +-
.../plan/planner/plan/node/process/LimitNode.java | 8 -
.../plan/planner/plan/node/process/OffsetNode.java | 8 -
.../planner/plan/node/process/ProjectNode.java | 11 -
.../node/process/SlidingWindowAggregationNode.java | 28 +-
.../plan/planner/plan/node/process/SortNode.java | 8 -
.../planner/plan/node/process/TimeJoinNode.java | 8 -
.../planner/plan/node/process/TransformNode.java | 43 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 18 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 13 +-
.../source/AlignedSeriesAggregationScanNode.java | 36 -
.../plan/node/source/AlignedSeriesScanNode.java | 28 +-
.../plan/node/source/LastQueryScanNode.java | 13 +-
.../node/source/SeriesAggregationScanNode.java | 29 +-
.../planner/plan/node/source/SeriesScanNode.java | 28 +-
.../planner/plan/node/write/DeleteDataNode.java | 13 -
.../plan/node/write/InsertMultiTabletsNode.java | 31 +-
.../plan/planner/plan/node/write/InsertNode.java | 28 +-
.../planner/plan/node/write/InsertRowNode.java | 111 +-
.../planner/plan/node/write/InsertRowsNode.java | 33 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 63 +-
.../planner/plan/node/write/InsertTabletNode.java | 205 +-
.../plan/parameter/AggregationDescriptor.java | 90 +-
.../planner/plan/parameter/AggregationStep.java | 7 -
.../planner/plan/parameter/FillDescriptor.java | 9 -
.../plan/parameter/FilterNullParameter.java | 10 -
.../plan/parameter/GroupByLevelDescriptor.java | 15 +-
.../plan/parameter/GroupByTimeParameter.java | 25 +-
.../scheduler/AbstractFragInsStateTracker.java | 1 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 52 +-
.../scheduler/FixedRateFragInsStateTracker.java | 14 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 86 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 89 +
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 64 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 115 +-
.../db/mpp/plan/statement/StatementVisitor.java | 43 +-
.../statement/component/GroupByLevelComponent.java | 13 -
.../db/mpp/plan/statement/component/OrderBy.java | 13 +-
.../plan/statement/crud/InsertBaseStatement.java | 4 -
.../crud/InsertMultiTabletsStatement.java | 18 -
.../plan/statement/crud/InsertRowStatement.java | 12 -
.../crud/InsertRowsOfOneDeviceStatement.java | 9 -
.../plan/statement/crud/InsertRowsStatement.java | 17 -
.../mpp/plan/statement/crud/InsertStatement.java | 29 -
.../plan/statement/crud/InsertTabletStatement.java | 14 -
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +-
.../InternalCreateTimeSeriesStatement.java | 96 -
.../statement/internal/SchemaFetchStatement.java | 2 +-
.../mpp/plan/statement/literal/BooleanLiteral.java | 23 +-
.../mpp/plan/statement/literal/DoubleLiteral.java | 23 +-
.../db/mpp/plan/statement/literal/Literal.java | 6 -
.../db/mpp/plan/statement/literal/LongLiteral.java | 22 +-
.../db/mpp/plan/statement/literal/NullLiteral.java | 18 -
.../mpp/plan/statement/literal/StringLiteral.java | 13 -
.../CreateTimeSeriesByDeviceStatement.java | 68 +
.../statement/metadata/ShowClusterStatement.java | 36 -
.../statement/metadata/ShowDataNodesStatement.java | 54 -
.../statement/metadata/ShowFunctionsStatement.java | 46 -
.../statement/metadata/ShowRegionStatement.java | 54 -
.../mpp/plan/statement/sys/ExplainStatement.java | 50 -
.../db/mpp/plan/statement/sys/FlushStatement.java | 91 -
.../plan/statement/sys/ShowVersionStatement.java | 33 -
.../mpp/transformation/api/LayerPointReader.java | 2 +-
.../db/mpp/transformation/api/LayerRowReader.java | 4 +-
.../transformation/api/LayerRowWindowReader.java | 4 +-
.../db/mpp/transformation/api/YieldableReader.java | 29 -
.../db/mpp/transformation/api/YieldableState.java | 26 -
...ializableRowRecordListBackedMultiColumnRow.java | 16 +-
...izableRowRecordListBackedMultiColumnWindow.java | 12 +-
...wRecordListBackedMultiColumnWindowIterator.java | 4 +-
...ticSerializableTVListBackedSingleColumnRow.java | 14 +-
...SerializableTVListBackedSingleColumnWindow.java | 13 +-
...ableTVListBackedSingleColumnWindowIterator.java | 4 +-
.../LayerPointReaderBackedSingleColumnRow.java | 14 +-
.../dag/input/ConstantInputReader.java | 10 +-
.../transformation/dag/input/IUDFInputDataSet.java | 50 -
.../dag/input/QueryDataSetInputLayer.java | 70 +-
.../dag/input/TsBlockInputDataSet.java | 37 +-
.../intermediate/ConstantIntermediateLayer.java | 4 +-
.../dag/intermediate/IntermediateLayer.java | 6 +-
.../MultiInputColumnIntermediateLayer.java | 363 +-
...InputColumnMultiReferenceIntermediateLayer.java | 202 +-
...nputColumnSingleReferenceIntermediateLayer.java | 168 +-
.../dag/transformer/Transformer.java | 40 -
.../dag/transformer/binary/BinaryTransformer.java | 75 +-
.../transformer/binary/LogicBinaryTransformer.java | 119 +-
.../transformer/multi/UDFQueryRowTransformer.java | 15 -
.../multi/UDFQueryRowWindowTransformer.java | 12 -
.../dag/transformer/multi/UDFQueryTransformer.java | 26 +-
.../transformer/ternary/BetweenTransformer.java | 67 -
.../ternary/CompareTernaryTransformer.java | 86 -
.../transformer/ternary/TernaryTransformer.java | 265 -
.../dag/transformer/unary/InTransformer.java | 38 +-
.../dag/transformer/unary/IsNullTransformer.java | 70 -
.../dag/transformer/unary/RegularTransformer.java | 8 +-
.../dag/transformer/unary/UnaryTransformer.java | 22 -
.../mpp/transformation/dag/udf/UDTFExecutor.java | 24 +-
.../transformation/dag/udf/UDTFTypeInferrer.java | 17 +-
.../mpp/transformation/dag/util/InputRowUtils.java | 2 +-
.../transformation/dag/util/LayerCacheUtils.java | 93 +-
.../tv/ElasticSerializableBinaryTVList.java | 15 +-
.../tv/ElasticSerializableTVList.java | 33 +-
.../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 | 75 -
.../mpprest/handler/QueryDataSetHandler.java | 252 -
.../mpprest/handler/RequestValidationHandler.java | 53 -
.../handler/StatementConstructionHandler.java | 157 -
.../mpprest/impl/GrafanaApiServiceImpl.java | 245 -
.../protocol/mpprest/impl/PingApiServiceImpl.java | 51 -
.../protocol/mpprest/impl/RestApiServiceImpl.java | 193 -
.../db/protocol/mqtt/JSONPayloadFormatter.java | 15 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 163 -
.../apache/iotdb/db/protocol/rest/RestService.java | 13 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 11 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 13 +-
.../qp/physical/crud/InsertMultiTabletsPlan.java | 6 -
.../iotdb/db/qp/physical/crud/InsertPlan.java | 2 -
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 12 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 6 -
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 6 -
.../db/qp/physical/crud/InsertTabletPlan.java | 35 -
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 26 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 2 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 79 +-
.../iotdb/db/query/control/SessionManager.java | 33 +-
.../db/query/control/SessionTimeoutManager.java | 4 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 3 +-
.../iotdb/db/query/dataset/IUDFInputDataSet.java | 42 +
.../dataset/RawQueryDataSetWithValueFilter.java | 1 -
.../iotdb/db/query/dataset/UDFInputDataSet.java | 1 -
.../UDFRawQueryInputDataSetWithoutValueFilter.java | 1 -
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 1 -
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 1 -
.../groupby/impl/LocalAlignedGroupByExecutor.java | 81 +-
.../groupby/impl/LocalGroupByExecutor.java | 59 +-
.../query/reader/chunk/MemAlignedPageReader.java | 52 +-
.../iotdb/db/rescon/PrimitiveArrayManager.java | 6 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 233 +-
.../db/service/DataNodeInternalRPCService.java | 95 -
.../service/DataNodeInternalRPCServiceMBean.java | 22 -
.../apache/iotdb/db/service/InternalService.java | 94 +
.../iotdb/db/service/InternalServiceMBean.java | 22 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 38 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 18 +-
.../org/apache/iotdb/db/service/MQTTService.java | 12 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 243 -
.../org/apache/iotdb/db/service/NewIoTDBMBean.java | 28 -
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../db/service/basic/QueryFrequencyRecorder.java | 4 +-
.../iotdb/db/service/metrics/enums/Metric.java | 8 +-
.../db/service/metrics/predefined/FileMetrics.java | 39 +-
.../metrics/recorder/CacheMetricsRecorder.java | 65 -
.../recorder/CompactionMetricsRecorder.java | 175 -
.../db/service/thrift/ProcessorWithMetrics.java | 4 +-
.../thrift/handler/RPCServiceThriftHandler.java | 7 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 1324 ----
.../impl/DataNodeInternalRPCServiceImpl.java | 540 --
.../thrift/impl/DataNodeTSIServiceImpl.java | 1302 ++++
.../thrift/impl/IClientRPCServiceWithHandler.java | 25 -
.../service/thrift/impl/InternalServiceImpl.java | 414 ++
.../db/service/thrift/impl/TSIEventHandler.java | 25 +
.../db/service/thrift/impl/TSServiceImpl.java | 4 +-
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 4 -
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 12 -
.../iotdb/db/sync/sender/service/MsgManager.java | 2 +-
.../db/sync/sender/service/SenderService.java | 5 -
.../db/sync/sender/service/TransportHandler.java | 21 +-
.../db/sync/transport/client/ClientWrapper.java | 125 -
.../db/sync/transport/client/ITransportClient.java | 2 -
.../db/sync/transport/client/TransportClient.java | 258 +-
.../transport/server/TransportServiceImpl.java | 29 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 15 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 30 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 6 -
.../db/utils/datastructure/AlignedTVList.java | 6 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 6 +-
.../db/utils/datastructure/BooleanTVList.java | 6 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 6 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 6 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 6 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 6 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 50 +-
.../allocation/AbstractNodeAllocationStrategy.java | 5 +-
.../db/wal/allocation/FirstCreateStrategy.java | 22 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 55 +-
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 8 +-
.../apache/iotdb/db/wal/buffer/SignalWALEntry.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 86 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 22 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 16 +-
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 24 +-
.../apache/iotdb/db/wal/io/CheckpointReader.java | 6 +-
.../org/apache/iotdb/db/wal/io/ILogWriter.java | 11 +-
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 8 +-
.../java/org/apache/iotdb/db/wal/io/WALWriter.java | 13 -
.../org/apache/iotdb/db/wal/node/IWALNode.java | 10 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 15 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 315 +-
.../db/wal/recover/CheckpointRecoverUtils.java | 14 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 74 +-
.../iotdb/db/wal/recover/WALRecoverManager.java | 83 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 4 +-
.../apache/iotdb/db/wal/utils/WALFileStatus.java | 50 -
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 63 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 38 +-
.../engine/compaction/CompactionSchedulerTest.java | 95 +-
.../compaction/CompactionTaskComparatorTest.java | 82 +-
.../compaction/CompactionTaskManagerTest.java | 133 +-
.../ReadPointCompactionPerformerTest.java | 137 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 27 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 15 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 37 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 20 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 9 +-
.../compaction/inner/InnerCompactionLogTest.java | 1 +
.../inner/InnerCompactionMoreDataTest.java | 5 +-
.../inner/InnerCompactionSchedulerTest.java | 4 +
.../compaction/inner/InnerSeqCompactionTest.java | 17 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 30 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 12 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 30 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 7 +-
.../SizeTieredCompactionRecoverTest.java | 70 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 18 +-
.../recover/SizeTieredCompactionRecoverTest.java | 38 +-
.../db/engine/storagegroup/DataRegionTest.java | 21 +-
.../storagegroup/StorageGroupProcessorTest.java | 9 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 24 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 2 +-
.../db/metadata/mtree/disk/MemManagerTest.java | 6 +-
.../db/metadata/schemaRegion/SchemaRegionTest.java | 70 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 9 +-
.../db/mpp/aggregation/TimeRangeIteratorTest.java | 22 +-
.../mpp/common/schematree/PathPatternTreeTest.java | 10 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 46 +-
.../db/mpp/execution/ConfigExecutionTest.java | 7 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 4 +-
.../datatransfer/DataBlockManagerTest.java | 121 +
.../datatransfer/LocalSinkHandleTest.java | 153 +
.../datatransfer/LocalSourceHandleTest.java | 119 +
.../datatransfer/SharedTsBlockQueueTest.java | 160 +
.../mpp/execution/datatransfer/SinkHandleTest.java | 528 ++
.../execution/datatransfer/SourceHandleTest.java | 642 ++
.../mpp/execution/datatransfer/StubSinkHandle.java | 99 +
.../iotdb/db/mpp/execution/datatransfer/Utils.java | 112 +
.../execution/exchange/LocalSinkHandleTest.java | 153 -
.../execution/exchange/LocalSourceHandleTest.java | 119 -
.../exchange/MPPDataExchangeManagerTest.java | 123 -
.../execution/exchange/SharedTsBlockQueueTest.java | 166 -
.../db/mpp/execution/exchange/SinkHandleTest.java | 524 --
.../mpp/execution/exchange/SourceHandleTest.java | 637 --
.../db/mpp/execution/exchange/StubSinkHandle.java | 99 -
.../iotdb/db/mpp/execution/exchange/Utils.java | 112 -
.../execution/memory/MemorySourceHandleTest.java | 2 +-
.../operator/AggregationOperatorTest.java | 3 +-
.../execution/operator/LinearFillOperatorTest.java | 532 +-
.../operator/RawDataAggregationOperatorTest.java | 12 -
.../SlidingWindowAggregationOperatorTest.java | 7 +-
.../schema/SchemaFetchScanOperatorTest.java | 17 +-
.../schedule/DefaultDriverSchedulerTest.java | 41 +-
.../execution/schedule/DriverSchedulerTest.java | 13 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 11 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 151 -
.../plan/analyze/AggregationDescriptorTest.java | 61 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 23 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 16 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 128 +-
.../distribution/AggregationDistributionTest.java | 293 +-
.../distribution/NoDataRegionPlanningTest.java | 84 -
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 4 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 9 +-
.../node/process/AggregationNodeSerdeTest.java | 36 +-
.../plan/plan/node/process/FillNodeSerdeTest.java | 3 +-
.../plan/node/process/FilterNodeSerdeTest.java | 3 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 18 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 2 +-
.../plan/node/write/DeleteRegionNodeSerdeTest.java | 60 +
.../plan/scheduler/StandaloneSchedulerTest.java | 518 --
.../db/protocol/mqtt/JSONPayloadFormatterTest.java | 58 -
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 7 +-
.../db/protocol/rest/GrafanaApiServiceIT.java | 359 +
.../db/protocol/rest/GrafanaApiServiceTest.java | 359 -
.../iotdb/db/protocol/rest/IoTDBRestServiceIT.java | 895 +++
.../db/protocol/rest/IoTDBRestServiceTest.java | 895 ---
.../ElasticSerializableTVListTest.java | 6 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 26 +-
.../org/apache/iotdb/db/script/EnvScriptIT.java | 9 +-
.../DataNodeInternalRPCServiceImplTest.java | 345 -
.../iotdb/db/service/InternalServiceImplTest.java | 400 ++
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 13 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 5 +-
.../datastructure/PrimitiveArrayManagerTest.java | 42 -
.../db/wal/allocation/FirstCreateStrategyTest.java | 3 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 16 +-
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 8 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 7 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 68 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 37 +-
.../db/wal/recover/WALRecoverManagerTest.java | 14 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 303 -
.../iotdb/db/wal/utils/WALFileUtilsTest.java | 162 +-
.../datanode1conf/iotdb-datanode.properties | 38 -
.../datanode1conf/iotdb-engine.properties | 38 +
.../test/resources/datanode1conf/iotdb-metric.yml | 34 +-
.../datanode2conf/iotdb-datanode.properties | 38 -
.../datanode2conf/iotdb-engine.properties | 38 +
.../test/resources/datanode2conf/iotdb-metric.yml | 34 +-
.../datanode3conf/iotdb-datanode.properties | 38 -
.../datanode3conf/iotdb-engine.properties | 38 +
.../test/resources/datanode3conf/iotdb-metric.yml | 34 +-
.../src/test/resources/iotdb-datanode.properties | 30 -
server/src/test/resources/iotdb-engine.properties | 30 +
server/src/test/resources/iotdb-rest.properties | 3 -
server/src/test/resources/logback-test.xml | 1 -
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 26 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 15 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 20 +-
.../org/apache/iotdb/rpc/SynchronizedHandler.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 20 +-
.../java/org/apache/iotdb/session/Session.java | 43 +-
.../apache/iotdb/session/SessionConnection.java | 18 +-
.../org/apache/iotdb/session/SessionDataSet.java | 6 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 150 +-
session/src/test/resources/iotdb-rest.properties | 3 -
site/src/main/.vuepress/config.js | 20 +-
testcontainer/Readme.md | 8 +-
testcontainer/pom.xml | 26 +
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 4 +-
.../src/test/resources/1node/docker-compose.yaml | 44 +
.../test/resources/1node/iotdb-cluster.properties | 35 +
.../src/test/resources/3nodes/docker-compose.yaml | 44 +
.../test/resources/3nodes/iotdb-cluster.properties | 35 +
.../src/test/resources/5nodes/docker-compose.yaml | 43 +
.../test/resources/5nodes/iotdb-cluster.properties | 35 +
.../src/test/resources/iotdb-datanode.properties | 24 -
.../src/test/resources/iotdb-engine.properties | 24 +
thrift-cluster/README.md | 22 +
thrift-cluster/pom.xml | 72 +
{thrift-sync => thrift-cluster}/rpc-changelist.md | 0
thrift-cluster/src/main/thrift/cluster.thrift | 584 ++
thrift-commons/src/main/thrift/common.thrift | 60 +-
.../src/main/thrift/confignode.thrift | 108 +-
.../src/main/thrift/mutlileader.thrift | 8 +-
thrift/src/main/thrift/client.thrift | 499 --
thrift/src/main/thrift/datanode.thrift | 298 -
thrift/src/main/thrift/mpp.thrift | 259 +
thrift/src/main/thrift/rpc.thrift | 499 ++
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../tsfile/file/metadata/enums/TSDataType.java | 6 +-
.../file/metadata/statistics/Statistics.java | 20 +-
.../file/metadata/statistics/TimeStatistics.java | 14 -
.../org/apache/iotdb/tsfile/read/common/Path.java | 15 +-
.../block/column/BinaryArrayColumnEncoder.java | 5 +-
.../block/column/ByteArrayColumnEncoder.java | 5 +-
.../read/common/block/column/ColumnEncoder.java | 9 +-
.../common/block/column/ColumnEncoderFactory.java | 3 +-
.../read/common/block/column/ColumnEncoding.java | 6 +-
.../block/column/Int32ArrayColumnEncoder.java | 8 +-
.../block/column/Int64ArrayColumnEncoder.java | 21 +-
.../block/column/RunLengthColumnEncoder.java | 54 -
.../block/column/RunLengthEncodedColumn.java | 2 +-
.../read/common/block/column/TimeColumn.java | 4 -
.../read/common/block/column/TsBlockSerde.java | 19 +-
.../iotdb/tsfile/read/filter/TimeFilter.java | 12 -
.../tsfile/read/filter/factory/FilterFactory.java | 4 -
.../read/filter/factory/FilterSerializeId.java | 3 +-
.../iotdb/tsfile/read/filter/operator/Between.java | 141 -
.../tsfile/read/query/dataset/QueryDataSet.java | 4 -
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 43 +-
.../java/org/apache/iotdb/tsfile/utils/Pair.java | 8 -
.../common/block/BinaryArrayColumnEncoderTest.java | 8 +-
.../common/block/ByteArrayColumnEncoderTest.java | 9 +-
.../common/block/Int32ArrayColumnEncoderTest.java | 15 +-
.../common/block/Int64ArrayColumnEncoderTest.java | 17 +-
.../common/block/RunLengthColumnEncoderTest.java | 101 -
udf-api/pom.xml | 60 -
.../main/java/org/apache/iotdb/udf/api/UDF.java | 40 -
.../main/java/org/apache/iotdb/udf/api/UDTF.java | 120 -
.../java/org/apache/iotdb/udf/api/access/Row.java | 130 -
.../apache/iotdb/udf/api/access/RowIterator.java | 47 -
.../org/apache/iotdb/udf/api/access/RowWindow.java | 102 -
.../iotdb/udf/api/collector/PointCollector.java | 137 -
.../api/customizer/config/UDFConfigurations.java | 37 -
.../api/customizer/config/UDTFConfigurations.java | 105 -
.../parameter/UDFParameterValidator.java | 202 -
.../api/customizer/parameter/UDFParameters.java | 138 -
.../api/customizer/strategy/AccessStrategy.java | 57 -
.../strategy/RowByRowAccessStrategy.java | 61 -
.../strategy/SlidingSizeWindowAccessStrategy.java | 123 -
.../strategy/SlidingTimeWindowAccessStrategy.java | 230 -
.../UDFAttributeNotProvidedException.java | 27 -
.../iotdb/udf/api/exception/UDFException.java | 31 -
.../UDFInputSeriesDataTypeNotValidException.java | 41 -
.../UDFInputSeriesIndexNotValidException.java | 30 -
.../UDFInputSeriesNumberNotValidException.java | 38 -
.../UDFOutputSeriesDataTypeNotValidException.java | 30 -
.../exception/UDFParameterNotValidException.java | 27 -
.../api/exception/UDFRegistrationException.java | 32 -
.../java/org/apache/iotdb/udf/api/type/Binary.java | 150 -
.../java/org/apache/iotdb/udf/api/type/Type.java | 50 -
1937 files changed, 134948 insertions(+), 108389 deletions(-)
delete mode 100644 .github/workflows/cluster-it.yml
create mode 100644 .github/workflows/cluster.yml
delete mode 100644 .github/workflows/standalone-it-for-mpp.yml
delete mode 100644 client-py/iotdb/dbapi/Connection.py
delete mode 100644 client-py/iotdb/dbapi/Cursor.py
delete mode 100644 client-py/iotdb/dbapi/Exceptions.py
delete mode 100644 client-py/iotdb/dbapi/__init__.py
delete mode 100644 client-py/iotdb/dbapi/tests/__init__.py
delete mode 100644 client-py/iotdb/dbapi/tests/test_connection.py
delete mode 100644 client-py/iotdb/dbapi/tests/test_cursor.py
delete mode 100644 client-py/iotdb/sqlalchemy/IoTDBDialect.py
delete mode 100644 client-py/iotdb/sqlalchemy/IoTDBIdentifierPreparer.py
delete mode 100644 client-py/iotdb/sqlalchemy/IoTDBSQLCompiler.py
delete mode 100644 client-py/iotdb/sqlalchemy/IoTDBTypeCompiler.py
delete mode 100644 client-py/iotdb/sqlalchemy/__init__.py
delete mode 100644 client-py/iotdb/sqlalchemy/tests/__init__.py
delete mode 100644 client-py/iotdb/sqlalchemy/tests/test_dialect.py
delete mode 100644 client-py/iotdb/template/InternalNode.py
delete mode 100644 client-py/iotdb/template/MeasurementNode.py
delete mode 100644 client-py/iotdb/template/Template.py
delete mode 100644 client-py/iotdb/template/TemplateNode.py
delete mode 100644 client-py/iotdb/template/TemplateQueryType.py
delete mode 100644 client-py/iotdb/template/__init__.py
delete mode 100644 client-py/iotdb/tsfile/__init__.py
delete mode 100644 client-py/iotdb/tsfile/common/__init__.py
delete mode 100644 client-py/iotdb/tsfile/common/constant/TsFileConstant.py
delete mode 100644 client-py/iotdb/tsfile/common/constant/__init__.py
delete mode 100644 client-py/iotdb/tsfile/utils/Pair.py
delete mode 100644 client-py/iotdb/tsfile/utils/ReadWriteIOUtils.py
delete mode 100644 client-py/iotdb/tsfile/utils/__init__.py
delete mode 100644 client-py/tests/test_template.py
create mode 100644 cluster/pom.xml
create mode 100644 cluster/src/assembly/cluster.xml
create mode 100644 cluster/src/assembly/resources/conf/iotdb-cluster.properties
create mode 100755 cluster/src/assembly/resources/sbin/add-node.bat
create mode 100755 cluster/src/assembly/resources/sbin/add-node.sh
create mode 100755 cluster/src/assembly/resources/sbin/nodetool.bat
create mode 100755 cluster/src/assembly/resources/sbin/nodetool.sh
create mode 100755 cluster/src/assembly/resources/sbin/remove-node.bat
create mode 100755 cluster/src/assembly/resources/sbin/remove-node.sh
create mode 100755 cluster/src/assembly/resources/sbin/start-node.bat
create mode 100755 cluster/src/assembly/resources/sbin/start-node.sh
create mode 100644 cluster/src/assembly/resources/sbin/stop-node.bat
create mode 100644 cluster/src/assembly/resources/sbin/stop-node.sh
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClientMain.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterFileFlushPolicy.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDB.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBServerCommandLine.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/RemoteTsFileResource.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/BaseFactory.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/ClientCategory.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/ClientManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/ClientPoolFactory.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/IClientManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncBaseFactory.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncDataClient.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncMetaClient.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConfig.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConstant.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterDescriptor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ConsistencyLevel.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/AddSelfException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/BadSeedUrlFormatException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/ChangeMembershipException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/CheckConsistencyException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/ConfigInconsistentException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/EmptyIntervalException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryCompactedException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryUnavailableException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/GetEntriesWrongParametersException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/LeaderUnknownException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/MemberReadOnlyException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/NoHeaderNodeException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/NotInSameGroupException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/NotManagedSlotException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/PartitionTableUnavailableException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/PullFileException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/QueryTimeOutException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/ReaderNotFoundException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/RequestTimeOutException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/SnapshotInstallationException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/StartUpCheckFailureException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/TruncateCommittedEntryException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/UnknownLogTypeException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/UnsupportedPlanException.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogCallback.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogTask.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/HardState.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/Log.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/LogApplier.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/LogParser.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/Snapshot.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/StableEntryManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/AsyncDataLogApplier.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/BaseApplier.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/DataLogApplier.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/MetaLogApplier.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/CatchUpTask.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/LogCatchUpTask.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/SnapshotCatchUpTask.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/AddNodeLog.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/CloseFileLog.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/EmptyContentLog.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/LargeTestLog.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/PhysicalPlanLog.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/RemoveNodeLog.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/FilePartitionedSnapshotLogManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/MetaSingleSnapshotLogManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/PartitionedSnapshotLogManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/LogManagerMeta.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/FileSnapshot.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshot.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PartitionedSnapshot.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTask.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskDescriptor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotInstaller.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/TimeseriesSchemaSnapshot.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/CSchemaProcessor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/MetaPuller.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeAdditionResult.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeRemovalResult.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/PartitionGroup.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/PartitionTable.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/DefaultSlotBalancer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/SlotBalancer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeAdditionResult.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeRemovalResult.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotPartitionTable.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotStrategy.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotTimePartitionFilter.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterDataQueryExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPhysicalGenerator.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanRouter.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterQueryRouter.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/aggregate/ClusterAggregateExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/aggregate/ClusterAggregator.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterFillExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterLinearFill.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterPreviousFill.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/PreviousFillArguments.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotSgFilter.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotTsFileFilter.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSet.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByVFilterDataSet.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/last/ClusterLastQueryExecutor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterSessionManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/manage/QueryCoordinator.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ClusterReaderFactory.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ClusterTimeGenerator.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/DataSourceInfo.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/EmptyReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ManagedDescPriorityMergeReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ManagedPriorityMergeReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/MergedReaderByTime.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/RemoteSeriesReaderByTimestamp.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AbstractMultPointReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathAscPriorityMergeReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathDescPriorityMergeReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IAssignPathPriorityMergeReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IMultBatchReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultBatchReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultDataSourceInfo.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultElement.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultEmptyReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReader.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterRPCService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterRPCServiceMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterTSServiceImpl.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/HardLinkCleaner.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/NodeCharacter.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/PullSnapshotHintService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/Response.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/StoppedMemberManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/basic/ClusterServiceProvider.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImpl.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceThriftHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GenericHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetChildNodeNextLevelHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetChildNodeNextLevelPathHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetDevicesHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetNodesListHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetTimeseriesSchemaHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/JoinClusterHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpInBatchHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/NodeStatusHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PreviousFillHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullMeasurementSchemaHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullSnapshotHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullTimeseriesSchemaHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/ShowTimeSeriesHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/SnapshotCatchUpHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/package-info.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/forwarder/ForwardPlanHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThread.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMemberMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMemberMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMemberMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/package-info.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeReport.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeStatus.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeStatusManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Peer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractDataRaftService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractMetaRaftService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractRaftService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatServiceMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftServiceMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatServiceMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftServiceMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/BaseAsyncService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/BaseSyncService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataAsyncService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngine.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngineMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupServiceImpls.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataSyncService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaAsyncService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaSyncService.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/package-info.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClientUtils.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterConsistent.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterNode.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterQueryUtils.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterUtils.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/IOUtils.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/NodeSerializeUtils.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/PartitionUtils.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/StatusUtils.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitorMBean.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/NodeTool.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/Printer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Header.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/LogView.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Migration.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/NodeToolCmd.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Partition.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Ring.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Slot.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Status.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/BaseClientTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/ClientManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/ClientPoolFactoryTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/MockClientManager.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncDataClientTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncMetaClientTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncDataClientTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncMetaClientTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/IoTDBTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncClient.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncDataClient.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncMetaClient.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestDataGroupMember.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestLog.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogApplier.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestManagedSeriesReader.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestMetaGroupMember.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestPartitionedLogManager.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestSnapshot.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestSyncClient.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestUtils.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/integration/BaseSingleNodeTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/integration/SingleNodeTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogCallbackTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogTaskTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/HardStateTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/LogDispatcherTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/LogParserTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/applier/AsyncDataLogApplierTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/applier/DataLogApplierTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/applier/MetaLogApplierTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/CatchUpTaskTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/LogCatchUpTaskTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/SnapshotCatchUpTaskTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/logtypes/SerializeLogTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/FilePartitionedSnapshotLogManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/MetaSingleSnapshotLogManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/DataSnapshotTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/FileSnapshotTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshotTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PartitionedSnapshotTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskDescriptorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/SimpleSnapshot.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/SchemaProcessorWhiteBox.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/SlotManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/SlotPartitionTableTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/BaseQueryTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterAggregateExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterDataQueryExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPhysicalGeneratorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPlanExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPlannerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/LoadConfigurationTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/fill/ClusterFillExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSetTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByVFilterDataSetTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/last/ClusterLastQueryExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/manage/QueryCoordinatorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/ClusterReaderFactoryTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/ClusterTimeGeneratorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSeriesReaderByTimestampTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReaderTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImplTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/GenericHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/JoinClusterHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/PullMeasurementSchemaHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/PullSnapshotHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/SnapshotCatchUpHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/forwarder/ForwardPlanHandlerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThreadTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThreadTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThreadTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/BaseMember.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/DataGroupMemberTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/MetaGroupMemberTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/RaftMemberTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/utils/CreateTemplatePlanUtil.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/utils/SerializeUtilTest.java
create mode 100644 cluster/src/test/resources/logback-test.xml
create mode 100644 cluster/src/test/resources/node1conf/iotdb-cluster.properties
create mode 100644 cluster/src/test/resources/node1conf/iotdb-engine.properties
create mode 100644 cluster/src/test/resources/node1conf/iotdb-metric.yml
create mode 100644 cluster/src/test/resources/node1conf/logback.xml
create mode 100644 cluster/src/test/resources/node2conf/iotdb-cluster.properties
create mode 100644 cluster/src/test/resources/node2conf/iotdb-engine.properties
create mode 100644 cluster/src/test/resources/node2conf/iotdb-metric.yml
create mode 100644 cluster/src/test/resources/node2conf/logback.xml
create mode 100644 cluster/src/test/resources/node3conf/iotdb-cluster.properties
create mode 100644 cluster/src/test/resources/node3conf/iotdb-engine.properties
create mode 100644 cluster/src/test/resources/node3conf/iotdb-metric.yml
create mode 100644 cluster/src/test/resources/node3conf/logback.xml
delete mode 100644 confignode/src/assembly/resources/sbin/remove-confignode.sh
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/AsyncConfigNodeClientPool.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/ConfigNodeHeartbeatHandler.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/DataNodeHeartbeatHandler.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/FlushHandler.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/HeartbeatHandler.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/SetTTLHandler.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConf.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/SystemPropertiesUtils.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanType.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigRequest.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigRequestType.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/auth/AuthorPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/auth/AuthorReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/CountStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/CountStorageGroupReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetDataNodeInfoPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetDataNodeInfoReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetDataPartitionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetNodePathsPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetNodePathsPartitionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateDataPartitionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateSchemaPartitionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetRegionInfoListPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaPartitionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetStorageGroupReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ActivateDataNodePlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/AdjustMaxRegionGroupCountPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ApplyConfigNodePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ApplyConfigNodeReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateDataPartitionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateFunctionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateFunctionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateRegionGroupsPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateRegionsReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateSchemaPartitionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteProcedurePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteProcedureReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteRegionsPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteRegionsReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteStorageGroupReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DropFunctionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DropFunctionReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/PreDeleteStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/PreDeleteStorageGroupReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RegisterDataNodePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RegisterDataNodeReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RemoveConfigNodePlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetDataReplicationFactorPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetDataReplicationFactorReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetSchemaReplicationFactorPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetSchemaReplicationFactorReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetStorageGroupReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetTTLPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetTTLReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetTimePartitionIntervalPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetTimePartitionIntervalReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/UpdateProcedurePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/UpdateProcedureReq.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/RegionInfoListResp.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/exception/AddPeerException.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/exception/StorageGroupNotExistsException.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/exception/TimeoutException.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/SeriesPartitionSlotBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/allocator/CopySetRegionAllocator.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/allocator/IRegionAllocator.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/GreedyPartitionAllocator.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/IPartitionAllocator.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/CopySetRegionAllocator.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/IRegionAllocator.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/IRouter.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouter.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LoadScoreGreedyRouter.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/ConfigNodeHeartbeatCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/DataNodeHeartbeatCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatWindow.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/IRegionGroupCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/RegionGroupCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/DataPartitionRule.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/PartitionInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigPlanExecutor.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigRequestExecutor.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionGroup.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/StorageGroupPartitionTable.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/AddConfigNodeProcedure.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/cli/TemporaryClientDemo.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigRequestSerDeTest.java
delete mode 100644 confignode/src/test/resources/confignode1conf/iotdb-metric.yml
delete mode 100644 confignode/src/test/resources/confignode2conf/iotdb-metric.yml
delete mode 100644 confignode/src/test/resources/confignode3conf/iotdb-metric.yml
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/ConsensusConfig.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/RatisConfig.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/conf/MultiLeaderConsensusConfig.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/FileInfoWithDelayedMd5Computing.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/RecoveryTest.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/FakeConsensusReqReader.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/RequestSets.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestEntry.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestStateMachine.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/standalone/EmptyStateMachine.java
delete mode 100644 distribution/src/assembly/datanode.xml
create mode 100644 distribution/src/assembly/server.xml
create mode 100644 docker/src/main/Dockerfile-cluster
delete mode 100644 docs/Development/HowtoContributeCode.md
delete mode 100644 docs/UserGuide/Cluster/Cluster-Concept.md
create mode 100644 docs/UserGuide/Cluster/Cluster-Setup-Example.md
create mode 100644 docs/UserGuide/Reference/Config-Manual.md
delete mode 100644 docs/UserGuide/Reference/ConfigNode-Config-Manual.md
delete mode 100644 docs/UserGuide/Reference/DataNode-Config-Manual.md
delete mode 100644 docs/zh/Development/HowtoContributeCode.md
delete mode 100644 docs/zh/UserGuide/Cluster/Cluster-Concept.md
create mode 100644 docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md
create mode 100644 docs/zh/UserGuide/Reference/Config-Manual.md
delete mode 100644 docs/zh/UserGuide/Reference/ConfigNode-Config-Manual.md
delete mode 100644 docs/zh/UserGuide/Reference/DataNode-Config-Manual.md
delete mode 100644 example/jdbc/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java
delete mode 100644 example/rest-java-example/pom.xml
delete mode 100644 example/rest-java-example/src/main/java/org/apache/iotdb/HttpExample.java
delete mode 100644 example/rest-java-example/src/main/java/org/apache/iotdb/HttpsExample.java
delete mode 100644 example/rest-java-example/src/main/java/org/apache/iotdb/SSLClient.java
delete mode 100644 example/session/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java
delete mode 100644 grafana-connector/src/main/java/org/apache/iotdb/web/grafana/interceptor/LoginInterceptor.java
rename grafana-metrics-example/{standalone => }/Apache IoTDB Dashboard v0.13.1.json (100%)
create mode 100644 grafana-metrics-example/Apache IoTDB Dashboard v0.14.0.json
delete mode 100644 grafana-metrics-example/cluster/Apache IoTDB ConfigNode Dashboard v0.14.0.json
delete mode 100644 grafana-metrics-example/cluster/Apache IoTDB DataNode Dashboard v0.14.0.json
delete mode 100644 grafana-metrics-example/standalone/Apache IoTDB Dashboard v0.14.0.json
delete mode 100644 integration-test/README.md
delete mode 100644 integration-test/checkstyle.xml
delete mode 100644 integration-test/import-control.xml
delete mode 100644 integration-test/pom.xml
delete mode 100644 integration-test/src/assembly/mpp-share.xml
delete mode 100644 integration-test/src/assembly/mpp-test.xml
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/Accumulator.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/Adder.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/Counter.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/ExampleUDFConstant.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/Max.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/Multiplier.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester0.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingTimeWindowConstructionTester.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/TerminateTester.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/ValidateTester.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/WindowStartEnd.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/AbstractEnv.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/AbstractNodeWrapper.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/Cluster1Env.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ConfigFactory.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ConfigNodeWrapper.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/DataNodeWrapper.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/EnvFactory.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/IoTDBTestRunner.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/MppConfig.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerConfig.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/StandaloneDataNodeWrapper.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/StandaloneOnMppEnv.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/category/ClusterIT.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/category/LocalStandaloneIT.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/category/RemoteIT.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinAggregationFunctionEnum.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinTimeSeriesGeneratingFunctionEnum.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/constant/TestConstant.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/constant/UDFTestConstant.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseConfig.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/exception/InconsistentDataException.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/exception/ParallelRequestTimeoutException.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterResultSetMetaData.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestConnection.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestStatement.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/NodeConnection.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ParallelRequestDelegate.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestDelegate.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestThreadPool.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/runtime/SerialRequestDelegate.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBAuthIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBCreateTimeseriesIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterBetweenIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterNullIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBNestedQueryIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBQuotedPathIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBSyntaxConventionIdentifierIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBSyntaxConventionStringLiteralIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBTimeZoneIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationByLevelIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationDeleteIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationLargeDataIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationSmallDataIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBAlignByDeviceIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/AlignedWriteUtil.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAggregationWithDeletion2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAggregationWithDeletionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBGroupByLevelQueryIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBGroupByQueryWithValueFilterWithDeletion2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBGroupByQueryWithValueFilterWithDeletionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletion2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletion2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnv.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnvConfig.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IOTDBGroupByIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByNaturalMonthIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAliasIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBNullValueFillIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBPaginationIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBQueryWithComplexValueFilterIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBResultSetIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFManagementIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDTFBuiltinFunctionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/utils/TestUtils.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/withoutNull/IoTDBWithoutAllNullIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/withoutNull/IoTDBWithoutAnyNullIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/withoutNull/IoTDBWithoutNullAllFilterIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/withoutNull/IoTDBWithoutNullAnyFilterIT.java
delete mode 100644 integration-test/src/test/resources/iotdb-engine.properties
delete mode 100644 integration-test/src/test/resources/logback-test.xml
delete mode 100644 integration/checkstyle.xml
delete mode 100644 integration/import-control.xml
rename integration/src/{main => test}/java/org/apache/iotdb/db/engine/trigger/example/Accumulator.java (100%)
rename integration/src/{main => test}/java/org/apache/iotdb/db/engine/trigger/example/Counter.java (100%)
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBAliasIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBAlignByDeviceIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBAsIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateTimeseriesIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLimitSlimitIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsfileWithVirtualSGIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBNumberPathIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBPathNumOverLimitIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryWithComplexValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQuotedPathIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBResultMetadataIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBResultSetIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTimeZoneIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFManagementIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBWithoutAllNullIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBWithoutAnyNullIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationByLevelIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationDeleteIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationLargeDataIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationSmallDataIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationGroupByLevelIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilter2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilterWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilterWithDeletionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilter2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterWithDeletionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDevice2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDeviceIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBEmptyDataIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilter2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilterWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilterWithDeletionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilter2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupBySlidingWindowQueryWithValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupBySlidingWindowQueryWithoutValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBInsertAlignedValuesIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQuery2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCache2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter3IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IOTDBGroupByIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IOTDBGroupByInnerIntervalIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByMonthFillIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByMonthIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByNaturalMonthFillIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByUnseqIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/withoutNullFilter/IoTDBWithoutNullAllFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/withoutNullFilter/IoTDBWithoutNullAnyFilterIT.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncDataNodeDataBlockServiceClient.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncDataNodeMPPDataExchangeServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeDataBlockServiceClient.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeMPPDataExchangeServiceClient.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeStatus.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cluster/RegionStatus.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/ScheduledExecutorUtil.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionTable.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartitionTable.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SeriesPartitionTable.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/UDF.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/UDTF.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/access/Row.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/access/RowIterator.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/access/RowWindow.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/collector/PointCollector.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/config/UDFConfigurations.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/config/UDTFConfigurations.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/parameter/UDFParameterValidator.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/parameter/UDFParameters.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/strategy/AccessStrategy.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/strategy/RowByRowAccessStrategy.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/strategy/SlidingSizeWindowAccessStrategy.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/strategy/SlidingTimeWindowAccessStrategy.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFAttributeNotProvidedException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFInputSeriesIndexNotValidException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFInputSeriesNumberNotValidException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFOutputSeriesDataTypeNotValidException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFParameterNotValidException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFRegistrationException.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFConcat.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFEndsWith.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFLower.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStartsWith.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrCompare.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLength.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLocate.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFSubstr.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFTrim.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFUpper.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/UDFBinaryTransformer.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/UDFDataTypeTransformer.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/ClientManagerTest.java
delete mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerTest.java
delete mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java
delete mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCServiceMBean.java
delete mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/partition/DataPartitionTableTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/partition/DataPartitionTest.java
delete mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/partition/SchemaPartitionTableTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/partition/SchemaPartitionTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/partition/SerializeTest.java
delete mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/partition/SeriesPartitionTableTest.java
delete mode 100644 server/src/assembly/resources/conf/datanode-env.bat
delete mode 100755 server/src/assembly/resources/conf/datanode-env.sh
delete mode 100644 server/src/assembly/resources/conf/iotdb-datanode.properties
create mode 100644 server/src/assembly/resources/conf/iotdb-engine.properties
create mode 100644 server/src/assembly/resources/conf/iotdb-env.bat
create mode 100755 server/src/assembly/resources/conf/iotdb-env.sh
delete mode 100644 server/src/assembly/resources/sbin/start-new-server.bat
delete mode 100644 server/src/assembly/resources/sbin/start-new-server.sh
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/AuthorityFetcher.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/auth/IAuthorityFetcher.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionMetricsManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionWorker.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/http/HTTPForwardConfiguration.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/http/HTTPForwardEvent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/http/HTTPForwardHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/mqtt/MQTTForwardConfiguration.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/mqtt/MQTTForwardEvent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/mqtt/MQTTForwardHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardConfiguration.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardEvent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardConfiguration.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardEvent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementAlreadyExistException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/runtime/SerializationRunTimeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sql/MeasurementNotExistException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sql/PathNumOverLimitException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/visitor/MNodeVisitor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/snapshot/MemMTreeSnapshotUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/utils/TimeseriesVersionUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockServiceMBean.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockServiceThriftHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/IDataBlockManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/IDataBlockManagerCallback.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/ISinkHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/ISourceHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSourceHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SharedTsBlockQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SinkHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/TsBlockSerdeFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/IMPPDataExchangeManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/IMPPDataExchangeManagerCallback.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/ISinkHandle.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/ISourceHandle.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSinkHandle.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSourceHandle.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeServiceMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeServiceThriftHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SinkHandle.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SourceHandle.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/TsBlockSerdeFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterNullOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/FragmentSinkOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/StepTracker.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/DataNodeEndPoints.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/AuthorizerConfigTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/AuthorizerTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/FlushTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowClusterTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowDataNodesTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowFunctionsTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowRegionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/IConfigTaskExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandaloneConfigTaskExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/ternary/BetweenExpression.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/ternary/TernaryExpression.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/unary/IsNullExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/DeleteRegionNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/InternalCreateTimeSeriesNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/InternalCreateTimeSeriesStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateTimeSeriesByDeviceStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowClusterStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowDataNodesStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowFunctionsStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowRegionStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/ExplainStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/FlushStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/ShowVersionStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/api/YieldableReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/api/YieldableState.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/input/IUDFInputDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/ternary/BetweenTransformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/ternary/CompareTernaryTransformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/ternary/TernaryTransformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/unary/IsNullTransformer.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/handler/StatementConstructionHandler.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/MPPPublishHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/IUDFInputDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCServiceMBean.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/InternalService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/InternalServiceMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/NewIoTDB.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/NewIoTDBMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CacheMetricsRecorder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CompactionMetricsRecorder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/IClientRPCServiceWithHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSIEventHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/ClientWrapper.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/WALFileStatus.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSourceHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/SharedTsBlockQueueTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/SinkHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/StubSinkHandle.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/Utils.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSinkHandleTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSourceHandleTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueueTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/SinkHandleTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/SourceHandleTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/StubSinkHandle.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/Utils.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/StandaloneCoordinatorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/NoDataRegionPlanningTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/DeleteRegionNodeSerdeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneSchedulerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/rest/GrafanaApiServiceIT.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/rest/GrafanaApiServiceTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/rest/IoTDBRestServiceIT.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/rest/IoTDBRestServiceTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/service/DataNodeInternalRPCServiceImplTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/utils/datastructure/PrimitiveArrayManagerTest.java
delete mode 100644 server/src/test/resources/datanode1conf/iotdb-datanode.properties
create mode 100644 server/src/test/resources/datanode1conf/iotdb-engine.properties
delete mode 100644 server/src/test/resources/datanode2conf/iotdb-datanode.properties
create mode 100644 server/src/test/resources/datanode2conf/iotdb-engine.properties
delete mode 100644 server/src/test/resources/datanode3conf/iotdb-datanode.properties
create mode 100644 server/src/test/resources/datanode3conf/iotdb-engine.properties
delete mode 100644 server/src/test/resources/iotdb-datanode.properties
create mode 100644 server/src/test/resources/iotdb-engine.properties
create mode 100644 testcontainer/src/test/resources/1node/docker-compose.yaml
create mode 100644 testcontainer/src/test/resources/1node/iotdb-cluster.properties
create mode 100644 testcontainer/src/test/resources/3nodes/docker-compose.yaml
create mode 100644 testcontainer/src/test/resources/3nodes/iotdb-cluster.properties
create mode 100644 testcontainer/src/test/resources/5nodes/docker-compose.yaml
create mode 100644 testcontainer/src/test/resources/5nodes/iotdb-cluster.properties
delete mode 100644 testcontainer/src/test/resources/iotdb-datanode.properties
create mode 100644 testcontainer/src/test/resources/iotdb-engine.properties
create mode 100644 thrift-cluster/README.md
create mode 100644 thrift-cluster/pom.xml
copy {thrift-sync => thrift-cluster}/rpc-changelist.md (100%)
create mode 100644 thrift-cluster/src/main/thrift/cluster.thrift
delete mode 100644 thrift/src/main/thrift/client.thrift
delete mode 100644 thrift/src/main/thrift/datanode.thrift
create mode 100644 thrift/src/main/thrift/mpp.thrift
create mode 100644 thrift/src/main/thrift/rpc.thrift
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/RunLengthColumnEncoder.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Between.java
delete mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/RunLengthColumnEncoderTest.java
delete mode 100644 udf-api/pom.xml
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/UDF.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/UDTF.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/access/Row.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/access/RowIterator.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/access/RowWindow.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/collector/PointCollector.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/config/UDFConfigurations.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/config/UDTFConfigurations.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/parameter/UDFParameterValidator.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/parameter/UDFParameters.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/AccessStrategy.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/RowByRowAccessStrategy.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/SlidingSizeWindowAccessStrategy.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/SlidingTimeWindowAccessStrategy.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFAttributeNotProvidedException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFInputSeriesIndexNotValidException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFInputSeriesNumberNotValidException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFOutputSeriesDataTypeNotValidException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFParameterNotValidException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFRegistrationException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/type/Binary.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/type/Type.java