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/06/26 09:16:18 UTC
[iotdb] branch rename updated (26dbdfcca9 -> c912e575fc)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch rename
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 26dbdfcca9 change HostAdress to Host
add 11c6c331e6 remove old cluster module from master branch (#6446)
add 8c82eb14bb upgrade spotless to fix jvmargs issue (#6441)
add 4b6e722721 Merge remote-tracking branch 'origin/master' into rename
add c912e575fc rename rpc_ip to rpc_address
No new revisions were added by this update.
Summary of changes:
README.md | 14 -
README_ZH.md | 13 -
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 | 675 ------
.../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 | 1038 ---------
.../log/manage/UnCommittedEntryManager.java | 276 ---
.../log/manage/serializable/LogManagerMeta.java | 143 --
.../serializable/SyncLogDequeSerializer.java | 1409 -------------
.../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 | 181 --
.../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 | 325 ---
.../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 ---
.../resources/conf/iotdb-confignode.properties | 4 +-
.../assembly/resources/sbin/stop-confignode.bat | 6 +-
.../confignode/conf/ConfigNodeDescriptor.java | 2 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 6 +-
.../confignode1conf/iotdb-confignode.properties | 2 +-
.../confignode2conf/iotdb-confignode.properties | 2 +-
.../confignode3conf/iotdb-confignode.properties | 2 +-
docker/src/main/Dockerfile-cluster | 44 -
docs/Development/ContributeGuide.md | 14 -
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 16 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 8 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 18 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 12 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 2 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 4 +-
pom.xml | 6 +-
.../resources/conf/iotdb-engine.properties | 4 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 6 +-
server/src/assembly/resources/sbin/stop-server.bat | 6 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../datanode1conf/iotdb-engine.properties | 4 +-
.../datanode2conf/iotdb-engine.properties | 4 +-
.../datanode3conf/iotdb-engine.properties | 4 +-
server/src/test/resources/iotdb-engine.properties | 2 +-
testcontainer/pom.xml | 14 -
thrift-cluster/README.md | 22 -
thrift-cluster/pom.xml | 72 -
thrift-cluster/rpc-changelist.md | 181 --
thrift-cluster/src/main/thrift/cluster.thrift | 584 ------
398 files changed, 60 insertions(+), 69200 deletions(-)
delete mode 100644 cluster/pom.xml
delete mode 100644 cluster/src/assembly/cluster.xml
delete mode 100644 cluster/src/assembly/resources/conf/iotdb-cluster.properties
delete mode 100755 cluster/src/assembly/resources/sbin/add-node.bat
delete mode 100755 cluster/src/assembly/resources/sbin/add-node.sh
delete mode 100755 cluster/src/assembly/resources/sbin/nodetool.bat
delete mode 100755 cluster/src/assembly/resources/sbin/nodetool.sh
delete mode 100755 cluster/src/assembly/resources/sbin/remove-node.bat
delete mode 100755 cluster/src/assembly/resources/sbin/remove-node.sh
delete mode 100755 cluster/src/assembly/resources/sbin/start-node.bat
delete mode 100755 cluster/src/assembly/resources/sbin/start-node.sh
delete mode 100644 cluster/src/assembly/resources/sbin/stop-node.bat
delete mode 100644 cluster/src/assembly/resources/sbin/stop-node.sh
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClientMain.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterFileFlushPolicy.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDB.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBServerCommandLine.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/RemoteTsFileResource.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/BaseFactory.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/ClientCategory.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/ClientManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/ClientPoolFactory.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/IClientManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncBaseFactory.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncDataClient.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncMetaClient.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConfig.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConstant.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterDescriptor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ConsistencyLevel.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/AddSelfException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/BadSeedUrlFormatException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/ChangeMembershipException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/CheckConsistencyException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/ConfigInconsistentException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/EmptyIntervalException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryCompactedException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryUnavailableException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/GetEntriesWrongParametersException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/LeaderUnknownException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/MemberReadOnlyException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/NoHeaderNodeException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/NotInSameGroupException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/NotManagedSlotException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/PartitionTableUnavailableException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/PullFileException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/QueryTimeOutException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/ReaderNotFoundException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/RequestTimeOutException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/SnapshotInstallationException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/StartUpCheckFailureException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/TruncateCommittedEntryException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/UnknownLogTypeException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/exception/UnsupportedPlanException.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogCallback.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogTask.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/HardState.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/Log.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/LogApplier.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/LogParser.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/Snapshot.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/StableEntryManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/AsyncDataLogApplier.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/BaseApplier.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/DataLogApplier.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/applier/MetaLogApplier.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/CatchUpTask.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/LogCatchUpTask.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/SnapshotCatchUpTask.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/AddNodeLog.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/CloseFileLog.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/EmptyContentLog.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/LargeTestLog.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/PhysicalPlanLog.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/RemoveNodeLog.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/FilePartitionedSnapshotLogManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/MetaSingleSnapshotLogManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/PartitionedSnapshotLogManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/LogManagerMeta.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/FileSnapshot.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshot.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PartitionedSnapshot.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTask.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskDescriptor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotInstaller.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/TimeseriesSchemaSnapshot.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/CSchemaProcessor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/MetaPuller.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeAdditionResult.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeRemovalResult.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/PartitionGroup.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/PartitionTable.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/DefaultSlotBalancer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/SlotBalancer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeAdditionResult.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeRemovalResult.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotPartitionTable.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotStrategy.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotTimePartitionFilter.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterDataQueryExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPhysicalGenerator.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanRouter.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterQueryRouter.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/aggregate/ClusterAggregateExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/aggregate/ClusterAggregator.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterFillExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterLinearFill.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterPreviousFill.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/fill/PreviousFillArguments.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotSgFilter.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotTsFileFilter.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSet.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByVFilterDataSet.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/last/ClusterLastQueryExecutor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterSessionManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/manage/QueryCoordinator.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ClusterReaderFactory.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ClusterTimeGenerator.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/DataSourceInfo.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/EmptyReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ManagedDescPriorityMergeReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ManagedPriorityMergeReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/MergedReaderByTime.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/RemoteSeriesReaderByTimestamp.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AbstractMultPointReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathAscPriorityMergeReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathDescPriorityMergeReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IAssignPathPriorityMergeReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IMultBatchReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultBatchReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultDataSourceInfo.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultElement.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultEmptyReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReader.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterRPCService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterRPCServiceMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterTSServiceImpl.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/HardLinkCleaner.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/NodeCharacter.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/PullSnapshotHintService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/Response.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/StoppedMemberManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/basic/ClusterServiceProvider.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImpl.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceThriftHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GenericHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetChildNodeNextLevelHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetChildNodeNextLevelPathHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetDevicesHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetNodesListHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetTimeseriesSchemaHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/JoinClusterHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpInBatchHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/NodeStatusHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PreviousFillHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullMeasurementSchemaHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullSnapshotHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullTimeseriesSchemaHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/ShowTimeSeriesHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/SnapshotCatchUpHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/package-info.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/forwarder/ForwardPlanHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThread.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMemberMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMemberMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMemberMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/package-info.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeReport.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeStatus.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeStatusManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Peer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractDataRaftService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractMetaRaftService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractRaftService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatServiceMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftServiceMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatServiceMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftServiceMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/BaseAsyncService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/BaseSyncService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataAsyncService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngine.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngineMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupServiceImpls.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataSyncService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaAsyncService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaSyncService.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/service/package-info.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClientUtils.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterConsistent.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterNode.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterQueryUtils.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterUtils.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/IOUtils.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/NodeSerializeUtils.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/PartitionUtils.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/StatusUtils.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitor.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitorMBean.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/NodeTool.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/Printer.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Header.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/LogView.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Migration.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/NodeToolCmd.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Partition.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Ring.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Slot.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Status.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/BaseClientTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/ClientManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/ClientPoolFactoryTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/MockClientManager.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncDataClientTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncMetaClientTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncDataClientTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncMetaClientTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/IoTDBTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncClient.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncDataClient.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncMetaClient.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestDataGroupMember.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestLog.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogApplier.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestManagedSeriesReader.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestMetaGroupMember.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestPartitionedLogManager.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestSnapshot.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestSyncClient.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestUtils.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/integration/BaseSingleNodeTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/integration/SingleNodeTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogCallbackTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogTaskTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/HardStateTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/LogDispatcherTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/LogParserTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/applier/AsyncDataLogApplierTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/applier/DataLogApplierTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/applier/MetaLogApplierTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/CatchUpTaskTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/LogCatchUpTaskTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/SnapshotCatchUpTaskTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/logtypes/SerializeLogTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/FilePartitionedSnapshotLogManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/MetaSingleSnapshotLogManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/DataSnapshotTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/FileSnapshotTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshotTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PartitionedSnapshotTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskDescriptorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/SimpleSnapshot.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/SchemaProcessorWhiteBox.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/SlotManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/SlotPartitionTableTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/BaseQueryTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterAggregateExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterDataQueryExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPhysicalGeneratorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPlanExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPlannerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/LoadConfigurationTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/fill/ClusterFillExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSetTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByVFilterDataSetTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/last/ClusterLastQueryExecutorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/manage/QueryCoordinatorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/ClusterReaderFactoryTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/ClusterTimeGeneratorTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSeriesReaderByTimestampTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReaderTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImplTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/GenericHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/JoinClusterHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/PullMeasurementSchemaHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/PullSnapshotHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/SnapshotCatchUpHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/forwarder/ForwardPlanHandlerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThreadTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThreadTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThreadTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/BaseMember.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/DataGroupMemberTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/MetaGroupMemberTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/RaftMemberTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/utils/CreateTemplatePlanUtil.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/utils/SerializeUtilTest.java
delete mode 100644 cluster/src/test/resources/logback-test.xml
delete mode 100644 cluster/src/test/resources/node1conf/iotdb-cluster.properties
delete mode 100644 cluster/src/test/resources/node1conf/iotdb-engine.properties
delete mode 100644 cluster/src/test/resources/node1conf/iotdb-metric.yml
delete mode 100644 cluster/src/test/resources/node1conf/logback.xml
delete mode 100644 cluster/src/test/resources/node2conf/iotdb-cluster.properties
delete mode 100644 cluster/src/test/resources/node2conf/iotdb-engine.properties
delete mode 100644 cluster/src/test/resources/node2conf/iotdb-metric.yml
delete mode 100644 cluster/src/test/resources/node2conf/logback.xml
delete mode 100644 cluster/src/test/resources/node3conf/iotdb-cluster.properties
delete mode 100644 cluster/src/test/resources/node3conf/iotdb-engine.properties
delete mode 100644 cluster/src/test/resources/node3conf/iotdb-metric.yml
delete mode 100644 cluster/src/test/resources/node3conf/logback.xml
delete mode 100644 docker/src/main/Dockerfile-cluster
delete mode 100644 thrift-cluster/README.md
delete mode 100644 thrift-cluster/pom.xml
delete mode 100644 thrift-cluster/rpc-changelist.md
delete mode 100644 thrift-cluster/src/main/thrift/cluster.thrift