This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a change to branch kyy
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 56663f9 format
add 86405ca set props in MeasurementSchema to null by default to release
memory (#1585)
add 9fc0e17 [IOTDB-827] Fix no permissions for operation LAST (#1587)
add 6e7a5c9 Merge branch 'master' into cluster_new
add 3bb95d5 fix start-up check when only one node
add a28ff17 Merge pull request #1582 from apache/kyy
add 5d7bfa7 Merge branch 'cluster_new' of
https://github.com/apache/incubator-iotdb into cluster_new
add 7d95b53 fix cannot start data group when only one node
add 8c252de fix null pointer
add 346e7a7 add a test
add d56e94f fix headers format
add 12de9c5 server log_info.log does not contain INFO level log (#1598)
add f465f06 Use readLock in `getActiveRatio`
add 794ad5f [ISSUE#1599]check datatype with encoding. (#1600)
add ffdf15f fix spark package name in doc (#1607)
add b3f21a3 [IOTDB-832] fix reconnection failure bug in sessionPool
(#1610)
add 5e6c4b3 fix docker jmx
add d70758c Merge pull request #1612 from apache/fix_docker_jmx
add b15574f Merge branch 'master' into cluster_new
add 1f9760c code refine
add ac5b58a Merge pull request #1608 from
neuyilan/apache_cluster_new_0810_code_refine
add 8c3263d use loosen catch up strategy
add 5ae7774 Enable iotdb to set useasyncserver and useasyncapplier
through configuration files
add 8eea20a Enable iotdb to set useasyncserver and useasyncapplier
through configuration files
add 7325ae5 Enable iotdb to set useasyncserver and useasyncapplier
through configuration files
add b225bf1 Enable iotdb to set useasyncserver and useasyncapplier
through configuration files
add dbd7a5e Merge pull request #1588 from wyh-ztf/cluster_new
add d9351cc Enable iotdb can stop node under distributed
add f9baf1e Enable iotdb to stop node under distributed
add 8889c64 Merge pull request #1617 from wyh-ztf/cluster_w
add 0c07a44 fix query clientPool leak
add 0e8f77c Merge pull request #1618 from
LebronAl/cluster_new_bug_clientpool_query_leak
add 5ce2c12 support merge and flush
add 45cfa41 improve async applier
add bb2bf4f Enable to stop the local iotdb service in the distributed
environmen
add 7535fdd Enable to stop the local iotdb service in the distributed
environmen
add 15fd694 Enable to stop iotdb server by iotdb.IoTDB
add 5ff98f7 Enable to stop the local iotdb service in the distributed
environmen
add 92be4ea Enable to stop the local iotdb service in the distributed
environment
add c197a80 Merge pull request #1631 from wyh-ztf/cluster_w
add 37cca06 Merge branch 'cluster_new' of
https://github.com/apache/incubator-iotdb into cluster_new
add 1e6b42f fix applier tests
add 72aa40c [IOTDB-835] Fix delete timeseries and change data type then
write failed (#1625)
add d674035 [hotfix] Delete useless code in Jenkinsfile
add 5709256 add a data migration example (#1601)
add 571b7f5 [IOTDB-841] Unify the IOTDBConfig with iotdb-engine.cofig
(#1629)
add 290bc6a Merge branch 'master' into cluster_new
add 2a811dd fix pull schema out of order
add 379a7df disable vm (#1643)
add f0b8a4b [IOTDB-836] Fix merging statistics failed when endFile (#1637)
add 6ef6646 add Delete Storage Group statement to User Guide DDL (#1644)
add 8af64cf Merge branch 'master' into cluster_new
add e502a4a change prepared statement log level from info to debug (#1649)
add 5075299 Merge branch 'master' into cluster_new
add ad2823f fix member accesss
add 085b751 fix an NPE and pullTimeseriesSchema to pullMeasurementSchema
add 487a467 async applier refine
add 52ff188 fix the async log applier bug
add 6602e8e add UT
add f794745 remove useless thread pool
add 0d2fbbe support flush plan when do snapshot
add ae1540f refine syncCloseOneProcessor method in StorageGroupProcessor
add ecb1a52 change the log msg
add 1101cfb fix the license
add 3833718 fix the check applir log index
add 7d1fa0d fix checkAppliedLogIndex
add f1071bd fix flushPlan bug
add 261dbfe fix flushPlan bug
add 4e8e25d add more log message
add 162edfb make
add 9624981 Delete the extra blank lines
add 7ae9f80 fix flushplan serialize bug
add 5187c10 fix flushplan serialize bug
add e299193 add flushPlan test
add 4027bba Delete the extra blank lines
add 94b5a10 move syncFlushAllProcessor out of synchronized (logmanager) in
add 5c3f239 make the applyEntries in one seperate thread
add 5ac7bf3 flush the partitions belong to the datagroup and fix some UT
add 8fda671 Merge pull request #1635 from
neuyilan/apache_cluster_new_0819_async_applier
add 24f4598 shrink PartitionTable interface & add SlotStrategy
add ea67bf6 add log increment in node report
add c160923 Fix bug that 'List role privileges' cannot apply to root and
other issues in doc (#1647)
add ec9ef4f [IOTDB-849] Optimize value filter query (#1651)
add fd6992b [IOTDB-682] C++ client build (#1616)
add 9789c2c Update the master branch for releasing 0.10.1 (#1646)
add 12e1332 Support double quotation in Path and optimize the Path String
usage v2 (#1627)
add 4c224bc - Made it possible to load the config from the classpath
(#1661)
add 55c2e20 [IOTDB-855] Put back SessionPool resources if
RuntimeException occurs (#1663)
add afafc79 [IOTDB-839] Make Tablet api more friendly (#1658)
add 2ec3916 fix a bug which caused delete timeseries unsuccessfully
(#1664)
add 2c6e057 resolve grammatical mistake (#1669)
add 76a9aaa [IOTDB-837] ArrayIndexOutOfBoundsException if the
measurementId size is not consistent with the value size (#1662)
add 1fc68e7 IoTDB Session Interface Updates(0.9-0.10) (#1672)
add 988deda fix Chinese webpage translation (#1677)
add 1132192 fixed typo (#1674)
add 11323fe modify data manipulation doc (#1678)
add 393a91f [New feature] Add the alias and show it as column name when
querying (#1621)
add 4cedb4e Add java doc. (#1681)
add 7eeae49 Reduce unnecessary initialization (#1682)
add 1e48707 fix scheduleWithFixedDelay in wal
add 7e3f820 enlarge force_wal_period_in_ms to 100ms
add a7cfb1e Merge pull request #1679 from apache/real_fix_wal
add c626197 [Sonar] Fix Sonar checking bugs (#1673)
add 545d912 Fix thrift put some unnecessary bytes in a ByteBuffer (#1655)
add b3ea173 add new committer chaow (#1688)
add 82706a7 Merge branch 'master' into cluster_new
add f288663 avoid spinning when checking applied log index
add 9f342f2 wait for prevlog on receiver side
add b5141cf wait on both sides
add a6e4ffa add thread name
add ffdfd15 restrict append log pool size
add bcf5b9d extract waitForPrevLog
add 8eed545 extract duplicates
add fa271c0 use TThreadedSelectorServer
add 163d2de IndexOutOfBoundsException
add 9c00c3a Merge branch 'cluster_receiver_wait' of
https://github.com/apache/incubator-iotdb into cluster_receiver_wait
add ed23591 Merge branch 'cluster_receiver_wait' of
github.com:apache/incubator-iotdb into cluster_receiver_wait
add e1a3ef5 add lastHeartBeatIndex in Peer and PlanSerializer
add e5b3a98 add log dispatcher
add cbe6fb4 Merge branch 'cluster_log_order' into cluster_new
add d63813b instrument
add 45dacf6 Merge branch 'cluster_receiver_wait' of
https://github.com/apache/incubator-iotdb into cluster_receiver_wait
add 7a9ecac Revert "instrument"
add 442cf38 remove wait time in receiver
add 75a32db Merge branch 'cluster_receiver_wait' into cluster_new
add 732a8a8 add cluster document
add 379b8a0 add printgc
add de4af74 resolve grammatical mistake
add cbe4648 resolve grammatical mistake
add 9ea64da remove repeates and amend the description
add aff113c remend the rpc_thrift_compression_enable description
add 2bbff8a add en doc
add 3713abc Perfect description
add 31ba19a Perfect description
add ec238df Merge pull request #1666 from
neuyilan/apache_cluster_new_0831_document
add c74983d fix flush NullPointer error and update last cache NullPointer
error
add 89a4bfc add some annotation
add 9f5b26d Merge pull request #1696 from
neuyilan/apache_cluster_new_0907_merge_master
add d71da59 IOTDB-851: enhance failure tolerance when recover WAL (#1665)
add 1aa0c50 Add show TTL to DDL Data Definition Language.md (#1695)
add df250c3 [IOTDB-813] Show storage group under given path prefix (#1694)
add 7e2dbc6 fix Url bug (#1699)
add 1a02d88 fix dead lock on UpgradeUtils (#1701)
add 0014143 Change hot compact way to level merge (#1620)
add 1e0933b [IOTDB-856] Clear up the IoTDBSessionIT (#1670)
add 287f3fa Add PPMC info for Jincheng Sun (#1709)
add 399917a [IOTDB-670] raw data query interface (#1704)
add 43b07a2 Merge branch 'master' into cluster_new
add b5523bf IOTDB-859 list all files generated or used by IoTDB
add c6cba87 Merge pull request #1667 from mychaow/cluster_new
add 0c8cc35 Merge branch 'cluster_new' of
github.com:apache/incubator-iotdb into cluster_new
add d944de9 Move Session API updates into Native_API.md (#1706)
add d675044 Merge branch 'master' into cluster_new
add c4e89db fix timer in QueryCoordinator
add d988b1c fix session IT
add 376cb32 fix sonar issues
add df8e089 add documents
add 0c1822d [IOTDB-878][connector] Bump Flink to Flink 1.11.1 (#1711)
add 2c4fae5 [IOTDB-875]fix flush storage group error when no data in
storage group (#1700)
add 32abc11 [Hot compaction] Add upgrade logic for TsFileManagement
(#1707)
add 2df5415 Merge branch 'master' into cluster_new
add 55d9f6c add header
add faf2e23 code refinements and documents
add 8c2c032 fix an NPE
add ee5de41 change one log level
add ca62ea5 fix client pool initialization
add b42b0f1 massive refactor: RaftMembers now care about less
add 168cbbd Add merge speed limiting (#1712)
add 62f009c [IOTDB-873] Add count devices DDL (#1705)
add 883b5dc Fix As clause doc (#1697)
add 4852a10 Fix Python method "set_time_zone" exception message (#1713)
add 13c246e [IOTDB-871] change port to rpc port in session (#1720)
add b0b943a fix mem setting on windws when using 64-bit Java
add 237bd6f Merge pull request #1702 from
xiaoyekanren/fix_mem_setting_on_wind
add 83b7fce add new PPMC members Haonan Hou and Dawei Liu (#1729)
add d729f99 fix some importcsv tool bug (#1692)
add 7834fc8 [IOTDB-881] Fix Double quotes bug in Align by device (#1717)
add 42e3c16 fix importCsvIT bug (#1730)
add cef8858 Merge branch 'master' into cluster_new
add ef2c8a2 fix method name
add f1c4228 minor fixes
add 4d4fdca merge non-cluster code changes into master
add 7f4d7c5 self review and fix
add 78b4db6 fix cross tests
add 3aaf7de [IOTDB-840] Encode the three enum fields in MeasurementSchema
to save memory (#1724)
add 2323f26 fix bug that cross-test generates data out of the target
folder (#1738)
add da54ec5 [IOTDB-850] check list user/role privilege (#1698)
add fc795d3 [IOTDB-848] support order by time asc/desc (#1650)
add 4e4df33 [IOTDB-877] fix prefix bug on show storage group and show
devices (#1723)
add e9defff [Doc]Add wal test doc (#1735)
add 686f066 [IOTDB-876] Add count storage group DDL (#1734)
add fcf0eb9 Merge branch 'master' into cluster_premerge
add dd7b761 Merge branch 'cluster_premerge' into cluster_new
add e6b288f timer
add c9e41b9 report
add 096f029 nano time, atomic long
add bf5c4cf follower report
add 76e10cc print ms
add c1c6a90 data group member forward plan
add a3ea05e raft member wait for prev log
add 6a3d090 send log async
add 1c69644 vote counter
add 3549404 test network
add 10d29c9 ignore insert
add ab07bcc skip null plan
add 87e2fa2 recEiver
add 0477577 maybe append
add 6b78832 merge log order
add 79c75e7 election
add 08880f9 election
add 11ddd3d merge cluster_new
add cf58cbc 60 elections
add cd80b6c not qeual
add c35c530 equal
add d515a59 index diff
add 06364e5 remove scale
add b7159ee in queue time
add 15b0d9b log dispatch
add eaf6615 timer
add 81b49c8 timer
add 2501b2c timer
add 20d891a log
add 6fa492d create timne
add 661080c binding
add a4dccbb histo
add 8fa2f90 append log
add ccd7a0d handler
add 4be9832 log
add d4a2682 log
add 1417456 log
add 35f4e76 log
add 000ce2c log
add 2b6b11f timer
add 58acaf7 bingding=2
add e5cfe2a binding=1
add de6e713 histo
add a426503 histo=100
add b8bb7b3 histo=180
add 0b19c04 remove histo
add fae1099 Merge branch 'cluster_performance' into cluster_new
add 4c3395a refactor timer
add 03cdb71 Merge branch 'cluster_new' of
github.com:apache/incubator-iotdb into cluster_new
add 50994cd fix test
add f9749fb Merge branch 'cluster_premerge' into cluster_new
add 842619d fix after merge
add 2fb5d14 fix code smells
add ffa9b2d Revert incorrect sonar fix in sync module (#1740)
add 0d853dc [IOTDB-869] Failed to insert data via Windows CLI (#1714)
add 5160615 add compaction resource delete (#1741)
add 8421bbb fix cross-tests bug (#1743)
add 8c0f097 Merge branch 'master' into cluster_premerge
add b37ff19 Merge branch 'cluster_premerge' into cluster_new
add c5a2391 fix flush plan
add 3b600e6 Merge branch 'cluster_premerge' into cluster_new
add 8862df9 add device read lock when getting schemas
add 703ed15 add clientPort for Node
add c723230 finish server logic
add 11c4264 adjust stane-alone session architecture to support cluster
session interface
add ed4895a add single insert redirection && deepcopy status in server to
avoid mistake
add 09fd396 add batch insert direction
add 8110e22 Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add 83574a1 update clientport docs and nodetools
add 229779f adjust close cache leader logic to avoid NPE && add TODO
parallel && remove sessionExample wrong comments and test codes
add d6331be Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add 31817d1 fix review
add efcf3fe Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add 5869775 adjust insertTabletPlan maxTime and minTime cache
add dabae00 Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add b2e92ed Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add 7d12d5b Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add ba4a74d Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add 3a949ba Merge branch 'cluster_new' of
github.com:Apache/incubator-iotdb into cluster_new_cache_leader
add 69c0527 Merge pull request #1691 from
LebronAl/cluster_new_cache_leader
add b15f047 fix license
add 69386f2 fix cross tests
add 5a5a8db Merge branch 'cluster_premerge' into cluster_new
add 0d8fd2e delete lock in the LeafNode (#1745)
add 7f59dc5 Merge branch 'master' into cluster_premerge
add 4c2d060 Merge branch 'cluster_premerge' into cluster_new
add 3d5b7b6 fix MergeManagerTest and disable port examinations in
EnvironmentUtils
add 78fb24f Merge branch 'cluster_premerge' into cluster_new
add 593d26d fix code smells
add 0a1529e print result of cross test
add 06eb546 add cross test print
add 8971a3a catch exception (#1748)
add 7809b9c fix ProgressBar bug (#1747)
add 85ff7e6 [IOTDB-872] Use system timezone in CLI (#1722)
add 0de9fff [IOTDB-904] fix update last cache NullPointerException (#1752)
add 479bfad Update maven download url for TravisCI (WinOS) (#1754)
add 19a2a54 Merge branch 'master' into cluster_premerge
add 6d6a93c Merge branch 'cluster_premerge' into cluster_new
add 7418ed6 fix after merge
add 1991cb2 add unit test
add 2f6aa46 fix license
add 886b12f modify cross test
add 9a0e6de add print in cross test
add 0bdc1e1 Change TreeSet to List in getAllDevices (#1756)
add 38bf656 Improve the readUnLock way while inserting (#1757)
add ee8c17f update the website because of graduation (#1755)
add 3df2da3 fix ImportCsvToolIT bug
add 72aaa98 Merge branch 'master' into cluster_premerge
add 208b61f Merge branch 'cluster_premerge' into cluster_new
add 89136f2 fix after merge
add 2c8cc68 fix test
add 0af270a add unit tests
add a7f6542 fix cross test
add a1260a0 Fixed getFloat(int ColumnIndex) Method.
add f2820e4 [bug] modify disableIS08601 to disableISO8601
add 3db6cb0 - Removed the incubation resources from the produced jars -
Made the source plugin create source-jars even for SNAPSHOT builds
add 617960f Merge branch 'master' into cluster_premerge
add 5f8826b Merge branch 'cluster_premerge' into cluster_new
add acf598d add RaftLogManager tests and fix AsyncDataLogApplierTests
add adb5926 [IOTDB-870] change tags and attributes output format to two
columns with json values(#1731)
add 5fa23d0 [IOTDB-892] Replace fastjson with Gson (#1728)
add c2ca774 Avoid type conversion when encoding MeasureSchema (#1749)
add 8415385 Merge branch 'master' into cluster_premerge
add 83937e1 Merge branch 'cluster_premerge' into cluster_new
add c8c0af4 fix MTreeTest
add 5168ce1 Merge branch 'cluster_premerge' into cluster_new
add 49279c0 fix show timeseries
add 7e562ab add FileSnapshotTest and fix AsyncDataLogApplierTest
add 348489c update FileSnapshotTest
add 0a146e7 fix tests
add 044e5a3 record the down node
add 7b0ea89 fix election vote and MetaSimpleSnspshot
add 1c7c5fe inscrease the catch up timeout
add 3460bf1 code refine
add abf8f4e Merge pull request #1777 from
neuyilan/apache_cluster_new_0927_fix_down_startup
add b3b8c41 Update
server/src/main/java/org/apache/iotdb/db/exception/runtime/SQLParserException.java
add ece4928 Update DML Data Manipulation Language.md (#1769)
add 2e7d902 [IOTDB-863]: add a switch to drop ouf-of-order data that is
recognized by IoTDB (#1693)
add 410815d [IOTDB-907] Change TreeSet to HashSet in getAllDevices (#1772)
add 1e3d945 [IOTDB-919] Update License binary as fastjson has been
removed (#1773)
add 824562c Merge branch 'master' into cluster_premerge
add 153de82 Merge branch 'cluster_premerge' into cluster_new
add b4e91db fix tests
add 67fc333 improve test speed
add 0b84e44 improve AsyncDataLogApplier
add b3e7bb3 refactor exception capture
add 599861d roll back typo
add d10dc8e add comments and synchronized on apply
add 57df69a extend instrumenting
add d0467ee fix instrument
add 93e8121 fix meta query
new 904026a recursive
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 8 +
.mvn/wrapper/MavenWrapperDownloader.java | 10 +-
.travis.yml | 4 +-
DISCLAIMER | 6 -
Jenkinsfile | 37 +-
LICENSE-binary | 2 +-
.../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 128 +-
cli/pom.xml | 1 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 10 +
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 1 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 76 +-
.../java/org/apache/iotdb/cli/AbstractScript.java | 5 +
.../StorageEngine/WAL.md => client-cpp/README.md | 8 +-
client-cpp/client-cpp-example/pom.xml | 162 ++
client-cpp/client-cpp-example/src/CMakeLists.txt | 30 +
.../client-cpp-example/src/SessionExample.cpp | 296 +++
client-cpp/pom.xml | 360 ++++
client-cpp/src/assembly/client-cpp.xml | 60 +
client-cpp/src/main/CMakeLists.txt | 42 +
client-cpp/src/main/IOTDBSession.cpp | 1018 +++++++++
client-cpp/src/main/IOTDBSession.h | 633 ++++++
client-cpp/src/test/CMakeLists.txt | 41 +
client-cpp/src/test/cpp/sessionIT.cpp | 171 ++
.../src/test/main.cpp | 32 +-
client-py/src/Session.py | 2 +-
client-py/src/SessionExample.py | 2 +
.../resources/conf/iotdb-cluster.properties | 38 +-
.../resources/conf/iotdb-engine.properties | 2 +-
cluster/src/assembly/resources/conf/logback.xml | 5 +-
cluster/src/assembly/resources/sbin/start-node.bat | 2 +-
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 | 4 +-
.../iotdb/cluster/ClusterFileFlushPolicy.java | 13 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 59 +-
.../apache/iotdb/cluster/RemoteTsFileResource.java | 20 +-
.../iotdb/cluster/client/DataClientProvider.java | 79 +
.../cluster/client/async/AsyncClientPool.java | 68 +-
.../cluster/client/async/AsyncDataClient.java | 41 +-
.../client/async/AsyncDataHeartbeatClient.java | 6 +-
.../cluster/client/async/AsyncMetaClient.java | 12 +-
.../client/async/AsyncMetaHeartbeatClient.java | 2 +-
.../TimeoutChangeableTFastFramedTransport.java | 9 +-
.../cluster/client/sync/SyncClientAdaptor.java | 265 ++-
.../iotdb/cluster/client/sync/SyncClientPool.java | 6 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 11 +-
.../client/sync/SyncDataHeartbeatClient.java | 2 +-
.../iotdb/cluster/client/sync/SyncMetaClient.java | 2 +
.../client/sync/SyncMetaHeartbeatClient.java | 2 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 66 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 24 +-
.../exception/BadSeedUrlFormatException.java | 2 +-
...ion.java => SnapshotInstallationException.java} | 10 +-
.../exception/StartUpCheckFailureException.java | 4 +
.../CommitLogCallback.java} | 24 +-
.../apache/iotdb/cluster/log/CommitLogTask.java | 18 +-
.../org/apache/iotdb/cluster/log/HardState.java | 6 +-
.../java/org/apache/iotdb/cluster/log/Log.java | 46 +-
.../org/apache/iotdb/cluster/log/LogApplier.java | 13 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 364 ++++
.../org/apache/iotdb/cluster/log/Snapshot.java | 6 +
.../cluster/log/applier/AsyncDataLogApplier.java | 153 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 61 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 76 +-
.../iotdb/cluster/log/applier/MetaLogApplier.java | 8 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 19 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 53 +-
.../cluster/log/catchup/SnapshotCatchUpTask.java | 13 +-
.../iotdb/cluster/log/logtypes/AddNodeLog.java | 38 +-
.../cluster/log/logtypes/PhysicalPlanLog.java | 4 +-
.../cluster/log/manage/CommittedEntryManager.java | 76 +-
.../manage/FilePartitionedSnapshotLogManager.java | 63 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 9 +-
.../log/manage/PartitionedSnapshotLogManager.java | 15 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 368 +++-
.../log/manage/UnCommittedEntryManager.java | 23 +-
.../log/manage/serializable/LogManagerMeta.java | 4 +-
.../serializable/SyncLogDequeSerializer.java | 101 +-
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 417 +++-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 129 +-
.../cluster/log/snapshot/PartitionedSnapshot.java | 89 +-
.../cluster/log/snapshot/PullSnapshotTask.java | 23 +-
.../log/snapshot/PullSnapshotTaskDescriptor.java | 2 +-
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 46 +-
.../cluster/log/snapshot/SnapshotInstaller.java | 20 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 1079 +++++++++-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 71 +-
.../cluster/partition/NodeAdditionResult.java | 18 -
.../iotdb/cluster/partition/NodeRemovalResult.java | 16 +-
.../iotdb/cluster/partition/PartitionTable.java | 47 +-
.../cluster/partition/{ => slot}/SlotManager.java | 21 +-
.../SlotNodeAdditionResult.java} | 18 +-
.../partition/slot/SlotNodeRemovalResult.java | 29 +-
.../partition/{ => slot}/SlotPartitionTable.java | 65 +-
.../iotdb/cluster/partition/slot/SlotStrategy.java | 36 +
.../cluster/query/ClusterConcatPathOptimizer.java | 18 +-
.../cluster/query/ClusterDataQueryExecutor.java | 31 +-
.../cluster/query/ClusterPhysicalGenerator.java | 37 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 319 +--
.../iotdb/cluster/query/ClusterPlanRouter.java | 49 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 4 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 5 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 659 ++++++
.../{ => aggregate}/ClusterAggregateExecutor.java | 27 +-
.../cluster/query/aggregate/ClusterAggregator.java | 211 ++
.../query/dataset/ClusterAlignByDeviceDataSet.java | 17 +-
.../cluster/query/fill/ClusterFillExecutor.java | 6 +-
.../cluster/query/fill/ClusterLinearFill.java | 30 +-
.../cluster/query/fill/ClusterPreviousFill.java | 171 +-
.../cluster/query/fill/PreviousFillArguments.java | 8 +-
.../iotdb/cluster/query/filter/SlotSgFilter.java | 6 +-
.../cluster/query/filter/SlotTsFileFilter.java | 7 +-
.../groupby/ClusterGroupByNoVFilterDataSet.java | 13 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 19 +-
.../query/groupby/MergeGroupByExecutor.java | 47 +-
.../query/groupby/RemoteGroupByExecutor.java | 44 +-
.../query/last/ClusterLastQueryExecutor.java | 20 +-
.../cluster/query/manage/ClusterQueryManager.java | 4 +-
.../iotdb/cluster/query/manage/NodeStatus.java | 3 +-
.../cluster/query/manage/QueryCoordinator.java | 28 +-
.../cluster/query/reader/ClusterReaderFactory.java | 551 +++++
.../cluster/query/reader/ClusterTimeGenerator.java | 16 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 49 +-
.../iotdb/cluster/query/reader/EmptyReader.java | 33 +-
.../cluster/query/reader/ManagedMergeReader.java | 1 +
.../query/reader/RemoteSimpleSeriesReader.java | 6 +-
.../apache/iotdb/cluster/server/ClientServer.java | 24 +-
.../iotdb/cluster/server/DataClusterServer.java | 57 +-
.../iotdb/cluster/server/MetaClusterServer.java | 3 +-
.../apache/iotdb/cluster/server/NodeReport.java | 25 +-
.../java/org/apache/iotdb/cluster/server/Peer.java | 21 +
.../cluster/server/PullSnapshotHintService.java | 2 +-
.../apache/iotdb/cluster/server/RaftServer.java | 56 +-
.../iotdb/cluster/server/StoppedMemberManager.java | 8 +-
.../org/apache/iotdb/cluster/server/Timer.java | 203 ++
.../handlers/caller/AppendNodeEntryHandler.java | 30 +-
.../server/handlers/caller/ElectionHandler.java | 4 +-
.../server/handlers/caller/GenericHandler.java | 6 +
.../caller/GetChildNodeNextLevelPathHandler.java | 2 +-
.../handlers/caller/GetNodesListHandler.java | 2 +-
.../caller/GetTimeseriesSchemaHandler.java | 2 +-
.../server/handlers/caller/HeartbeatHandler.java | 75 +-
.../server/handlers/caller/JoinClusterHandler.java | 2 +-
.../server/handlers/caller/LogCatchUpHandler.java | 4 +
.../handlers/caller/LogCatchUpInBatchHandler.java | 9 +-
...dler.java => PullMeasurementSchemaHandler.java} | 6 +-
.../caller/PullTimeseriesSchemaHandler.java | 10 +-
.../handlers/forwarder/ForwardPlanHandler.java | 3 +-
.../server/heartbeat/DataHeartbeatServer.java | 2 +-
.../server/heartbeat/DataHeartbeatThread.java | 20 +-
.../cluster/server/heartbeat/HeartbeatServer.java | 29 +-
.../cluster/server/heartbeat/HeartbeatThread.java | 18 +-
.../server/heartbeat/MetaHeartbeatServer.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 1290 ++---------
.../cluster/server/member/MetaGroupMember.java | 2256 ++++----------------
.../iotdb/cluster/server/member/RaftMember.java | 2240 ++++++++++---------
.../cluster/server/service/BaseAsyncService.java | 18 +-
.../cluster/server/service/BaseSyncService.java | 13 +-
.../cluster/server/service/DataAsyncService.java | 110 +-
.../cluster/server/service/DataSyncService.java | 90 +-
.../cluster/server/service/MetaAsyncService.java | 6 +-
.../cluster/server/service/MetaSyncService.java | 2 +-
.../service/package-info.java} | 13 +-
.../apache/iotdb/cluster/utils/ClientUtils.java | 70 +
.../apache/iotdb/cluster/utils/ClusterNode.java | 26 +-
.../iotdb/cluster/utils/ClusterQueryUtils.java | 18 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 126 +-
.../org/apache/iotdb/cluster/utils/IOUtils.java | 87 +
.../apache/iotdb/cluster/utils/PartitionUtils.java | 28 +-
.../apache/iotdb/cluster/utils/PlanSerializer.java | 51 +
.../apache/iotdb/cluster/utils/StatusUtils.java | 14 +
.../cluster/utils/nodetool/ClusterMonitor.java | 31 +-
.../utils/nodetool/ClusterMonitorMBean.java | 13 +-
.../iotdb/cluster/utils/nodetool/NodeTool.java | 41 +-
.../iotdb/cluster/utils/nodetool/Printer.java | 1 +
.../cluster/utils/nodetool/function/LogView.java | 7 +-
.../utils/nodetool/function/NodeToolCmd.java | 4 +-
.../cluster/utils/nodetool/function/Partition.java | 2 -
.../cluster/utils/nodetool/function/Status.java | 4 +-
.../iotdb/cluster/client/AsyncClientPoolTest.java | 131 --
.../cluster/client/DataClientProviderTest.java | 73 +
.../cluster/client/async/AsyncClientPoolTest.java | 188 ++
.../cluster/client/async/AsyncDataClientTest.java | 61 +
.../async/AsyncDataHeartbeatClientTest.java} | 47 +-
.../cluster/client/async/AsyncMetaClientTest.java | 61 +
.../async/AsyncMetaHeartbeatClientTest.java} | 47 +-
.../TimeoutChangeableTFastFramedTransportTest.java | 24 +
.../cluster/client/sync/SyncClientAdaptorTest.java | 345 +++
.../cluster/client/sync/SyncClientPoolTest.java | 157 ++
.../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 | 1 -
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 35 +-
.../{TestClient.java => TestAsyncClient.java} | 8 +-
.../cluster/common/TestAsyncClientFactory.java | 2 +-
.../iotdb/cluster/common/TestAsyncDataClient.java | 29 +-
.../iotdb/cluster/common/TestDataGroupMember.java | 2 +-
.../org/apache/iotdb/cluster/common/TestLog.java | 4 +
.../iotdb/cluster/common/TestLogApplier.java | 35 +-
.../cluster/common/TestPartitionedLogManager.java | 7 +-
.../apache/iotdb/cluster/common/TestSnapshot.java | 18 +
.../iotdb/cluster/common/TestSyncClient.java} | 30 +-
...ientFactory.java => TestSyncClientFactory.java} | 55 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 86 +-
.../apache/iotdb/cluster/log/HardStateTest.java | 2 +-
.../apache/iotdb/cluster/log/LogParserTest.java | 7 +-
.../log/applier/AsyncDataLogApplierTest.java | 158 ++
.../cluster/log/applier/DataLogApplierTest.java | 188 +-
.../cluster/log/applier/MetaLogApplierTest.java | 50 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 225 +-
.../cluster/log/catchup/LogCatchUpTaskTest.java | 151 +-
.../log/catchup/SnapshotCatchUpTaskTest.java | 145 +-
.../cluster/log/logtypes/SerializeLogTest.java | 32 +-
.../log/manage/CommittedEntryManagerTest.java | 7 +-
.../FilePartitionedSnapshotLogManagerTest.java | 26 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 15 +-
.../cluster/log/manage/RaftLogManagerTest.java | 353 ++-
.../serializable/SyncLogDequeSerializerTest.java | 100 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 404 ++++
.../log/snapshot/MetaSimpleSnapshotTest.java | 90 +
.../iotdb/cluster/partition/SlotManagerTest.java | 25 +-
.../cluster/partition/SlotPartitionTableTest.java | 177 +-
.../apache/iotdb/cluster/query/BaseQueryTest.java | 6 +-
.../query/ClusterAggregateExecutorTest.java | 36 +-
.../query/ClusterDataQueryExecutorTest.java | 12 +-
.../cluster/query/ClusterFillExecutorTest.java | 13 +-
.../query/ClusterPhysicalGeneratorTest.java | 9 +-
.../cluster/query/ClusterPlanExecutorTest.java | 18 +-
.../cluster/query/ClusterQueryRouterTest.java | 43 +-
.../ClusterGroupByNoVFilterDataSetTest.java | 10 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 14 +-
.../query/groupby/MergeGroupByExecutorTest.java | 15 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 24 +-
.../cluster/query/manage/QueryCoordinatorTest.java | 2 +
.../query/reader/ClusterTimeGeneratorTest.java | 13 +-
.../cluster/query/reader/DatasourceInfoTest.java | 14 +-
.../reader/RemoteSeriesReaderByTimestampTest.java | 111 +-
.../query/reader/RemoteSimpleSeriesReaderTest.java | 12 +-
.../handlers/caller/HeartbeatHandlerTest.java | 8 +-
....java => PullMeasurementSchemaHandlerTest.java} | 7 +-
.../handlers/forwarder/ForwardPlanHandlerTest.java | 12 +-
.../forwarder/GenericForwardHandlerTest.java | 70 -
.../server/heartbeat/DataHeartbeatThreadTest.java | 4 +-
.../server/heartbeat/HeartbeatThreadTest.java | 5 +-
.../server/heartbeat/MetaHeartbeatThreadTest.java | 44 +-
.../cluster/server/member/DataGroupMemberTest.java | 164 +-
.../iotdb/cluster/server/member/MemberTest.java | 105 +-
.../cluster/server/member/MetaGroupMemberTest.java | 228 +-
.../iotdb/cluster/utils/SerializeUtilTest.java | 14 +-
compile-tools/README.md | 147 ++
compile-tools/boost/pom.xml | 141 ++
compile-tools/boost/src/assembly/bundle.xml | 35 +
compile-tools/pom.xml | 121 ++
compile-tools/thrift/pom.xml | 420 ++++
compile-tools/thrift/src/assembly/compiler.xml | 37 +
compile-tools/thrift/src/assembly/cpp.xml | 51 +
compile-tools/thrift/src/assembly/python.xml | 38 +
cross-tests/pom.xml | 87 +
.../tests/tools/importCsv}/AbstractScript.java | 40 +-
.../tests/tools/importCsv/ImportCsvTestIT.java | 157 ++
.../iotdb/cross/tests}/utils/EnvironmentUtils.java | 28 +-
.../src/test/resources/iotdb-engine.properties | 0
distribution/pom.xml | 4 +-
distribution/src/assembly/distribution.xml | 3 -
docker/src/main/Dockerfile | 4 +-
docker/src/main/Dockerfile-0.10.1 | 41 +
docs/Development/VoteRelease.md | 12 +-
docs/Download/README.md | 16 +-
docs/SystemDesign/DataQuery/AlignByDeviceQuery.md | 10 +-
.../SystemDesign/StorageEngine/DataManipulation.md | 10 +-
docs/SystemDesign/StorageEngine/WAL.md | 24 +-
docs/SystemDesign/Tools/Sync.md | 2 +-
docs/UserGuide/Client/Command Line Interface.md | 32 +-
docs/UserGuide/Client/Programming - Native API.md | 185 +-
docs/UserGuide/Client/Programming - TsFile API.md | 2 +-
docs/UserGuide/Client/Status Codes.md | 1 +
.../Concept/Data Model and Terminology.md | 6 +-
.../Ecosystem Integration/Spark TsFile.md | 18 +-
.../Get Started/Frequently asked questions.md | 4 +-
.../DDL Data Definition Language.md | 13 +-
.../DML Data Manipulation Language.md | 30 +-
docs/UserGuide/Operation Manual/SQL Reference.md | 70 +-
docs/UserGuide/Server/Cluster Setup.md | 207 +-
docs/UserGuide/Server/Config Manual.md | 2 +-
docs/UserGuide/Server/Download.md | 2 +-
docs/UserGuide/Server/ServerFileList.md | 157 ++
docs/UserGuide/System Tools/NodeTool.md | 289 +++
docs/zh/Development/VoteRelease.md | 12 +-
docs/zh/Download/README.md | 16 +-
.../SystemDesign/DataQuery/AlignByDeviceQuery.md | 10 +-
docs/zh/SystemDesign/DataQuery/DataQuery.md | 2 +
docs/zh/SystemDesign/DataQuery/OrderByTimeQuery.md | 190 ++
.../SystemDesign/StorageEngine/DataManipulation.md | 10 +-
.../SystemDesign/StorageEngine/TsFileManagement.md | 225 ++
docs/zh/SystemDesign/StorageEngine/WAL.md | 23 +
docs/zh/UserGuide/Client/Command Line Interface.md | 28 +-
.../UserGuide/Client/Programming - Native API.md | 180 +-
.../UserGuide/Client/Programming - TsFile API.md | 2 +-
docs/zh/UserGuide/Client/Status Codes.md | 1 +
.../Concept/Data Model and Terminology.md | 4 +
.../Ecosystem Integration/Spark TsFile.md | 18 +-
.../Get Started/Frequently asked questions.md | 4 +-
.../DDL Data Definition Language.md | 26 +-
.../DML Data Manipulation Language.md | 28 +-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 72 +-
docs/zh/UserGuide/Server/Cluster Setup.md | 197 +-
docs/zh/UserGuide/Server/Config Manual.md | 2 +-
docs/zh/UserGuide/Server/ServerFileList.md | 153 ++
docs/zh/UserGuide/System Tools/NodeTool.md | 245 +++
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 4 +-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 2 +-
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 2 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 2 +-
.../iotdb/flink/FlinkTsFileStreamSource.java | 2 +-
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 3 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 3 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 44 +-
.../org/apache/iotdb/DataMigrationExample.java | 185 ++
.../main/java/org/apache/iotdb/SessionExample.java | 101 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 50 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 139 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 46 +-
flink-iotdb-connector/pom.xml | 1 -
.../java/org/apache/iotdb/flink/IoTDBSink.java | 3 +-
flink-tsfile-connector/pom.xml | 7 +
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 5 +-
.../iotdb/flink/tsfile/TsFileInputFormat.java | 19 +-
.../flink/tsfile/RowTsFileConnectorTestBase.java | 2 +-
.../controller/DatabaseConnectController.java | 120 +-
.../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 3 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 22 +-
.../org/apache/iotdb/hive/TSFHiveRecordReader.java | 1 +
.../org/apache/iotdb/hive/TsFileDeserializer.java | 1 +
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 11 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 2 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 6 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 6 +-
pom.xml | 51 +-
server/pom.xml | 10 +
.../resources/conf/iotdb-engine.properties | 29 +-
server/src/assembly/resources/conf/iotdb-env.bat | 14 +-
server/src/assembly/resources/conf/iotdb-env.sh | 1 +
server/src/assembly/resources/conf/logback.xml | 1 +
.../src/assembly/resources/sbin/start-server.bat | 3 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 9 +-
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 18 +-
.../iotdb/db/auth/role/LocalFileRoleAccessor.java | 4 +
.../iotdb/db/auth/user/LocalFileUserAccessor.java | 4 +
.../org/apache/iotdb/db/concurrent/ThreadName.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 127 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 3 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 127 +-
.../db/conf/adapter/ActiveTimeSeriesCounter.java | 6 +-
.../iotdb/db/conf/adapter/CompressionRatio.java | 4 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 269 ++-
.../db/engine/cache/TimeSeriesMetadataCache.java | 6 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 4 -
.../iotdb/db/engine/flush/MemTableFlushTask.java | 26 +-
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 2 +-
.../db/engine/flush/pool/AbstractPoolManager.java | 1 +
.../engine/flush/pool/VmMergeTaskPoolManager.java | 75 -
.../iotdb/db/engine/memtable/AbstractMemTable.java | 15 +-
.../iotdb/db/engine/merge/manage/MergeContext.java | 8 +-
.../iotdb/db/engine/merge/manage/MergeManager.java | 69 +-
.../db/engine/merge/manage/MergeResource.java | 16 +-
.../iotdb/db/engine/merge/recover/LogAnalyzer.java | 64 +-
.../iotdb/db/engine/merge/recover/MergeLogger.java | 8 +-
.../engine/merge/selector/IMergePathSelector.java | 4 +-
.../engine/merge/selector/NaivePathSelector.java | 10 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 65 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 23 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 28 +-
.../db/engine/merge/task/RecoverMergeTask.java | 8 +-
.../iotdb/db/engine/modification/Deletion.java | 6 +-
.../iotdb/db/engine/modification/Modification.java | 10 +-
.../db/engine/modification/ModificationFile.java | 3 +-
.../io/LocalTextModificationAccessor.java | 18 +-
.../db/engine/querycontext/QueryDataSource.java | 11 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 4 +-
.../engine/storagegroup/StorageGroupProcessor.java | 571 ++---
.../iotdb/db/engine/storagegroup/TsFileLock.java | 6 +-
.../db/engine/storagegroup/TsFileProcessor.java | 497 +----
.../db/engine/storagegroup/TsFileResource.java | 52 +-
.../HotCompactionMergeTaskPoolManager.java | 113 +
.../engine/tsfilemanagement/TsFileManagement.java | 149 ++
.../tsfilemanagement/TsFileManagementStrategy.java | 28 +-
.../level/LevelTsFileManagement.java | 597 ++++++
.../normal/NormalTsFileManagement.java | 171 ++
.../utils/HotCompactionLogAnalyzer.java} | 37 +-
.../utils/HotCompactionLogger.java} | 38 +-
.../utils/HotCompactionUtils.java} | 147 +-
.../iotdb/db/engine/upgrade/UpgradeTask.java | 48 +-
.../version/SimpleFileVersionController.java | 1 +
.../metadata/DataTypeMismatchException.java | 25 +-
.../exception/metadata/PathNotExistException.java | 16 +-
.../db/exception/query/QueryProcessException.java | 4 +
.../db/exception/runtime/SQLParserException.java | 2 +-
.../org/apache/iotdb/db/metadata/MManager.java | 552 ++---
.../java/org/apache/iotdb/db/metadata/MTree.java | 466 ++--
.../org/apache/iotdb/db/metadata/MetaUtils.java | 79 +-
.../org/apache/iotdb/db/metadata/PartialPath.java | 249 +++
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 66 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 6 +-
.../apache/iotdb/db/metrics/server/JettyUtil.java | 30 +-
.../iotdb/db/metrics/server/MetricsSystem.java | 26 +-
.../iotdb/db/metrics/server/QueryServlet.java | 28 +-
.../iotdb/db/metrics/server/ServerArgument.java | 63 +-
.../iotdb/db/metrics/server/SqlArgument.java | 26 +-
.../apache/iotdb/db/metrics/sink/ConsoleSink.java | 26 +-
.../iotdb/db/metrics/sink/MetricsServletSink.java | 26 +-
.../org/apache/iotdb/db/metrics/sink/Sink.java | 26 +-
.../apache/iotdb/db/metrics/source/JvmSource.java | 26 +-
.../iotdb/db/metrics/source/MetricsSource.java | 26 +-
.../org/apache/iotdb/db/metrics/source/Source.java | 26 +-
.../apache/iotdb/db/metrics/ui/MetricsPage.java | 37 +-
.../apache/iotdb/db/metrics/ui/MetricsWebUI.java | 26 +-
.../apache/iotdb/db/monitor/MonitorConstants.java | 11 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 16 +-
.../apache/iotdb/db/mqtt/JSONPayloadFormatter.java | 27 +-
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 6 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 62 +-
.../apache/iotdb/db/qp/constant/DatetimeUtils.java | 14 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 27 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 423 ++--
.../db/qp/logical/crud/BasicFunctionOperator.java | 10 +-
.../db/qp/logical/crud/BasicOperatorType.java | 13 +-
.../iotdb/db/qp/logical/crud/FilterOperator.java | 26 +-
.../iotdb/db/qp/logical/crud/FromOperator.java | 8 +-
.../iotdb/db/qp/logical/crud/InOperator.java | 10 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 20 +
.../iotdb/db/qp/logical/crud/SFWOperator.java | 6 +-
.../iotdb/db/qp/logical/crud/SelectOperator.java | 15 +-
.../db/qp/logical/sys/AlterTimeSeriesOperator.java | 11 +-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 8 +-
.../iotdb/db/qp/logical/sys/CountOperator.java | 10 +-
.../qp/logical/sys/CreateTimeSeriesOperator.java | 17 +-
.../db/qp/logical/sys/DeletePartitionOperator.java | 7 +-
.../qp/logical/sys/DeleteStorageGroupOperator.java | 9 +-
.../qp/logical/sys/DeleteTimeSeriesOperator.java | 9 +-
.../iotdb/db/qp/logical/sys/FlushOperator.java | 8 +-
.../db/qp/logical/sys/SetStorageGroupOperator.java | 8 +-
.../iotdb/db/qp/logical/sys/SetTTLOperator.java | 7 +-
.../db/qp/logical/sys/ShowChildPathsOperator.java | 8 +-
.../db/qp/logical/sys/ShowDevicesOperator.java | 8 +-
...Operator.java => ShowStorageGroupOperator.java} | 72 +-
.../iotdb/db/qp/logical/sys/ShowTTLOperator.java | 8 +-
.../db/qp/logical/sys/ShowTimeSeriesOperator.java | 8 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 29 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 17 +-
.../db/qp/physical/crud/DeletePartitionPlan.java | 10 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 30 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 56 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 123 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 98 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 25 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 9 +-
.../iotdb/db/qp/physical/crud/UpdatePlan.java | 16 +-
.../db/qp/physical/sys/AlterTimeSeriesPlan.java | 21 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 26 +-
.../iotdb/db/qp/physical/sys/ClearCachePlan.java | 5 +-
.../apache/iotdb/db/qp/physical/sys/CountPlan.java | 9 +-
.../db/qp/physical/sys/CreateSnapshotPlan.java | 5 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 24 +-
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 4 +-
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 25 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 26 +-
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 217 +-
.../db/qp/physical/sys/LoadConfigurationPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 9 +-
.../apache/iotdb/db/qp/physical/sys/MergePlan.java | 5 +-
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 6 +-
.../db/qp/physical/sys/SetStorageGroupPlan.java | 20 +-
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 23 +-
.../db/qp/physical/sys/ShowChildPathsPlan.java | 8 +-
.../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 8 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 6 +-
...wDevicesPlan.java => ShowStorageGroupPlan.java} | 71 +-
.../iotdb/db/qp/physical/sys/ShowTTLPlan.java | 10 +-
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 15 +-
.../iotdb/db/qp/physical/sys/TracingPlan.java | 5 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 237 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 254 +--
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 117 +-
.../optimizer/MergeSingleFilterOptimizer.java | 17 +-
.../db/query/aggregation/AggregateResult.java | 7 +-
.../db/query/aggregation/impl/AvgAggrResult.java | 7 +-
.../db/query/aggregation/impl/CountAggrResult.java | 4 +-
.../aggregation/impl/FirstValueAggrResult.java | 9 +-
.../aggregation/impl/LastValueAggrResult.java | 15 +-
.../query/aggregation/impl/MaxTimeAggrResult.java | 7 +-
.../query/aggregation/impl/MaxValueAggrResult.java | 13 +-
.../query/aggregation/impl/MinTimeAggrResult.java | 9 +-
.../query/aggregation/impl/MinValueAggrResult.java | 11 +-
.../db/query/aggregation/impl/SumAggrResult.java | 7 +-
.../db/query/control/QueryResourceManager.java | 8 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 31 +-
.../apache/iotdb/db/query/dataset/ListDataSet.java | 10 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 24 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 17 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 44 +-
.../db/query/dataset/ShowTimeSeriesResult.java | 81 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 85 +-
.../iotdb/db/query/dataset/SingleDataSet.java | 7 +-
.../dataset/groupby/GroupByEngineDataSet.java | 46 +-
.../db/query/dataset/groupby/GroupByExecutor.java | 3 +
.../query/dataset/groupby/GroupByFillDataSet.java | 79 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 19 +-
.../groupby/GroupByWithValueFilterDataSet.java | 131 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 76 +-
.../dataset/groupby/LocalGroupByExecutor.java | 122 +-
.../db/query/executor/AggregationExecutor.java | 99 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 19 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 65 +-
.../iotdb/db/query/executor/QueryRouter.java | 48 +-
.../db/query/executor/RawDataQueryExecutor.java | 75 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 4 +-
.../db/query/executor/fill/LastPointReader.java | 7 +-
.../iotdb/db/query/executor/fill/LinearFill.java | 24 +-
.../iotdb/db/query/executor/fill/PreviousFill.java | 11 +-
.../FixLengthIExternalSortFileDeserializer.java | 75 +-
.../db/query/reader/chunk/MemChunkReader.java | 28 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 45 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 5 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 11 +-
.../reader/series/BaseManagedSeriesReader.java} | 29 +-
.../reader/series/DescSeriesReaderByTimestamp.java | 53 +
.../db/query/reader/series/IReaderByTimestamp.java | 15 +-
.../query/reader/series/SeriesAggregateReader.java | 15 +-
.../reader/series/SeriesRawDataBatchReader.java | 15 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 354 ++-
.../reader/series/SeriesReaderByTimestamp.java | 30 +-
.../reader/universal/DescPriorityMergeReader.java | 51 +
.../reader/universal/PriorityMergeReader.java | 28 +-
.../query/timegenerator/ServerTimeGenerator.java | 57 +-
.../apache/iotdb/db/rescon/CachedStringPool.java | 28 +-
.../org/apache/iotdb/db/rescon/MemTablePool.java | 2 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 7 +-
.../iotdb/db/service/MetricsServiceMBean.java | 26 +-
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../org/apache/iotdb/db/service/StaticResps.java | 8 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 393 ++--
.../iotdb/db/sync/receiver/load/FileLoader.java | 12 +-
.../db/sync/receiver/load/FileLoaderManager.java | 1 +
.../receiver/recover/SyncReceiverLogAnalyzer.java | 1 +
.../db/sync/receiver/transfer/SyncServiceImpl.java | 15 +-
.../db/sync/sender/manage/SyncFileManager.java | 18 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 8 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 12 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 3 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 254 +--
.../iotdb/db/tools/memestimation/MemEstTool.java | 40 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 1 +
.../db/tools/watermark/WatermarkDetector.java | 94 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 62 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 4 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 9 +-
.../org/apache/iotdb/db/utils/FilePathUtils.java | 21 +-
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 17 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 10 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 2 +
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 108 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 103 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 25 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 3 +-
.../org/apache/iotdb/db/utils/UpgradeUtils.java | 11 +-
.../iotdb/db/writelog/io/BatchLogReader.java | 3 +-
.../writelog/manager/MultiFileLogNodeManager.java | 36 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 61 +-
.../writelog/recover/TsFileRecoverPerformer.java | 162 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 18 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 76 +
.../org/apache/iotdb/db/constant/TestConstant.java | 16 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 43 +-
.../db/engine/cache/ChunkMetadataCacheTest.java | 26 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 5 +-
.../iotdb/db/engine/memtable/MemTablePoolTest.java | 1 +
.../apache/iotdb/db/engine/merge/MergeLogTest.java | 3 +-
.../iotdb/db/engine/merge/MergeManagerTest.java | 14 +
.../iotdb/db/engine/merge/MergeOverLapTest.java | 23 +-
.../iotdb/db/engine/merge/MergeTaskTest.java | 50 +-
.../apache/iotdb/db/engine/merge/MergeTest.java | 8 +-
.../engine/modification/DeletionFileNodeTest.java | 96 +-
.../db/engine/modification/DeletionQueryTest.java | 134 +-
.../engine/modification/ModificationFileTest.java | 17 +-
.../io/LocalTextModificationAccessorTest.java | 9 +-
.../storagegroup/FileNodeManagerBenchmark.java | 11 +-
.../storagegroup/StorageGroupProcessorTest.java | 352 ++-
.../iotdb/db/engine/storagegroup/TTLTest.java | 95 +-
.../storagegroup/TsFileProcessorEnableVmTest.java | 201 --
.../engine/storagegroup/TsFileProcessorTest.java | 22 +-
.../version/SysTimeVersionControllerTest.java | 1 +
.../iotdb/db/integration/IoTDBAddSubDeviceIT.java | 9 +-
.../iotdb/db/integration/IoTDBAggregationIT.java | 35 +-
.../integration/IoTDBAggregationLargeDataIT.java | 285 +--
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 49 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 164 +-
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 603 ++++++
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 1290 +++++------
.../apache/iotdb/db/integration/IoTDBCloseIT.java | 112 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 28 +-
.../db/integration/IoTDBDeleteStorageGroupIT.java | 14 +-
.../db/integration/IoTDBDeleteTimeseriesIT.java | 184 ++
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 24 +-
.../apache/iotdb/db/integration/IoTDBFillIT.java | 283 +--
.../db/integration/IoTDBFlushQueryMergeIT.java | 67 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 21 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 139 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 84 +-
.../iotdb/db/integration/IoTDBMergeTest.java | 68 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 189 +-
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 9 +-
.../db/integration/IoTDBMultiOverlappedPageIT.java | 20 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 25 +-
.../db/integration/IoTDBMultiStatementsIT.java | 92 +-
.../iotdb/db/integration/IoTDBNumberPathIT.java | 13 +-
.../db/integration/IoTDBOverlappedPageIT.java | 12 +-
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 152 +-
.../iotdb/db/integration/IoTDBRecoverIT.java | 3 +
.../db/integration/IoTDBRemovePartitionIT.java | 30 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 149 +-
.../db/integration/IoTDBSequenceDataQueryIT.java | 51 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 55 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 336 ++-
.../integration/IoTDBSortedShowTimeseriesIT.java | 128 +-
.../iotdb/db/integration/IoTDBTagAlterIT.java | 424 ++--
.../apache/iotdb/db/integration/IoTDBTagIT.java | 714 ++++---
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 12 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 71 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 246 +--
.../iotdb/db/metadata/MManagerImproveTest.java | 45 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 325 +--
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 65 +
.../apache/iotdb/db/metadata/PartialPathTest.java | 74 +
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 39 +-
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 7 +-
.../iotdb/db/qp/plan/ConcatOptimizerTest.java | 31 +-
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 51 +-
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 130 +-
.../apache/iotdb/db/qp/plan/SerializationTest.java | 81 +-
.../dataset/EngineDataSetWithValueFilterTest.java | 25 +-
.../db/query/dataset/GroupByFillDataSetTest.java | 188 ++
.../db/query/dataset/GroupByLevelDataSetTest.java | 1 -
.../db/query/dataset/GroupByTimeDataSetTest.java | 151 +-
.../query/executor/GroupByEngineDataSetTest.java | 12 +-
.../reader/series/SeriesAggregateReaderTest.java | 18 +-
.../reader/series/SeriesReaderByTimestampTest.java | 11 +-
.../db/query/reader/series/SeriesReaderTest.java | 49 +-
.../query/reader/series/SeriesReaderTestUtil.java | 22 +-
.../apache/iotdb/db/sql/CheckPathValidityTest.java | 3 +-
.../db/sync/receiver/load/FileLoaderTest.java | 51 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 39 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 3 +-
.../sender/recover/SyncSenderLogAnalyzerTest.java | 7 +-
.../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 74 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 17 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 74 +-
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 7 +-
.../db/utils/datastructure/PrecisionTest.java | 2 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 26 +-
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 8 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 32 +-
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 11 +-
.../db/writelog/io/MultiFileLogReaderTest.java | 6 +-
.../db/writelog/recover/DeviceStringTest.java | 16 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 89 +-
.../recover/RecoverResourceFromReaderTest.java | 24 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 20 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 35 +-
.../apache/iotdb/rpc/IoTDBConnectionException.java | 2 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 1 +
.../org/apache/iotdb/rpc/RedirectException.java | 22 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 24 +-
.../iotdb/rpc/StatementExecutionException.java | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../main/java/org/apache/iotdb/session/Config.java | 2 +-
.../java/org/apache/iotdb/session/Session.java | 1214 +++++------
.../apache/iotdb/session/SessionConnection.java | 404 ++++
.../org/apache/iotdb/session/SessionUtils.java | 1 +
.../org/apache/iotdb/session/pool/SessionPool.java | 36 +-
...DBSessionIT.java => IoTDBSessionComplexIT.java} | 910 ++------
.../org/apache/iotdb/session/IoTDBSessionIT.java | 337 ++-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 261 +++
.../java/org/apache/iotdb/session/SessionUT.java | 14 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 69 +-
site/iotdb-doap.rdf | 80 +
site/src/main/.vuepress/theme/components/Page.vue | 3 +-
.../theme/global-components/Contributor.vue | 13 +-
.../.vuepress/theme/global-components/IoTDB.vue | 17 +-
.../.vuepress/theme/global-components/IoTDBZH.vue | 23 +-
site/src/main/package.json | 4 +-
.../iotdb/spark/tsfile/qp/QueryProcessor.java | 2 +
.../qp/optimizer/MergeSingleFilterOptimizer.java | 1 +
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 2 +
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 2 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 71 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 54 +-
thrift/src/main/thrift/cluster.thrift | 17 +-
thrift/src/main/thrift/rpc.thrift | 48 +-
thrift/src/pypi/README.md | 6 +-
thrift/src/pypi/setup.py | 2 +-
tools/download_staged_release.sh | 4 +-
tsfile/pom.xml | 8 +-
.../tsfile/common/constant/TsFileConstant.java | 5 +-
.../iotdb/tsfile/encoding/encoder/RleEncoder.java | 1 +
.../file/metadata/MetadataIndexConstructor.java | 1 +
.../file/metadata/enums/CompressionType.java | 67 +-
.../tsfile/file/metadata/enums/TSDataType.java | 60 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 67 +-
.../file/metadata/statistics/Statistics.java | 5 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 65 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 40 +-
.../iotdb/tsfile/read/common/BatchDataFactory.java | 23 +-
.../iotdb/tsfile/read/common/DescBatchData.java | 66 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 206 +-
.../iotdb/tsfile/read/common/TimeColumn.java | 111 -
.../apache/iotdb/tsfile/read/common/TimeRange.java | 11 +-
.../read/controller/MetadataQuerierByFileImpl.java | 2 +
.../query/dataset/DataSetWithoutTimeGenerator.java | 1 +
.../tsfile/read/query/dataset/QueryDataSet.java | 8 +
.../read/query/timegenerator/TimeGenerator.java | 6 +-
.../query/timegenerator/TsFileTimeGenerator.java | 5 +
.../read/query/timegenerator/node/AndNode.java | 58 +-
.../read/query/timegenerator/node/LeafNode.java | 1 -
.../read/query/timegenerator/node/OrNode.java | 38 +-
.../iotdb/tsfile/read/reader/IPageReader.java | 7 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 15 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 2 +
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 5 +-
.../iotdb/tsfile/utils/RamUsageEstimator.java | 1 +
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 1 -
.../apache/iotdb/tsfile/write/record/Tablet.java | 57 +
.../tsfile/write/schema/MeasurementSchema.java | 78 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 6 +-
.../tsfile/encoding/decoder/BitmapDecoderTest.java | 1 -
.../iotdb/tsfile/read/ReadInPartitionTest.java | 22 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 20 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 59 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 71 +-
.../apache/iotdb/tsfile/read/common/PathTest.java | 80 +-
.../tsfile/read/controller/ChunkLoaderTest.java | 2 +-
.../controller/IMetadataQuerierByFileImplTest.java | 16 +-
.../read/filter/IExpressionOptimizerTest.java | 30 +-
.../read/query/executor/QueryExecutorTest.java | 20 +-
.../tsfile/read/query/timegenerator/NodeTest.java | 2 -
.../read/query/timegenerator/ReadWriteTest.java | 8 +-
.../query/timegenerator/ReaderByTimestampTest.java | 2 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 8 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 8 +-
.../query/timegenerator/TimeGeneratorTest.java | 6 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 22 +-
.../tsfile/read/reader/FakedTimeGenerator.java | 12 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 8 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 22 +-
.../iotdb/tsfile/utils/ReadWriteIOUtilsTest.java | 24 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 12 +-
.../iotdb/tsfile/utils/StringContainerTest.java | 5 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 109 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 91 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 16 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 4 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 4 +-
.../iotdb/tsfile/write/TsFileWriterTest.java | 18 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 51 +-
.../write/schema/converter/SchemaBuilderTest.java | 6 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 8 +-
.../writer/MeasurementSchemaSerializeTest.java | 55 +
.../write/writer/RestorableTsFileIOWriterTest.java | 83 +-
772 files changed, 35535 insertions(+), 17739 deletions(-)
delete mode 100644 DISCLAIMER
copy docs/zh/SystemDesign/StorageEngine/WAL.md => client-cpp/README.md (77%)
create mode 100644 client-cpp/client-cpp-example/pom.xml
create mode 100644 client-cpp/client-cpp-example/src/CMakeLists.txt
create mode 100644 client-cpp/client-cpp-example/src/SessionExample.cpp
create mode 100644 client-cpp/pom.xml
create mode 100644 client-cpp/src/assembly/client-cpp.xml
create mode 100644 client-cpp/src/main/CMakeLists.txt
create mode 100644 client-cpp/src/main/IOTDBSession.cpp
create mode 100644 client-cpp/src/main/IOTDBSession.h
create mode 100644 client-cpp/src/test/CMakeLists.txt
create mode 100644 client-cpp/src/test/cpp/sessionIT.cpp
copy
service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBConnectionException.java =>
client-cpp/src/test/main.cpp (56%)
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/client/DataClientProvider.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/{SnapshotApplicationException.java
=> SnapshotInstallationException.java} (76%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{server/handlers/forwarder/GenericForwardHandler.java
=> log/CommitLogCallback.java} (58%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowDevicesOperator.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotInstaller.java
(66%)
rename cluster/src/main/java/org/apache/iotdb/cluster/partition/{ =>
slot}/SlotManager.java (92%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/partition/{NodeAdditionResult.java
=> slot/SlotNodeAdditionResult.java} (78%)
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateSnapshotPlan.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeRemovalResult.java
(58%)
rename cluster/src/main/java/org/apache/iotdb/cluster/partition/{ =>
slot}/SlotPartitionTable.java (89%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotStrategy.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java
rename cluster/src/main/java/org/apache/iotdb/cluster/query/{ =>
aggregate}/ClusterAggregateExecutor.java (75%)
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/reader/ClusterReaderFactory.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/{PullTimeseriesSchemaHandler.java
=> PullMeasurementSchemaHandler.java} (91%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{exception/StartUpCheckFailureException.java
=> server/service/package-info.java} (77%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/ClientUtils.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/IOUtils.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/AsyncClientPoolTest.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
copy cluster/src/test/java/org/apache/iotdb/cluster/{common/TestClient.java =>
client/async/AsyncDataHeartbeatClientTest.java} (52%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncMetaClientTest.java
copy cluster/src/test/java/org/apache/iotdb/cluster/{common/TestClient.java =>
client/async/AsyncMetaHeartbeatClientTest.java} (53%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/rpcutils/TimeoutChangeableTFastFramedTransportTest.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
rename cluster/src/test/java/org/apache/iotdb/cluster/common/{TestClient.java
=> TestAsyncClient.java} (87%)
copy
cluster/src/{main/java/org/apache/iotdb/cluster/server/handlers/forwarder/GenericForwardHandler.java
=> test/java/org/apache/iotdb/cluster/common/TestSyncClient.java} (61%)
copy
cluster/src/test/java/org/apache/iotdb/cluster/common/{TestAsyncClientFactory.java
=> TestSyncClientFactory.java} (50%)
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/snapshot/FileSnapshotTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshotTest.java
rename
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/{PullTimeseriesSchemaHandlerTest.java
=> PullMeasurementSchemaHandlerTest.java} (91%)
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/forwarder/GenericForwardHandlerTest.java
create mode 100644 compile-tools/README.md
create mode 100644 compile-tools/boost/pom.xml
create mode 100644 compile-tools/boost/src/assembly/bundle.xml
create mode 100644 compile-tools/pom.xml
create mode 100644 compile-tools/thrift/pom.xml
create mode 100644 compile-tools/thrift/src/assembly/compiler.xml
create mode 100644 compile-tools/thrift/src/assembly/cpp.xml
create mode 100644 compile-tools/thrift/src/assembly/python.xml
create mode 100644 cross-tests/pom.xml
copy {cli/src/test/java/org/apache/iotdb/cli =>
cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/importCsv}/AbstractScript.java
(62%)
create mode 100644
cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/importCsv/ImportCsvTestIT.java
copy {server/src/test/java/org/apache/iotdb/db =>
cross-tests/src/test/java/org/apache/iotdb/cross/tests}/utils/EnvironmentUtils.java
(98%)
copy {server => cross-tests}/src/test/resources/iotdb-engine.properties (100%)
create mode 100644 docker/src/main/Dockerfile-0.10.1
create mode 100644 docs/UserGuide/Server/ServerFileList.md
create mode 100644 docs/UserGuide/System Tools/NodeTool.md
create mode 100644 docs/zh/SystemDesign/DataQuery/OrderByTimeQuery.md
create mode 100644 docs/zh/SystemDesign/StorageEngine/TsFileManagement.md
create mode 100644 docs/zh/UserGuide/Server/ServerFileList.md
create mode 100644 docs/zh/UserGuide/System Tools/NodeTool.md
create mode 100644
example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/flush/pool/VmMergeTaskPoolManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/tsfilemanagement/HotCompactionMergeTaskPoolManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/tsfilemanagement/TsFileManagement.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/SnapshotApplicationException.java
=>
server/src/main/java/org/apache/iotdb/db/engine/tsfilemanagement/TsFileManagementStrategy.java
(56%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/tsfilemanagement/level/LevelTsFileManagement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/tsfilemanagement/normal/NormalTsFileManagement.java
rename
server/src/main/java/org/apache/iotdb/db/engine/{flush/VmLogAnalyzer.java =>
tsfilemanagement/utils/HotCompactionLogAnalyzer.java} (67%)
rename server/src/main/java/org/apache/iotdb/db/engine/{flush/VmLogger.java =>
tsfilemanagement/utils/HotCompactionLogger.java} (66%)
rename
server/src/main/java/org/apache/iotdb/db/engine/{flush/VmMergeUtils.java =>
tsfilemanagement/utils/HotCompactionUtils.java} (54%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/SnapshotApplicationException.java
=>
server/src/main/java/org/apache/iotdb/db/exception/metadata/DataTypeMismatchException.java
(63%)
create mode 100755
server/src/main/java/org/apache/iotdb/db/metadata/PartialPath.java
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{ShowDevicesOperator.java
=> ShowStorageGroupOperator.java} (77%)
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{ShowDevicesPlan.java
=> ShowStorageGroupPlan.java} (76%)
copy
server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/CreateSnapshotPlan.java
=> query/reader/series/BaseManagedSeriesReader.java} (59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/DescSeriesReaderByTimestamp.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/universal/DescPriorityMergeReader.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/forwarder/GenericForwardHandler.java
=> server/src/main/java/org/apache/iotdb/db/rescon/CachedStringPool.java (60%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/conf/IoTDBDescriptorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorEnableVmTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBAsIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteTimeseriesIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/MetaUtilsTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/PartialPathTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/query/dataset/GroupByFillDataSetTest.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowDevicesPlan.java
=> service-rpc/src/main/java/org/apache/iotdb/rpc/RedirectException.java (67%)
create mode 100644
session/src/main/java/org/apache/iotdb/session/SessionConnection.java
copy session/src/test/java/org/apache/iotdb/session/{IoTDBSessionIT.java =>
IoTDBSessionComplexIT.java} (51%)
create mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionSimpleIT.java
create mode 100644 site/iotdb-doap.rdf
rename
cluster/src/main/java/org/apache/iotdb/cluster/exception/SnapshotApplicationException.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/BatchDataFactory.java
(61%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/DescBatchData.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/TimeColumn.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/MeasurementSchemaSerializeTest.java
