You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by su...@apache.org on 2020/12/10 01:48:35 UTC
[iotdb] branch fileIndex updated (230828f -> 32bee10)
This is an automated email from the ASF dual-hosted git repository.
sunzesong pushed a change to branch fileIndex
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 230828f Fix code smell
add c93be51 Rename
add 818c579 fix mem control calculate twice (#2218)
add 580b012 [IOTDB-68] New shared-nothing cluster (#460)
add bbbd88b [IOTDB-995][C++ Client] C++ client supports new session interfaces with time zone (#2036)
add 6cb930d Remove useless imports in python client (#2210)
add 6fa424c add 0.11 file check (#2225)
add e42e4d3 Merge remote-tracking branch 'origin/master' into fileIndex
add 32bee10 Solve conflicts with cluster branch
No new revisions were added by this update.
Summary of changes:
.gitignore | 6 +
.travis.yml | 13 +-
.../java/org/apache/iotdb/cli/AbstractScript.java | 5 +
client-cpp/README.md | 14 +-
client-cpp/client-cpp-example/pom.xml | 1 -
.../client-cpp-example/src/SessionExample.cpp | 2 +-
client-cpp/pom.xml | 17 +-
.../src/main/{IOTDBSession.cpp => Session.cpp} | 72 +-
client-cpp/src/main/{IOTDBSession.h => Session.h} | 54 +-
client-cpp/src/test/CMakeLists.txt | 1 +
client-cpp/src/test/cpp/sessionIT.cpp | 2 +-
client-cpp/src/test/main.cpp | 2 +-
client-py/src/iotdb/Session.py | 1 -
client-py/src/iotdb/utils/RowRecord.py | 1 -
cluster/pom.xml | 183 ++
cluster/src/assembly/cluster.xml | 27 +
.../resources/conf/iotdb-cluster.properties | 151 ++
cluster/src/assembly/resources/sbin/add-node.bat | 108 +
cluster/src/assembly/resources/sbin/add-node.sh | 76 +
cluster/src/assembly/resources/sbin/nodetool.bat | 58 +
cluster/src/assembly/resources/sbin/nodetool.sh | 48 +
cluster/src/assembly/resources/sbin/start-node.bat | 129 ++
cluster/src/assembly/resources/sbin/start-node.sh | 100 +
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 | 461 +++++
.../iotdb/cluster/ClusterFileFlushPolicy.java | 67 +
.../java/org/apache/iotdb/cluster/ClusterMain.java | 319 +++
.../apache/iotdb/cluster/RemoteTsFileResource.java | 174 ++
.../iotdb/cluster/client/DataClientProvider.java | 79 +
.../cluster/client/async/AsyncClientFactory.java | 62 +
.../cluster/client/async/AsyncClientPool.java | 234 +++
.../cluster/client/async/AsyncDataClient.java | 148 ++
.../client/async/AsyncDataHeartbeatClient.java | 69 +
.../cluster/client/async/AsyncMetaClient.java | 125 ++
.../client/async/AsyncMetaHeartbeatClient.java | 70 +
.../cluster/client/sync/SyncClientAdaptor.java | 456 ++++
.../cluster/client/sync/SyncClientFactory.java | 31 +-
.../iotdb/cluster/client/sync/SyncClientPool.java | 137 ++
.../iotdb/cluster/client/sync/SyncDataClient.java | 105 +
.../client/sync/SyncDataHeartbeatClient.java | 71 +
.../iotdb/cluster/client/sync/SyncMetaClient.java | 80 +
.../client/sync/SyncMetaHeartbeatClient.java | 71 +
.../apache/iotdb/cluster/config/ClusterConfig.java | 444 ++++
.../iotdb/cluster/config/ClusterConstant.java | 28 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 371 ++++
.../iotdb/cluster/config/ConsistencyLevel.java | 69 +
.../iotdb/cluster/exception/AddSelfException.java | 19 +-
.../exception/BadSeedUrlFormatException.java | 17 +-
.../exception/CheckConsistencyException.java | 22 +-
.../exception/ConfigInconsistentException.java | 17 +-
.../cluster/exception/EmptyIntervalException.java | 17 +-
.../cluster/exception/EntryCompactedException.java | 18 +-
.../exception/EntryUnavailableException.java | 17 +-
.../GetEntriesWrongParametersException.java | 16 +-
.../cluster/exception/LeaderUnknownException.java | 20 +-
.../cluster/exception/LogExecutionException.java | 16 +-
.../cluster/exception/MemberReadOnlyException.java | 19 +-
.../cluster/exception/NoHeaderNodeException.java | 20 +-
.../cluster/exception/NotInSameGroupException.java | 20 +-
.../cluster/exception/NotManagedSlotException.java | 19 +-
.../PartitionTableUnavailableException.java | 21 +-
.../iotdb/cluster/exception/PullFileException.java | 15 +-
.../cluster/exception/QueryTimeOutException.java | 16 +-
.../cluster/exception/ReaderNotFoundException.java | 16 +-
.../cluster/exception/RequestTimeOutException.java | 18 +-
.../exception/SnapshotInstallationException.java | 22 +-
.../exception/StartUpCheckFailureException.java | 20 +-
.../exception/TruncateCommittedEntryException.java | 18 +-
.../cluster/exception/UnknownLogTypeException.java | 19 +-
.../exception/UnsupportedPlanException.java | 18 +-
.../iotdb/cluster/log/CommitLogCallback.java | 29 +-
.../apache/iotdb/cluster/log/CommitLogTask.java | 68 +
.../org/apache/iotdb/cluster/log/HardState.java | 133 ++
.../java/org/apache/iotdb/cluster/log/Log.java | 130 ++
.../org/apache/iotdb/cluster/log/LogApplier.java | 22 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 424 ++++
.../org/apache/iotdb/cluster/log/LogParser.java | 100 +
.../org/apache/iotdb/cluster/log/Snapshot.java | 71 +
.../iotdb/cluster/log/StableEntryManager.java | 55 +
.../cluster/log/applier/AsyncDataLogApplier.java | 270 +++
.../iotdb/cluster/log/applier/BaseApplier.java | 150 ++
.../iotdb/cluster/log/applier/DataLogApplier.java | 114 +
.../iotdb/cluster/log/applier/MetaLogApplier.java | 70 +
.../iotdb/cluster/log/catchup/CatchUpTask.java | 359 ++++
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 343 ++++
.../cluster/log/catchup/SnapshotCatchUpTask.java | 153 ++
.../iotdb/cluster/log/logtypes/AddNodeLog.java | 93 +
.../iotdb/cluster/log/logtypes/CloseFileLog.java | 119 ++
.../cluster/log/logtypes/EmptyContentLog.java | 63 +
.../iotdb/cluster/log/logtypes/LargeTestLog.java | 78 +
.../cluster/log/logtypes/PhysicalPlanLog.java | 112 +
.../iotdb/cluster/log/logtypes/RemoveNodeLog.java | 87 +
.../cluster/log/manage/CommittedEntryManager.java | 236 +++
.../manage/FilePartitionedSnapshotLogManager.java | 205 ++
.../log/manage/MetaSingleSnapshotLogManager.java | 84 +
.../log/manage/PartitionedSnapshotLogManager.java | 100 +
.../iotdb/cluster/log/manage/RaftLogManager.java | 949 +++++++++
.../log/manage/UnCommittedEntryManager.java | 259 +++
.../log/manage/serializable/LogManagerMeta.java | 136 ++
.../serializable/SyncLogDequeSerializer.java | 1329 ++++++++++++
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 621 ++++++
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 300 +++
.../cluster/log/snapshot/PartitionedSnapshot.java | 212 ++
.../cluster/log/snapshot/PullSnapshotTask.java | 231 +++
.../log/snapshot/PullSnapshotTaskDescriptor.java | 122 ++
.../cluster/log/snapshot/SnapshotFactory.java | 17 +-
.../cluster/log/snapshot/SnapshotInstaller.java | 22 +-
.../log/snapshot/TimeseriesSchemaSnapshot.java | 19 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 1428 +++++++++++++
.../apache/iotdb/cluster/metadata/MetaPuller.java | 207 ++
.../cluster/partition/NodeAdditionResult.java | 25 +-
.../iotdb/cluster/partition/NodeRemovalResult.java | 37 +-
.../iotdb/cluster/partition/PartitionGroup.java | 65 +
.../iotdb/cluster/partition/PartitionTable.java | 130 ++
.../iotdb/cluster/partition/slot/SlotManager.java | 315 +++
.../partition/slot/SlotNodeAdditionResult.java | 24 +-
.../partition/slot/SlotNodeRemovalResult.java | 27 +-
.../cluster/partition/slot/SlotPartitionTable.java | 508 +++++
.../iotdb/cluster/partition/slot/SlotStrategy.java | 36 +
.../cluster/query/ClusterConcatPathOptimizer.java | 26 +-
.../cluster/query/ClusterDataQueryExecutor.java | 103 +
.../cluster/query/ClusterPhysicalGenerator.java | 104 +
.../iotdb/cluster/query/ClusterPlanExecutor.java | 543 +++++
.../iotdb/cluster/query/ClusterPlanRouter.java | 365 ++++
.../apache/iotdb/cluster/query/ClusterPlanner.java | 57 +
.../iotdb/cluster/query/ClusterQueryRouter.java | 88 +
.../iotdb/cluster/query/LocalQueryExecutor.java | 690 +++++++
.../iotdb/cluster/query/RemoteQueryContext.java | 72 +
.../query/aggregate/ClusterAggregateExecutor.java | 96 +
.../cluster/query/aggregate/ClusterAggregator.java | 224 ++
.../query/dataset/ClusterAlignByDeviceDataSet.java | 60 +
.../cluster/query/fill/ClusterFillExecutor.java | 61 +
.../cluster/query/fill/ClusterLinearFill.java | 70 +
.../cluster/query/fill/ClusterPreviousFill.java | 222 ++
.../cluster/query/fill/PreviousFillArguments.java | 67 +
.../iotdb/cluster/query/filter/SlotSgFilter.java | 34 +-
.../cluster/query/filter/SlotTsFileFilter.java | 57 +
.../groupby/ClusterGroupByNoVFilterDataSet.java | 59 +
.../groupby/ClusterGroupByVFilterDataSet.java | 74 +
.../query/groupby/MergeGroupByExecutor.java | 134 ++
.../query/groupby/RemoteGroupByExecutor.java | 144 ++
.../query/last/ClusterLastQueryExecutor.java | 249 +++
.../cluster/query/manage/ClusterQueryManager.java | 130 ++
.../iotdb/cluster/query/manage/NodeStatus.java | 87 +
.../cluster/query/manage/QueryCoordinator.java | 169 ++
.../cluster/query/reader/ClusterReaderFactory.java | 571 +++++
.../cluster/query/reader/ClusterTimeGenerator.java | 75 +
.../iotdb/cluster/query/reader/DataSourceInfo.java | 249 +++
.../iotdb/cluster/query/reader/EmptyReader.java | 170 ++
.../cluster/query/reader/ManagedMergeReader.java | 93 +
.../cluster/query/reader/MergedReaderByTime.java | 33 +-
.../reader/RemoteSeriesReaderByTimestamp.java | 105 +
.../query/reader/RemoteSimpleSeriesReader.java | 159 ++
.../apache/iotdb/cluster/server/ClientServer.java | 322 +++
.../iotdb/cluster/server/DataClusterServer.java | 860 ++++++++
.../iotdb/cluster/server/HardLinkCleaner.java | 109 +
.../iotdb/cluster/server/MetaClusterServer.java | 346 ++++
.../apache/iotdb/cluster/server/NodeCharacter.java | 19 +-
.../apache/iotdb/cluster/server/NodeReport.java | 183 ++
.../java/org/apache/iotdb/cluster/server/Peer.java | 70 +
.../cluster/server/PullSnapshotHintService.java | 141 ++
.../apache/iotdb/cluster/server/RaftServer.java | 241 +++
.../org/apache/iotdb/cluster/server/Response.java | 59 +
.../iotdb/cluster/server/StoppedMemberManager.java | 153 ++
.../org/apache/iotdb/cluster/server/Timer.java | 261 +++
.../handlers/caller/AppendGroupEntryHandler.java | 147 ++
.../handlers/caller/AppendNodeEntryHandler.java | 171 ++
.../server/handlers/caller/ElectionHandler.java | 127 ++
.../server/handlers/caller/GenericHandler.java | 91 +
.../caller/GetChildNodeNextLevelPathHandler.java | 57 +
.../handlers/caller/GetNodesListHandler.java | 58 +
.../caller/GetTimeseriesSchemaHandler.java | 57 +
.../server/handlers/caller/HeartbeatHandler.java | 132 ++
.../server/handlers/caller/JoinClusterHandler.java | 63 +
.../server/handlers/caller/LogCatchUpHandler.java | 104 +
.../handlers/caller/LogCatchUpInBatchHandler.java | 104 +
.../server/handlers/caller/NodeStatusHandler.java | 54 +
.../handlers/caller/PreviousFillHandler.java | 78 +
.../caller/PullMeasurementSchemaHandler.java | 69 +
.../handlers/caller/PullSnapshotHandler.java | 78 +
.../caller/PullTimeseriesSchemaHandler.java | 69 +
.../handlers/caller/SnapshotCatchUpHandler.java | 62 +
.../server/handlers/caller/package-info.java | 15 +-
.../handlers/forwarder/ForwardPlanHandler.java | 66 +
.../server/heartbeat/DataHeartbeatServer.java | 82 +
.../server/heartbeat/DataHeartbeatThread.java | 74 +
.../cluster/server/heartbeat/HeartbeatServer.java | 212 ++
.../cluster/server/heartbeat/HeartbeatThread.java | 383 ++++
.../server/heartbeat/MetaHeartbeatServer.java | 83 +
.../server/heartbeat/MetaHeartbeatThread.java | 72 +
.../cluster/server/member/DataGroupMember.java | 828 ++++++++
.../cluster/server/member/MetaGroupMember.java | 2172 ++++++++++++++++++++
.../iotdb/cluster/server/member/RaftMember.java | 1869 +++++++++++++++++
.../iotdb/cluster/server/member/package-info.java | 17 +-
.../cluster/server/service/BaseAsyncService.java | 159 ++
.../cluster/server/service/BaseSyncService.java | 175 ++
.../cluster/server/service/DataAsyncService.java | 349 ++++
.../cluster/server/service/DataSyncService.java | 350 ++++
.../cluster/server/service/MetaAsyncService.java | 202 ++
.../cluster/server/service/MetaSyncService.java | 194 ++
.../iotdb/cluster/server/service/package-info.java | 17 +-
.../apache/iotdb/cluster/utils/ClientUtils.java | 70 +
.../iotdb/cluster/utils/ClusterConsistent.java | 23 +-
.../apache/iotdb/cluster/utils/ClusterNode.java | 71 +
.../iotdb/cluster/utils/ClusterQueryUtils.java | 68 +
.../apache/iotdb/cluster/utils/ClusterUtils.java | 328 +++
.../org/apache/iotdb/cluster/utils/IOUtils.java | 87 +
.../apache/iotdb/cluster/utils/PartitionUtils.java | 401 ++++
.../apache/iotdb/cluster/utils/PlanSerializer.java | 51 +
.../apache/iotdb/cluster/utils/StatusUtils.java | 219 ++
.../cluster/utils/nodetool/ClusterMonitor.java | 179 ++
.../utils/nodetool/ClusterMonitorMBean.java | 84 +
.../iotdb/cluster/utils/nodetool/NodeTool.java | 47 +
.../iotdb/cluster/utils/nodetool/Printer.java | 24 +-
.../cluster/utils/nodetool/function/Host.java | 70 +
.../cluster/utils/nodetool/function/LogView.java | 82 +
.../utils/nodetool/function/NodeToolCmd.java | 102 +
.../cluster/utils/nodetool/function/Partition.java | 85 +
.../cluster/utils/nodetool/function/Ring.java | 42 +
.../cluster/utils/nodetool/function/Status.java | 44 +
.../cluster/client/DataClientProviderTest.java | 73 +
.../cluster/client/async/AsyncClientPoolTest.java | 188 ++
.../cluster/client/async/AsyncDataClientTest.java | 61 +
.../client/async/AsyncDataHeartbeatClientTest.java | 41 +
.../cluster/client/async/AsyncMetaClientTest.java | 61 +
.../client/async/AsyncMetaHeartbeatClientTest.java | 41 +
.../cluster/client/sync/SyncClientAdaptorTest.java | 366 ++++
.../cluster/client/sync/SyncClientPoolTest.java | 153 ++
.../cluster/client/sync/SyncDataClientTest.java | 80 +
.../client/sync/SyncDataHeartbeatClientTest.java | 63 +
.../cluster/client/sync/SyncMetaClientTest.java | 62 +
.../client/sync/SyncMetaHeartbeatClientTest.java | 63 +
.../iotdb/cluster/common/EnvironmentUtils.java | 218 ++
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 172 ++
.../iotdb/cluster/common/TestAsyncClient.java | 35 +-
.../cluster/common/TestAsyncClientFactory.java | 50 +
.../iotdb/cluster/common/TestAsyncDataClient.java | 190 ++
.../iotdb/cluster/common/TestAsyncMetaClient.java | 37 +-
.../iotdb/cluster/common/TestDataGroupMember.java | 46 +
.../apache/iotdb/cluster/common/TestException.java | 16 +-
.../org/apache/iotdb/cluster/common/TestLog.java | 67 +
.../iotdb/cluster/common/TestLogApplier.java | 65 +
.../iotdb/cluster/common/TestLogManager.java | 29 +-
.../cluster/common/TestManagedSeriesReader.java | 91 +
.../iotdb/cluster/common/TestMetaGroupMember.java | 29 +-
.../cluster/common/TestPartitionedLogManager.java | 48 +
.../apache/iotdb/cluster/common/TestSnapshot.java | 110 +
.../iotdb/cluster/common/TestSyncClient.java | 29 +-
.../cluster/common/TestSyncClientFactory.java | 71 +
.../org/apache/iotdb/cluster/common/TestUtils.java | 388 ++++
.../cluster/integration/BaseSingleNodeTest.java | 80 +
.../iotdb/cluster/integration/SingleNodeTest.java | 93 +
.../iotdb/cluster/log/CommitLogCallbackTest.java | 51 +
.../iotdb/cluster/log/CommitLogTaskTest.java | 72 +
.../apache/iotdb/cluster/log/HardStateTest.java | 36 +-
.../iotdb/cluster/log/LogDispatcherTest.java | 254 +++
.../apache/iotdb/cluster/log/LogParserTest.java | 99 +
.../log/applier/AsyncDataLogApplierTest.java | 166 ++
.../cluster/log/applier/DataLogApplierTest.java | 316 +++
.../cluster/log/applier/MetaLogApplierTest.java | 124 ++
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 393 ++++
.../cluster/log/catchup/LogCatchUpTaskTest.java | 289 +++
.../log/catchup/SnapshotCatchUpTaskTest.java | 270 +++
.../cluster/log/logtypes/SerializeLogTest.java | 128 ++
.../log/manage/CommittedEntryManagerTest.java | 429 ++++
.../FilePartitionedSnapshotLogManagerTest.java | 101 +
.../manage/MetaSingleSnapshotLogManagerTest.java | 91 +
.../cluster/log/manage/RaftLogManagerTest.java | 1412 +++++++++++++
.../log/manage/UnCommittedEntryManagerTest.java | 442 ++++
.../serializable/SyncLogDequeSerializerTest.java | 595 ++++++
.../cluster/log/snapshot/DataSnapshotTest.java | 163 ++
.../cluster/log/snapshot/FileSnapshotTest.java | 300 +++
.../log/snapshot/MetaSimpleSnapshotTest.java | 187 ++
.../log/snapshot/PartitionedSnapshotTest.java | 116 ++
.../snapshot/PullSnapshotTaskDescriptorTest.java | 62 +
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 299 +++
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 132 ++
.../iotdb/cluster/partition/MManagerWhiteBox.java | 53 +
.../iotdb/cluster/partition/SlotManagerTest.java | 149 ++
.../cluster/partition/SlotPartitionTableTest.java | 533 +++++
.../apache/iotdb/cluster/query/BaseQueryTest.java | 115 ++
.../query/ClusterAggregateExecutorTest.java | 129 ++
.../query/ClusterDataQueryExecutorTest.java | 66 +
.../cluster/query/ClusterFillExecutorTest.java | 115 ++
.../query/ClusterPhysicalGeneratorTest.java | 63 +
.../cluster/query/ClusterPlanExecutorTest.java | 83 +
.../iotdb/cluster/query/ClusterPlannerTest.java | 54 +
.../cluster/query/ClusterQueryRouterTest.java | 259 +++
.../ClusterGroupByNoVFilterDataSetTest.java | 83 +
.../groupby/ClusterGroupByVFilterDataSetTest.java | 94 +
.../query/groupby/MergeGroupByExecutorTest.java | 98 +
.../query/groupby/RemoteGroupByExecutorTest.java | 153 ++
.../query/manage/ClusterQueryManagerTest.java | 192 ++
.../cluster/query/manage/QueryCoordinatorTest.java | 117 ++
.../query/reader/ClusterTimeGeneratorTest.java | 70 +
.../cluster/query/reader/DatasourceInfoTest.java | 77 +
.../reader/RemoteSeriesReaderByTimestampTest.java | 202 ++
.../query/reader/RemoteSimpleSeriesReaderTest.java | 206 ++
.../caller/AppendGroupEntryHandlerTest.java | 159 ++
.../caller/AppendNodeEntryHandlerTest.java | 172 ++
.../handlers/caller/ElectionHandlerTest.java | 133 ++
.../server/handlers/caller/GenericHandlerTest.java | 57 +
.../handlers/caller/HeartbeatHandlerTest.java | 99 +
.../handlers/caller/JoinClusterHandlerTest.java | 66 +
.../handlers/caller/LogCatchUpHandlerTest.java | 125 ++
.../caller/PullMeasurementSchemaHandlerTest.java | 89 +
.../handlers/caller/PullSnapshotHandlerTest.java | 81 +
.../caller/SnapshotCatchUpHandlerTest.java | 57 +
.../handlers/forwarder/ForwardPlanHandlerTest.java | 57 +
.../server/heartbeat/DataHeartbeatThreadTest.java | 158 ++
.../server/heartbeat/HeartbeatThreadTest.java | 246 +++
.../server/heartbeat/MetaHeartbeatThreadTest.java | 214 ++
.../cluster/server/member/DataGroupMemberTest.java | 1047 ++++++++++
.../iotdb/cluster/server/member/MemberTest.java | 418 ++++
.../cluster/server/member/MetaGroupMemberTest.java | 1211 +++++++++++
.../iotdb/cluster/utils/SerializeUtilTest.java | 179 ++
{server => cluster}/src/test/resources/logback.xml | 24 +-
compile-tools/README.md | 6 +-
docs/UserGuide/Server/Cluster Setup.md | 50 +-
docs/UserGuide/Server/Config Manual.md | 29 +
docs/UserGuide/System Tools/NodeTool.md | 77 +-
docs/zh/UserGuide/Server/Cluster Setup.md | 51 +-
docs/zh/UserGuide/Server/Config Manual.md | 38 +-
docs/zh/UserGuide/System Tools/NodeTool.md | 84 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 16 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 54 +-
pom.xml | 1 +
.../resources/conf/iotdb-engine.properties | 9 +
server/src/assembly/resources/conf/logback.xml | 6 +-
.../java/org/apache/iotdb/db/auth/entity/Role.java | 8 +
.../java/org/apache/iotdb/db/auth/entity/User.java | 12 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 82 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 18 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 3 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 77 +-
.../no/NoCompactionTsFileManagement.java | 2 +-
.../engine/compaction/utils/CompactionUtils.java | 5 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 4 +-
.../db/engine/memtable/PrimitiveMemTable.java | 4 +
.../iotdb/db/engine/merge/task/MergeFileTask.java | 34 +-
.../db/engine/merge/task/RecoverMergeTask.java | 1 -
.../engine/storagegroup/StorageGroupProcessor.java | 230 +--
.../db/engine/storagegroup/TsFileProcessor.java | 168 +-
.../db/engine/storagegroup/TsFileResource.java | 176 +-
...onException.java => BatchProcessException.java} | 13 +-
.../db/exception/TsFileProcessorException.java | 2 +-
...eryProcessException.java => PathException.java} | 18 +-
.../db/exception/query/QueryProcessException.java | 4 +
.../{FileTimeIndexer.java => FileIndex.java} | 27 +-
.../iotdb/db/fileindex/FileIndexManager.java | 84 +-
...viceTimeIndexer.java => InMemoryFileIndex.java} | 23 +-
.../fileindex/impl/LoadAllDeviceTimeIndexer.java | 64 -
.../org/apache/iotdb/db/metadata/MManager.java | 217 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 10 +-
.../org/apache/iotdb/db/metadata/MetaUtils.java | 10 +-
.../org/apache/iotdb/db/metadata/PartialPath.java | 40 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 3 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 4 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 264 +--
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 31 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 22 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 119 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 65 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 3 +
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 117 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 19 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 4 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 13 +-
.../dataset/groupby/GroupByEngineDataSet.java | 7 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 2 +-
.../groupby/GroupByWithValueFilterDataSet.java | 5 +
.../db/query/executor/AggregationExecutor.java | 1 +
.../iotdb/db/query/executor/LastQueryExecutor.java | 34 +-
.../db/query/executor/RawDataQueryExecutor.java | 2 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 7 +-
.../reader/series/BaseManagedSeriesReader.java} | 29 +-
.../reader/series/SeriesReaderByTimestamp.java | 4 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 193 +-
.../db/service/thrift/ThriftServiceThread.java | 31 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 6 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 13 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 60 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 20 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 280 ++-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 9 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 154 +-
.../writelog/recover/TsFileRecoverPerformer.java | 24 +-
.../iotdb/db/engine/merge/MergeOverLapTest.java | 9 +-
.../apache/iotdb/db/engine/merge/MergeTest.java | 9 +-
.../storagegroup/StorageGroupProcessorTest.java | 13 +-
.../engine/storagegroup/TsFileProcessorTest.java | 8 +-
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 4 +-
.../db/integration/IoTDBRpcCompressionIT.java | 153 ++
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 6 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 2 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 13 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 6 +-
.../reader/series/SeriesAggregateReaderTest.java | 3 +-
.../reader/series/SeriesReaderByTimestampTest.java | 3 +-
.../db/query/reader/series/SeriesReaderTest.java | 3 +-
.../query/reader/series/SeriesReaderTestUtil.java | 16 +-
.../db/sync/receiver/load/FileLoaderTest.java | 7 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 11 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 3 -
server/src/test/resources/logback.xml | 2 +-
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 80 +
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 79 +
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 63 +
.../apache/iotdb/rpc/IoTDBConnectionException.java | 2 +-
...nectionException.java => NonOpenTransport.java} | 27 +-
...cutionException.java => RedirectException.java} | 33 +-
...atementExecutionException.java => RpcStat.java} | 33 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 56 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 66 +-
.../iotdb/rpc/StatementExecutionException.java | 2 +-
.../rpc/TCompressedElasticFramedTransport.java | 113 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 145 ++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 80 +
.../rpc/TimeoutChangeableTFastFramedTransport.java | 55 +
.../TimeoutChangeableTSnappyFramedTransport.java | 54 +
...eption.java => TimeoutChangeableTransport.java} | 19 +-
.../main/java/org/apache/iotdb/session/Config.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 1343 ++++++------
.../apache/iotdb/session/SessionConnection.java | 624 ++++++
.../java/org/apache/iotdb/session/SessionUT.java | 4 +-
thrift/src/main/thrift/cluster.thrift | 39 +-
thrift/src/main/thrift/rpc.thrift | 6 +
tsfile/format-changelist.md | 5 +
.../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 47 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 12 +
.../tsfile/read/query/dataset/QueryDataSet.java | 14 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 7 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 142 +-
.../write/writer/RestorableTsFileIOWriter.java | 15 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 21 +-
439 files changed, 55986 insertions(+), 2990 deletions(-)
rename client-cpp/src/main/{IOTDBSession.cpp => Session.cpp} (94%)
rename client-cpp/src/main/{IOTDBSession.h => Session.h} (91%)
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/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/ClusterMain.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/DataClientProvider.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncClientFactory.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncClientPool.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/AsyncDataHeartbeatClient.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/async/AsyncMetaHeartbeatClient.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java (56%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientPool.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/SyncDataHeartbeatClient.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/client/sync/SyncMetaHeartbeatClient.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConfig.java
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConstant.java (50%)
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
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/AddSelfException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/BadSeedUrlFormatException.java (64%)
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/CheckConsistencyException.java (60%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/ConfigInconsistentException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/EmptyIntervalException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryCompactedException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryUnavailableException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/GetEntriesWrongParametersException.java (64%)
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/LeaderUnknownException.java (62%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/MemberReadOnlyException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/NoHeaderNodeException.java (64%)
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/NotInSameGroupException.java (62%)
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/NotManagedSlotException.java (62%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/PartitionTableUnavailableException.java (63%)
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/PullFileException.java (63%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/QueryTimeOutException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/ReaderNotFoundException.java (64%)
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/RequestTimeOutException.java (63%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBConnectionException.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/SnapshotInstallationException.java (66%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/StartUpCheckFailureException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/TruncateCommittedEntryException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/UnknownLogTypeException.java (64%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/UnsupportedPlanException.java (64%)
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogCallback.java (53%)
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
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/log/LogApplier.java (62%)
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
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java (64%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBConnectionException.java => cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotInstaller.java (62%)
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/TimeseriesSchemaSnapshot.java (64%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/MetaPuller.java
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeAdditionResult.java (64%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/StatementExecutionException.java => cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeRemovalResult.java (56%)
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/slot/SlotManager.java
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeAdditionResult.java (59%)
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeRemovalResult.java (57%)
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
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterConcatPathOptimizer.java (56%)
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/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/dataset/ClusterAlignByDeviceDataSet.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
copy service-rpc/src/main/java/org/apache/iotdb/rpc/StatementExecutionException.java => cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotSgFilter.java (52%)
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/NodeStatus.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/ManagedMergeReader.java
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/main/java/org/apache/iotdb/cluster/query/reader/MergedReaderByTime.java (52%)
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/server/ClientServer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/DataClusterServer.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/MetaClusterServer.java
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/server/NodeCharacter.java (64%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/NodeReport.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/Peer.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/RaftServer.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/Timer.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/GetChildNodeNextLevelPathHandler.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/SnapshotCatchUpHandler.java
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/package-info.java (64%)
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/DataHeartbeatServer.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/HeartbeatServer.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/MetaHeartbeatServer.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/MetaGroupMember.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/server/member/package-info.java (64%)
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/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
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/server/service/package-info.java (64%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClientUtils.java
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterConsistent.java (62%)
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/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
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/Printer.java (62%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Host.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/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/Status.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/DataClientProviderTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncClientPoolTest.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/AsyncDataHeartbeatClientTest.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/async/AsyncMetaHeartbeatClientTest.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/SyncClientPoolTest.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/SyncDataHeartbeatClientTest.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/client/sync/SyncMetaHeartbeatClientTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/EnvironmentUtils.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/IoTDBTest.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/StatementExecutionException.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncClient.java (52%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncClientFactory.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncDataClient.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/StatementExecutionException.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncMetaClient.java (51%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestDataGroupMember.java
copy session/src/main/java/org/apache/iotdb/session/Config.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java (64%)
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
copy server/src/main/java/org/apache/iotdb/db/exception/BatchInsertionException.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java (58%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestManagedSeriesReader.java
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestMetaGroupMember.java (57%)
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
copy server/src/main/java/org/apache/iotdb/db/exception/TsFileProcessorException.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestSyncClient.java (60%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestSyncClientFactory.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
copy server/src/main/java/org/apache/iotdb/db/exception/query/QueryProcessException.java => cluster/src/test/java/org/apache/iotdb/cluster/log/HardStateTest.java (54%)
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/MManagerWhiteBox.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/ClusterFillExecutorTest.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/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/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/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/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/DataGroupMemberTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/member/MemberTest.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/utils/SerializeUtilTest.java
copy {server => cluster}/src/test/resources/logback.xml (58%)
rename server/src/main/java/org/apache/iotdb/db/exception/{BatchInsertionException.java => BatchProcessException.java} (78%)
copy server/src/main/java/org/apache/iotdb/db/exception/query/{QueryProcessException.java => PathException.java} (67%)
rename server/src/main/java/org/apache/iotdb/db/fileindex/{FileTimeIndexer.java => FileIndex.java} (74%)
rename server/src/main/java/org/apache/iotdb/db/fileindex/impl/{RocksDBDeviceTimeIndexer.java => InMemoryFileIndex.java} (74%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/fileindex/impl/LoadAllDeviceTimeIndexer.java
copy server/src/main/java/org/apache/iotdb/db/{exception/query/QueryProcessException.java => query/reader/series/BaseManagedSeriesReader.java} (57%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBRpcCompressionIT.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/AutoResizingBuffer.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/AutoScalingBufferReadTransport.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/AutoScalingBufferWriteTransport.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{IoTDBConnectionException.java => NonOpenTransport.java} (65%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{StatementExecutionException.java => RedirectException.java} (52%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{StatementExecutionException.java => RpcStat.java} (56%)
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/RpcTransportFactory.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TCompressedElasticFramedTransport.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TSnappyElasticFramedTransport.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTFastFramedTransport.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTSnappyFramedTransport.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{IoTDBConnectionException.java => TimeoutChangeableTransport.java} (65%)
create mode 100644 session/src/main/java/org/apache/iotdb/session/SessionConnection.java