You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ge...@apache.org on 2020/12/14 02:09:30 UTC
[iotdb] branch http_v2 updated (7e5fde1 -> 8eceb6b)
This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a change to branch http_v2
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 7e5fde1 update according to sonnar
add a40842e division by zero bug, when endtime - starttime < interval
add d5df5c5 Merge pull request #2060 from haimeiguo/master_division_by_zero_bug
add 6d8cdd0 [IOTDB-768] Extend more functions in aggregation group by level (#2088)
add 157be8f [IOTDB-937] change jdbc into session and don't need to create metadata (#1914)
add 891d8b6 Change listener to visitor in antlr in order to improve prase speed. (#2034)
add bf03882 [IOTDB-23] providing some statistics info about the writing operations (#1725)
add 1bd93f1 format document. (#2118)
add ae9a4ab fix issue-2110
add 53e7143 [Issue-2110] Update start-client to start-cli
add b0812c0 add mods file changelist
add 7f36819 [IOTDB-1027] add mods file changelist
add 1491050 Fix python path (#2127)
add afa6ecd The existing timePartitionId variable should be passed to the `insertToTsFileProcessor` method in the logic of inserting tsfile (#2111)
add 2735fa1 unlock mutil locks sequential (#2117)
add f9a972d fix import errors in Session.py and SessionExample.py
add abc6999 catch NullPointerException and log error (#2129)
add 875817b fix grafana value-time position bug (#2016)
add de4536a Declare the type of result of Future in StorageEngine (#2097)
add 093bd9b Remove the useless `public` keyword due to these methods in interface are (#2140)
add 7ebdf9a Fix compaction add list bug when last level exceeds max file num (#2141)
add 66d86b3 fix typo in userguide
add ff104e9 add MAX_POINT_NUMBER format check (#2148)
add 8657b13 Add Apache Pulsar to IoTDB example (#2122)
add d242932 Update compaction level list delete (#2152)
add 18bb46a [IOTDB-890] SDT implementation (#2087)
add 467897e add charset UTF-8 (#2155)
add f6cd1f9 [IOTDB-1035] Fix bug in getDeviceTimeseriesMetadata when querying non-exist device (#2150)
add 8e8384f Fix File Not Found when serializing TsFileResources (#2161)
add e95cebc Fix flink-iotdb set storage group bug (#2165)
add ccd6fab [IOTDB-1032]Refactor site/pom.xml and move v0.11 to 0.12 in all pom files (#2139)
add df22109 [IOTDB-1011] Memtable sort in query (#2144)
add 7dbc215 doc: fix dead links in the README (#2174)
add d951e82 [Mem control] Move one of the insert check out from the sg lock (#2154)
add 8aa9fef Remove duplicated static resps(column header) (#2164)
add bf0fb06 fix insert partial tablet with binary NullPointer bug (#2180)
add 20fed99 [IOTDB-1035] Add test for ReadChunkMetadataInDevice (#2157)
add 581d34f fix flink iotdb example for writing data with incorrect data types (#2181)
add 605a752 fix when one row failed, then insertRecords() does not clear the failed messages (#2191)
add c411218 IOTDB-1039 hive-connector mvn failed
add e652563 [ISSUE-2187] Fix compaction encoding bug after deserialization merge (#2188)
add a521f7f change mem control lock usage (#2153)
add 12fe408 Fix desc batchdata count bug (#2186)
add 84409f2 Add example results for User Guide documents (#2171)
add aea5a8d fix bug that when rpc compression = true, sync client does not use compression mode. (#2197)
add 2fe1950 The NumberFormatException itself should be used instead of its message (#2213)
add 435aae9 Fix the wrong placeholder in tracing manager (#2212)
add d20088a Remove useless blank lines in RPC doc (#2204)
add a533dd4 Fix code block type in client-py (#2205)
add cb9fe87 Correct the data type of the memory size to avoid loss of precision (#2211)
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 27c28a1 Change variable names makes the logic easier to understand
add 4fc4cf2 Merge pull request #2232 from liutaohua/add_comment
add 3982645 Fix the dash in the data model doc (#2234)
add baa317e Fix the spelling of storage group in the server file list doc (#2235)
add db49dae [IOTDB-1049] Fix Nullpointer exception and a delete bug in Last query (#2229)
add 678c2bf [To rel/0.11] Fix sync failed bug (#2241) (#2242)
add baa557d Remove useless escaped characters (#2207)
add 425d985 Clarify the data type when type conversion in batch mode (#2208)
add 20fabd3 add examples for setting fetchSize of session and JDBC (#2244)
add 69dbcfa update download links (#2249)
add ca24aaf fix error in site/config.js.
add 5a1ba81 [IoTDB-1051] Fix duplicate declaration of plugin :maven-assembly-plugin in hadoop/pom.xml
add 61db87b fix start-node script
add c8bc153 fix
add d7e291c Merge pull request #2223 from LebronAl/cluster_fix_auto_create_schema_bug
add 9e2a8f7 fix
add 2455b69 Merge pull request #2252 from LebronAl/cluster_dispatcher_build_request_optimize
add 8eceb6b Merge branch 'master' into http_v2
No new revisions were added by this update.
Summary of changes:
.gitignore | 6 +
.travis.yml | 13 +-
README.md | 63 +-
README_ZH.md | 67 +-
antlr/pom.xml | 6 +-
.../iotdb/db/qp/{strategy => sql}/SqlBase.g4 | 50 +-
cli/pom.xml | 11 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 11 +-
.../org/apache/iotdb/tool/AbstractCsvTool.java | 44 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 210 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 488 ++--
.../java/org/apache/iotdb/cli/AbstractScript.java | 9 +
.../org/apache/iotdb/tool/CsvLineSplitTest.java | 15 +-
.../org/apache/iotdb/tool/ExportCsvTestIT.java | 12 +-
.../org/apache/iotdb/tool/ImportCsvTestIT.java | 12 +-
client-cpp/README.md | 14 +-
client-cpp/client-cpp-example/pom.xml | 5 +-
.../client-cpp-example/src/SessionExample.cpp | 2 +-
client-cpp/pom.xml | 21 +-
.../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/pom.xml | 6 +-
client-py/pypi/README.md | 34 +-
client-py/pypi/setup.py | 2 +-
client-py/readme.md | 49 +-
client-py/src/SessionExample.py | 10 +-
client-py/src/{ => iotdb}/Session.py | 27 +-
client-py/src/{utils => iotdb}/__init__.py | 0
client-py/src/{ => iotdb}/utils/Field.py | 5 +-
client-py/src/{ => iotdb}/utils/IoTDBConstants.py | 0
client-py/src/{ => iotdb}/utils/IoTDBRpcDataSet.py | 13 +-
client-py/src/{ => iotdb}/utils/RowRecord.py | 7 +-
client-py/src/{ => iotdb}/utils/SessionDataSet.py | 16 +-
client-py/src/{ => iotdb}/utils/Tablet.py | 7 +-
client-py/src/{ => iotdb/utils}/__init__.py | 0
{cli => cluster}/pom.xml | 161 +-
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 +
.../src/assembly/resources/sbin/nodetool.sh | 66 +-
cluster/src/assembly/resources/sbin/start-node.bat | 129 +
cluster/src/assembly/resources/sbin/start-node.sh | 100 +
.../src/assembly/resources/sbin/stop-node.bat | 12 +-
.../src/assembly/resources/sbin/stop-node.sh | 27 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 461 ++++
.../iotdb/cluster/ClusterFileFlushPolicy.java | 67 +
.../java/org/apache/iotdb/cluster/ClusterMain.java | 320 +++
.../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 | 15 +-
.../exception/BadSeedUrlFormatException.java | 9 +-
.../exception/CheckConsistencyException.java | 29 +-
.../exception/ConfigInconsistentException.java | 9 +-
.../cluster/exception/EmptyIntervalException.java | 9 +-
.../cluster/exception/EntryCompactedException.java | 10 +-
.../exception/EntryUnavailableException.java | 9 +-
.../GetEntriesWrongParametersException.java | 8 +-
.../cluster/exception/LeaderUnknownException.java | 13 +-
.../cluster/exception/LogExecutionException.java | 12 +-
.../cluster/exception/MemberReadOnlyException.java | 13 +-
.../cluster/exception/NoHeaderNodeException.java | 12 +-
.../cluster/exception/NotInSameGroupException.java | 34 +-
.../cluster/exception/NotManagedSlotException.java | 16 +-
.../PartitionTableUnavailableException.java | 15 +-
.../iotdb/cluster/exception/PullFileException.java | 15 +-
.../cluster/exception/QueryTimeOutException.java | 12 +-
.../cluster/exception/ReaderNotFoundException.java | 12 +-
.../cluster/exception/RequestTimeOutException.java | 17 +-
.../exception/SnapshotInstallationException.java | 22 +-
.../exception/StartUpCheckFailureException.java | 14 +-
.../exception/TruncateCommittedEntryException.java | 14 +-
.../cluster/exception/UnknownLogTypeException.java | 11 +-
.../exception/UnsupportedPlanException.java | 12 +-
.../iotdb/cluster/log/CommitLogCallback.java | 30 +-
.../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 | 36 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 426 ++++
.../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 | 11 +-
.../cluster/log/snapshot/SnapshotInstaller.java | 13 +-
.../log/snapshot/TimeseriesSchemaSnapshot.java | 11 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 1445 +++++++++++
.../apache/iotdb/cluster/metadata/MetaPuller.java | 207 ++
.../cluster/partition/NodeAdditionResult.java | 17 +-
.../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 | 29 +-
.../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 | 34 +-
.../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 | 17 +-
.../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 | 9 +-
.../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 | 15 +-
.../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 | 15 +-
.../apache/iotdb/cluster/utils/ClientUtils.java | 70 +
.../iotdb/cluster/utils/ClusterConsistent.java | 15 +-
.../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 | 30 +-
.../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 | 159 +-
.../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 | 12 +-
.../org/apache/iotdb/cluster/common/TestLog.java | 67 +
.../iotdb/cluster/common/TestLogApplier.java | 65 +
.../iotdb/cluster/common/TestLogManager.java | 27 +-
.../cluster/common/TestManagedSeriesReader.java | 91 +
.../iotdb/cluster/common/TestMetaGroupMember.java | 28 +-
.../cluster/common/TestPartitionedLogManager.java | 48 +
.../apache/iotdb/cluster/common/TestSnapshot.java | 110 +
.../iotdb/cluster/common/TestSyncClient.java | 30 +-
.../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 +-
compile-tools/boost/pom.xml | 2 +-
compile-tools/pom.xml | 4 +-
compile-tools/thrift/pom.xml | 2 +-
cross-tests/pom.xml | 2 +-
.../tests/tools/importCsv/AbstractScript.java | 4 +-
.../tests/tools/importCsv/ExportCsvTestIT.java | 193 ++
.../tests/tools/importCsv/ImportCsvTestIT.java | 154 +-
distribution/pom.xml | 2 +-
docker/ReadMe.md | 10 +-
docker/src/main/Dockerfile | 4 +-
docs/Development/ContributeGuide.md | 6 +-
docs/Download/README.md | 47 +-
docs/SystemDesign/Client/RPC.md | 1 -
docs/SystemDesign/TsFile/Format.md | 2 +-
docs/UserGuide/Client/Command Line Interface.md | 1 +
docs/UserGuide/Concept/SDT.md | 45 +
docs/UserGuide/Operation Manual/Administration.md | 26 +-
.../DDL Data Definition Language.md | 177 +-
.../DML Data Manipulation Language.md | 688 +++--
docs/UserGuide/Operation Manual/SQL Reference.md | 10 +-
docs/UserGuide/Server/Cluster Setup.md | 50 +-
docs/UserGuide/Server/Config Manual.md | 56 +-
docs/UserGuide/Server/ServerFileList.md | 2 +-
docs/UserGuide/System Tools/CSV Tool.md | 85 +
.../System Tools/Monitor and Log Tools.md | 321 +--
docs/UserGuide/System Tools/NodeTool.md | 77 +-
docs/UserGuide/System Tools/Watermark Tool.md | 8 +-
docs/zh/Development/ContributeGuide.md | 2 +-
docs/zh/Download/README.md | 47 +-
docs/zh/SystemDesign/Client/RPC.md | 1 -
docs/zh/SystemDesign/TsFile/Format.md | 2 +-
docs/zh/UserGuide/Client/Command Line Interface.md | 2 +-
.../Concept/Data Model and Terminology.md | 3 +-
docs/zh/UserGuide/Concept/Data Type.md | 2 +-
.../Client/RPC.md => UserGuide/Concept/SDT.md} | 44 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 6 +-
docs/zh/UserGuide/Get Started/Publication.md | 2 +-
.../DDL Data Definition Language.md | 129 +-
.../DML Data Manipulation Language.md | 708 +++++-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 10 +-
docs/zh/UserGuide/Server/Cluster Setup.md | 51 +-
docs/zh/UserGuide/Server/Config Manual.md | 67 +-
docs/zh/UserGuide/Server/Download.md | 14 +-
docs/zh/UserGuide/Server/ServerFileList.md | 2 +-
docs/zh/UserGuide/System Tools/CSV Tool.md | 88 +
.../System Tools/Monitor and Log Tools.md | 305 +--
docs/zh/UserGuide/System Tools/NodeTool.md | 84 +-
docs/zh/UserGuide/System Tools/Watermark Tool.md | 8 +-
example/flink/pom.xml | 27 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 17 +-
example/hadoop/pom.xml | 6 +-
example/jdbc/pom.xml | 2 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 4 +
example/kafka/pom.xml | 2 +-
.../main/java/org/apache/iotdb/kafka/Constant.java | 2 +
example/mqtt/pom.xml | 2 +-
example/pom.xml | 3 +-
example/{tsfile => pulsar}/pom.xml | 18 +-
.../java/org/apache/iotdb/pulsar/Constant.java | 38 +-
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 108 +
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 70 +
.../org/apache/iotdb/pulsar/PulsarProducer.java | 82 +
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 17 +
example/tsfile/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 25 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana/pom.xml | 2 +-
.../controller/DatabaseConnectController.java | 4 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 29 +-
.../web/grafana/dao/impl/BasicDaoImplTest.java | 55 +
hadoop/pom.xml | 24 +-
hive-connector/pom.xml | 10 +-
jdbc/pom.xml | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 16 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 54 +-
pom.xml | 6 +-
.../file-changelists/TsFileMods-changelist.md | 14 +-
server/pom.xml | 2 +-
.../resources/conf/iotdb-engine.properties | 45 +-
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 | 78 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 18 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 3 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 39 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 122 +-
.../db/engine/compaction/TsFileManagement.java | 21 +
.../level/LevelCompactionTsFileManagement.java | 42 +-
.../no/NoCompactionTsFileManagement.java | 24 +-
.../engine/compaction/utils/CompactionUtils.java | 26 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 14 +
.../iotdb/db/engine/flush/FlushManagerMBean.java | 8 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 6 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 52 +-
.../db/engine/memtable/IWritableMemChunk.java | 24 +-
.../db/engine/memtable/PrimitiveMemTable.java | 4 +
.../iotdb/db/engine/memtable/WritableMemChunk.java | 35 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 32 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 37 +-
.../engine/storagegroup/StorageGroupProcessor.java | 289 ++-
.../db/engine/storagegroup/TsFileProcessor.java | 226 +-
.../db/engine/storagegroup/TsFileResource.java | 176 +-
...onException.java => BatchProcessException.java} | 13 +-
.../db/exception/TsFileProcessorException.java | 2 +-
...ption.java => WriteProcessRejectException.java} | 13 +-
...eryProcessException.java => PathException.java} | 18 +-
.../db/exception/query/QueryProcessException.java | 4 +
.../apache/iotdb/db/index/common/IndexUtils.java | 4 +-
.../org/apache/iotdb/db/metadata/MManager.java | 224 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 10 +-
.../org/apache/iotdb/db/metadata/MetaUtils.java | 10 +-
.../org/apache/iotdb/db/metadata/PartialPath.java | 44 +-
.../org/apache/iotdb/db/metrics/sink/Sink.java | 6 +-
.../org/apache/iotdb/db/metrics/source/Source.java | 2 +-
.../apache/iotdb/db/monitor/MonitorConstants.java | 94 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 447 ++--
.../StatMonitorMBean.java} | 29 +-
.../iotdb/db/monitor/collector/FileSize.java | 162 --
.../monitor/collector/MemTableWriteTimeCost.java | 85 -
.../main/java/org/apache/iotdb/db/qp/Planner.java | 10 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 2 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 4 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 264 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 21 +
.../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 +-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 2 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 3 +
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 117 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 6 +-
.../IoTDBSqlVisitor.java} | 2628 ++++++++++----------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 1949 +--------------
.../apache/iotdb/db/qp/strategy/ParseDriver.java | 69 -
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 72 +-
...gicalGeneratorError.java => SQLParseError.java} | 4 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 17 +-
.../db/query/aggregation/AggregateResult.java | 12 +-
.../iotdb/db/query/control/TracingManager.java | 2 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 13 +-
.../dataset/groupby/GroupByEngineDataSet.java | 7 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 2 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 14 +-
.../groupby/GroupByWithValueFilterDataSet.java | 5 +
.../db/query/executor/AggregationExecutor.java | 21 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 43 +-
.../db/query/executor/RawDataQueryExecutor.java | 2 +-
.../db/query/executor/fill/LastPointReader.java | 3 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 9 +-
.../reader/series/BaseManagedSeriesReader.java} | 29 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 4 +-
.../reader/series/SeriesReaderByTimestamp.java | 4 +
.../org/apache/iotdb/db/rescon/SystemInfo.java | 37 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 11 +-
.../java/org/apache/iotdb/db/service/Monitor.java | 150 --
.../org/apache/iotdb/db/service/StaticResps.java | 98 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 444 ++--
.../db/service/thrift/ThriftServiceThread.java | 31 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 14 +-
.../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/FilePathUtils.java | 131 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 20 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 280 ++-
.../iotdb/db/utils/datastructure/TVList.java | 128 +-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 9 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 154 +-
.../writelog/recover/TsFileRecoverPerformer.java | 24 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 2 +-
.../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/IOTDBGroupByIT.java | 5 +
.../db/integration/IoTDBAggregationByLevelIT.java | 324 +++
.../iotdb/db/integration/IoTDBAggregationIT.java | 17 +-
.../integration/IoTDBAggregationLargeDataIT.java | 5 +
.../integration/IoTDBAggregationSmallDataIT.java | 7 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 7 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 154 ++
.../iotdb/db/integration/IoTDBDeletionIT.java | 14 +-
.../db/integration/IoTDBInsertWithQueryIT.java | 503 ++++
.../iotdb/db/integration/IoTDBLargeDataIT.java | 5 +
.../apache/iotdb/db/integration/IoTDBLastIT.java | 75 +-
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 5 +
.../db/integration/IoTDBMultiOverlappedPageIT.java | 5 +
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 5 +
.../db/integration/IoTDBMultiStatementsIT.java | 5 +
.../db/integration/IoTDBOverlappedPageIT.java | 5 +
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 4 +-
.../iotdb/db/integration/IoTDBRecoverIT.java | 14 +-
.../db/integration/IoTDBRecoverUnclosedIT.java | 12 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 61 +-
.../db/integration/IoTDBRpcCompressionIT.java | 153 ++
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 428 +++-
.../iotdb/db/metadata/MManagerBasicTest.java | 2 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 13 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 6 +-
.../iotdb/db/monitor/collector/FileSizeTest.java | 93 -
.../iotdb/db/qp/plan/IndexLogicalPlanTest.java | 32 +-
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 110 +-
.../sql/DatetimeQueryDataSetUtilsTest.java | 2 +-
.../iotdb/db/qp/strategy/LogicalGeneratorTest.java | 26 +-
.../db/query/dataset/GroupByLevelDataSetTest.java | 25 +-
.../db/query/dataset/GroupByTimeDataSetTest.java | 18 +-
.../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 +-
service-rpc/pom.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 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 7 +-
.../org/apache/iotdb/rpc/NonOpenTransport.java | 24 +-
...cutionException.java => RedirectException.java} | 33 +-
.../main/java/org/apache/iotdb/rpc/RpcStat.java | 39 +-
.../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 | 4 +
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 80 +
.../rpc/TimeoutChangeableTFastFramedTransport.java | 55 +
.../TimeoutChangeableTSnappyFramedTransport.java | 54 +
.../iotdb/rpc/TimeoutChangeableTransport.java | 12 +-
session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/session/Config.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 1349 +++++-----
.../apache/iotdb/session/SessionConnection.java | 624 +++++
.../iotdb/session/IoTDBSessionComplexIT.java | 2 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 47 +
.../java/org/apache/iotdb/session/SessionUT.java | 4 +-
site/README-zh.md | 8 +-
site/README.md | 15 +-
site/pom.xml | 568 ++++-
site/src/main/.vuepress/config.js | 202 +-
site/src/main/package.json | 6 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 12 +-
spark-tsfile/pom.xml | 4 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/cluster.thrift | 40 +-
thrift/src/main/thrift/rpc.thrift | 7 +
thrift/src/main/thrift/sync.thrift | 1 +
tsfile/format-changelist.md | 5 +
tsfile/pom.xml | 2 +-
.../iotdb/tsfile/compress/IUnCompressor.java | 2 +-
.../iotdb/tsfile/encoding/encoder/SDTEncoder.java | 448 ++++
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 14 +-
.../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 47 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 30 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 35 +-
.../iotdb/tsfile/read/common/BatchDataFactory.java | 7 +-
.../{DescBatchData.java => DescReadBatchData.java} | 14 +-
.../tsfile/read/common/DescReadWriteBatchData.java | 374 +++
.../tsfile/read/query/dataset/QueryDataSet.java | 14 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 9 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 116 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 2 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 121 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 5 +-
.../write/writer/RestorableTsFileIOWriter.java | 15 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 21 +-
.../iotdb/tsfile/encoding/SDTEncoderTest.java | 176 ++
.../tsfile/read/TsFileSequenceReaderTest.java | 41 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 2 +-
622 files changed, 64666 insertions(+), 9945 deletions(-)
rename antlr/src/main/antlr4/org/apache/iotdb/db/qp/{strategy => sql}/SqlBase.g4 (94%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cli/src/test/java/org/apache/iotdb/tool/CsvLineSplitTest.java (68%)
rename client-cpp/src/main/{IOTDBSession.cpp => Session.cpp} (94%)
rename client-cpp/src/main/{IOTDBSession.h => Session.h} (91%)
rename client-py/src/{ => iotdb}/Session.py (95%)
rename client-py/src/{utils => iotdb}/__init__.py (100%)
rename client-py/src/{ => iotdb}/utils/Field.py (98%)
copy client-py/src/{ => iotdb}/utils/IoTDBConstants.py (100%)
rename client-py/src/{ => iotdb}/utils/IoTDBRpcDataSet.py (97%)
rename client-py/src/{ => iotdb}/utils/RowRecord.py (93%)
rename client-py/src/{ => iotdb}/utils/SessionDataSet.py (92%)
rename client-py/src/{ => iotdb}/utils/Tablet.py (98%)
rename client-py/src/{ => iotdb/utils}/__init__.py (100%)
copy {cli => cluster}/pom.xml (60%)
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
rename client-py/src/utils/IoTDBConstants.py => cluster/src/assembly/resources/sbin/nodetool.sh (60%)
mode change 100644 => 100755
create mode 100755 cluster/src/assembly/resources/sbin/start-node.bat
create mode 100755 cluster/src/assembly/resources/sbin/start-node.sh
rename client-py/compile.bat => cluster/src/assembly/resources/sbin/stop-node.bat (75%)
rename client-py/compile.sh => cluster/src/assembly/resources/sbin/stop-node.sh (65%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/AddSelfException.java (77%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/BadSeedUrlFormatException.java (72%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/CheckConsistencyException.java (60%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/ConfigInconsistentException.java (74%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/EmptyIntervalException.java (73%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryCompactedException.java (71%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryUnavailableException.java (73%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/GetEntriesWrongParametersException.java (75%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/LeaderUnknownException.java (66%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java (82%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/MemberReadOnlyException.java (71%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/NoHeaderNodeException.java (71%)
copy server/src/main/java/org/apache/iotdb/db/service/MonitorMBean.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/NotInSameGroupException.java (64%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/NotManagedSlotException.java (66%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/PartitionTableUnavailableException.java (67%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/QueryTimeOutException.java (80%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/ReaderNotFoundException.java (77%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/RequestTimeOutException.java (65%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/StartUpCheckFailureException.java (72%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/TruncateCommittedEntryException.java (71%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/UnknownLogTypeException.java (76%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/exception/UnsupportedPlanException.java (74%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.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/service/MonitorMBean.java => cluster/src/main/java/org/apache/iotdb/cluster/log/LogApplier.java (63%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java (81%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotInstaller.java (66%)
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/TimeseriesSchemaSnapshot.java (72%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeAdditionResult.java (71%)
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 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.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 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/server/NodeCharacter.java (77%)
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 server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/package-info.java (86%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/server/member/package-info.java (77%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/main/java/org/apache/iotdb/cluster/server/service/package-info.java (83%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/ClientUtils.java
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterConsistent.java (66%)
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
copy server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalGeneratorError.java => cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Ring.java (50%)
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
copy {spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db => cluster/src/test/java/org/apache/iotdb/cluster/common}/EnvironmentUtils.java (54%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java (82%)
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 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java (59%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/common/TestManagedSeriesReader.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestMetaGroupMember.java (58%)
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 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.java => cluster/src/test/java/org/apache/iotdb/cluster/common/TestSyncClient.java (61%)
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%)
create mode 100644 cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/importCsv/ExportCsvTestIT.java
create mode 100644 docs/UserGuide/Concept/SDT.md
create mode 100644 docs/UserGuide/System Tools/CSV Tool.md
copy docs/zh/{SystemDesign/Client/RPC.md => UserGuide/Concept/SDT.md} (52%)
create mode 100644 docs/zh/UserGuide/System Tools/CSV Tool.md
copy example/{tsfile => pulsar}/pom.xml (79%)
copy server/src/main/java/org/apache/iotdb/db/service/MonitorMBean.java => example/pulsar/src/main/java/org/apache/iotdb/pulsar/Constant.java (62%)
create mode 100644 example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumer.java
create mode 100644 example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumerThread.java
create mode 100644 example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarProducer.java
create mode 100644 grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
copy client-cpp/README.md => server/file-changelists/TsFileMods-changelist.md (77%)
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/{TsFileProcessorException.java => WriteProcessRejectException.java} (69%)
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/{service/MonitorMBean.java => monitor/StatMonitorMBean.java} (69%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/monitor/collector/MemTableWriteTimeCost.java
copy server/src/main/java/org/apache/iotdb/db/qp/{strategy/LogicalGenerator.java => sql/IoTDBSqlVisitor.java} (61%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/ParseDriver.java
rename server/src/main/java/org/apache/iotdb/db/qp/strategy/{LogicalGeneratorError.java => SQLParseError.java} (89%)
copy server/src/main/java/org/apache/iotdb/db/{exception/query/QueryProcessException.java => query/reader/series/BaseManagedSeriesReader.java} (57%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/Monitor.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBAggregationByLevelIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertWithQueryIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBRpcCompressionIT.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/monitor/collector/FileSizeTest.java
rename server/src/test/java/org/apache/iotdb/db/{ => qp}/sql/DatetimeQueryDataSetUtilsTest.java (99%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java (67%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{StatementExecutionException.java => RedirectException.java} (52%)
rename server/src/main/java/org/apache/iotdb/db/qp/logical/crud/QueryIndexOperator.java => service-rpc/src/main/java/org/apache/iotdb/rpc/RpcStat.java (53%)
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 server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java => service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTransport.java (81%)
create mode 100644 session/src/main/java/org/apache/iotdb/session/SessionConnection.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SDTEncoder.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/{DescBatchData.java => DescReadBatchData.java} (84%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/DescReadWriteBatchData.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/SDTEncoderTest.java