This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/AliasDebug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8790bf5364 fix bug in rpcDataSet
add 5496aaf3ca merge master
add 37ecc6e166 [IOTDB-3195] Added a configuration interface for the
consensus layer (#6081)
add 044d12ca63 Adapt wal memtabe snapshot to new cluster (#6138)
add 964f3218b5 fix: Fix `SessionDataSet` not close automatically (#6134)
add eff66ef3a3 [IOTDB-3327] Fix data region is created twice (#6136)
add e66320a169 [IOTDB-2988] Cache leader in session (#6083)
add 117f4d4060 fix: Fix `FileOutputStream` not close automatically (#6135)
add 93dae13b47 [IOTDB-3351] Add python Client schema template functions:
create template function and drop template function (#6092)
add 18ce8537b7 Added a new document “How to Contribute Code” with chinese
and english (#6141)
add 6fab5c3597 Fix some issues in MPP query prepared for representation
(#6130)
add 23efe9791a fix aggregation bug (#6146)
add c77c70b249 [IOTDB-3375] Fix NPE when inserting multi-rows by SQL
(#6148)
add 5527c66f67 Fix duplicated InputExpression in GroupByLevelNode (#6143)
add 464cbfe44d [IOTDB-3366] fix npe when no data when show latest
timeseries. (#6126)
add cb6b1d542f [IOTDB-2978][compaction error log ] Log level and "null"
error message handling (#6140)
add d3b4564e89 [IOTDB-3377] Enhance IT files code style checking (#6149)
add 38e730e4cf [IOTDB-3378] Fix iotdb reporter in metric framework and
update rpc address and port when use cluster mode. (#6150)
add 3c3d6bd4c3 [ISSUE-5878] Fix FileOutputStream not close automatically
add 45ca963708 [IOTDB-3379] Add deserialize method for DeviceMergeNode in
PlanNodeType (#6151)
add 18f185c261 change default settings (#6153)
add 1512a93845 [IOTDB-2880] Fix procedure worker threads config doesn't
take effect, and remove id lock. (#6129)
add 83ef38a2eb [IOTDB-2919] Delete regions at once besides schedule in
300s interval (#6157)
add 565b14dbb1 [IOTDB-3383] Refactor calcInputLocationList() in
LocalExecutionPlanner (#6152)
add 7f1b0a74de [IOTDB-3374] NPE when AggregationOperator receive the null
tsblock from the child (#6144)
add 071cde31ad [IOTDB-3261][IOTDB-3332][IOTDB-3372] Ensure the concurrency
security of Region alloction (#6156)
add c2afca12d5 [IOTDB-3317] RatisConsensus fallback for StateMachine
RuntimeException (#6101)
add 3b59ee22a0 [IOTDB-3395] Use thrift server to fix clientManagerTest
"bind address already used" issue (#6163)
add 7565b7987a [IOTDB-3393] Optimize log in auth module and fix the init
of parameter in resp. (#6161)
add a9ee691ecc [IOTDB-3363][IOTDB-3252] Update thrift fileds about
Authorization (#6165)
add 67cdb1737e Add an error message for setting TTL when the storagegroup
does not exist (#6164)
add 5cd0a21f94 [IOTDB-3402] Fix abuse of
ScheduledExecutorService.scheduleWithFixedDelay (#6172)
add d5b5aad3a2 Update ConfigNode startup process (#6168)
add a3f0606f3c [IOTDB-3403]JDBC storesUpperCaseIdentifiers interface
should return false (#6173)
add 85d27c3e20 [IOTDB-3259] fix sg already exists check. (#6162)
add feddaa31b9 [IOTDB-3041] Add code example of using jdbc/session
interface after updating syntax convention (#6145)
add 2fbfa556d0 Fix SchemaTree SearchDeviceSchema NPE (#6176)
add 7cb2d3f6cf [IOTDB-3168] Fix the path with * could be executed
successfully when inserting in version 14. (#6158)
add 61e9a0e4db [IOTDB-3406] Correct the exclude part of xml format plugin
(#6177)
add 8a8e727a20 [IOTDB-3370] Fix count nodes number (#6178)
add fbeddb9a77 Fix the issue that LastQuery lack MergeNode in some FI
(#6186)
add 6c10edff06 [IOTDB-3417] Group by month unit bug in MPP (#6185)
add 922ee7b162 [IOTDB-3361] Exception if measurement is not exist in where
clause in align by device
add dc08d01081 [IOTDB-3422] Fix metric tag in compaction task (#6191)
add 34c8b6f64a [IOTDB-3001] Read and write process for new standalone
iotdb (#6159)
add d190615638 [IOTDB-3407] Checkstyle: force to use safe thread schedule
interface (#6182)
add 4e9a5c2e91 [IOTDB-3359] Refactor the serialization interface for the
consensus layer to avoid hard-coding size ByteBuffers (#6187)
add 9855b3688e [IOTDB-3432] Add IT for raw query (#6188)
add 08006e2ae0 [IOTDB-3360] Fix precision loss bug due to float converted
to double (#6192)
add 0868dfa889 Add thread name for log (#6202)
add 4fde65e41e [IOTDB-3394] Add cache metrics (#6201)
add 5d48b1ecd8 [IOTDB-3425] [IOTDB-3415] add permission operate to
LocalConfigNode && Abstract an interface for Standalone Authority Check (#6196)
add b0af35219e [IOTDB-3144] refactor sync recovery (#5985)
add e04af828e7 [IOTDB-3385] Reduce the serialization size for the Datanode
consensus layer (#6209)
add 376632713c Fix insert OOM && Optimize new standalone auto create
schema (#6204)
add ce5c5746cc [IOTDB-3423] Update default config of confignode. (#6194)
add 27eeae4e01 Make New Cluter CI stable (#6212)
add ecf22abdbe [IOTDB-3399] Reconstruct PartitionTable (#6199)
add b1c33910c1 [ISSUE-5885] Synchronize this method to match the
synchronization on "setModFile" (#6197)
add a7c9179b59 fix the issue that NPE will be threw when query the series
with no data (#6211)
add 13912663db fix missing import (#6222)
add 5bf64166a4 [IOTDB-3435] Interface of migrate region for internal
service (#6206)
add 8d1cb93260 Fix standalone data partition bug (#6220)
add 4d6bc04a6a [IOTDB-3439] Move Setting up RPC Service to the last step
of starting DataNode (#6221)
add 5afedbe88f set the type of compaction execution thread pool to fix
size thread pool (#6224)
add 033ecd148f [IOTDB-3448] Migrate the logic of deleteRegion onto the
consensus module (#6216)
add b8c60541ff [IOTDB-3410] Support Snapshot Folder Hierarchy (#6210)
add 98cd64308c [IOTDB-3441] Python API: Session implements
executeStatement method (#6237)
add db703d33d7 [IOTDB-3444] Make period serivce be scheduled more flexible
(#6215)
add 71ef6f01b7 Optimize Plan Print (#6218)
add 28a2bab330 Try fix Concurrent Bug (#6214)
add 39298c609f [IOTDB-3459] Make sure SignalWALEntry be pushed to the
queue successfully in close() (#6241)
add 546f71dae8 [IOTDB-3458] Fix incorrect error handling strategy of some
periodic services (#6240)
add e80b219032 Make CI stable (#6243)
add 38f3332736 skip RegionReplicaSet in serialization of Fragment Instance
(#6217)
add 7b07fd9cba [IOTDB-3413] Fix the datatype consistency check of group by
level (#6208)
add 74b7835c8a [IOTDB-3035] Modify keywords doc: remove
encoding/compression/datatype (#6238)
add a3a0b23916 [IOTDB-3439] Move Setting up RPC Service to the last step
of starting DataNode 2 (#6232)
add abb242a54b fix the issue that AutoCreateTimeSeries throws NPE (#6249)
add ae5f78646c [IOTDB-3424] avoid run duplicated IotDB server/node (#6200)
add e3fe470a0f [IOTDB-3460] Python API: Add support for DBAPI (#6246)
add 3247f48cd8 [IOTDB-3447] add some schema template function in python
client (#6223)
add c05ac0ff0b [IOTDB-3099] Flush in new cluster (#6167)
add 51acf53822 Support LocalSinkHandle and LocalSourceHandle if two FI in
the same DataNode (#6193)
add 149ededde9 fix test (#6251)
add a5aed992fa Abandon set ttl, schema replication factor, data
replication factor, time partition interval to specific storage group (#6252)
add f6943d9dfe Support flush in new standalone IoTDB (#6254)
add 1e31ab278d [IOTDB-3445][IOTDB-3446] Fixed empty dirs are not deleted
after data … (#6242)
add 5f9d274930 Fix group by level node serialize bug (#6258)
add 0eba12bfcf Rename deleteDirectoryAndParent to
deleteDirectoryAndEmptyParent (#6262)
add 2242a4033e [IOTDB-3331] Fix create three level timeseries. (#6247)
add 9e749b8ee1 [IOTDB-3472] Fix OOM in New Standalone mode (#6263)
add c742abeff6 [IOTDB-3390] Serialize ConfigNode expansion (#6256)
add a9060a1d3e [IOTDB-3440] Add description of compatibility between
0.13.x and 0.12.x / master and 0.13.x (#6234)
add 3e0a1281fb [IOTDB-5879]Override hashCode of AuthorReq (#6257)
add 3c78969fea Revert "[IOTDB-3390] Serialize ConfigNode expansion
(#6256)" (#6266)
add 9da5ad5281 [IOTDB-3463] IT framework supports read and compare from
multi data nodes (#6271)
add a93728770f IOTDB-3481 Optimize Log Print (#6273)
add c4b22f26ac [IOTDB-3477] Send two phase message to ConfigNode when
starting DataNode (#6269)
add babb62a355 [IOTDB-3416] Abstract interface of ConfigTask Execution for
standalone IoTDB (#6260)
add d7cf590774 [IOTDB-3384] fix run length tsblock serde (#6270)
add 16314af65a Add data Deletion IT and Insert IT for aligned time series
(#6259)
add 1871e60f39 [IOTDB-3476] remove error log when update cache
add 47ad89c8da Fix the issue that query is not removed from
QueryExecutionMap (#6278)
add b3355c58b3 [IOTDB-3485] Insert with wrong type didn't return error
massage (#6277)
add d976dcf530 [IOTDB-3434] Implement the Built-in Functions of String
(#6250)
add 73b4253ab9 fix the bug that the judgement of hasResultSet is skipped
(#6284)
add 3d4061ad69 [IOTDB-3473][metrics] Prometheus reporter will lose data in
some conditions (#6265)
add 914cc9a354 [IOTDB-3401] Fix some operators in filter condition query
are currently not returning BOOLEAN (#6169)
add f29b0f7609 [IOTDB-3486] Support deleteStorageGroup for new standalone
IoTDB (#6280)
add 732fa7716e [IOTDB-3489] Add test name to log folder in cluster test
(#6279)
add f6eae1f687 Merge remote-tracking branch 'origin/master' into
lmh/AliasDebug
add 955cf13241 fix NPE in non-data query
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it.yml | 14 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
checkstyle.xml | 30 +-
client-py/README.md | 141 ++
client-py/SessionExample.py | 98 ++
client-py/iotdb/Session.py | 303 ++++
client-py/iotdb/dbapi/Connection.py | 91 ++
client-py/iotdb/dbapi/Cursor.py | 282 ++++
.../iotdb/dbapi/Exceptions.py | 63 +-
.../iotdb/dbapi/__init__.py | 24 +-
client-py/iotdb/{ => dbapi/tests}/__init__.py | 0
client-py/iotdb/dbapi/tests/test_connection.py | 57 +
client-py/iotdb/dbapi/tests/test_cursor.py | 123 ++
.../iotdb/template/InternalNode.py | 43 +-
client-py/iotdb/template/MeasurementNode.py | 56 +
client-py/iotdb/template/Template.py | 87 ++
.../iotdb/template/TemplateNode.py | 49 +-
.../iotdb/template/TemplateQueryType.py | 35 +-
client-py/iotdb/{ => template}/__init__.py | 0
client-py/iotdb/{ => tsfile}/__init__.py | 0
client-py/iotdb/{ => tsfile/common}/__init__.py | 0
.../iotdb/tsfile/common/constant/TsFileConstant.py | 32 +-
.../iotdb/{ => tsfile/common/constant}/__init__.py | 0
.../iotdb/tsfile/utils/Pair.py | 24 +-
client-py/iotdb/tsfile/utils/ReadWriteIOUtils.py | 77 +
client-py/iotdb/{ => tsfile/utils}/__init__.py | 0
client-py/tests/test_template.py | 194 +++
.../java/org/apache/iotdb/cluster/ClientMain.java | 12 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 7 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 5 +-
.../serializable/SyncLogDequeSerializer.java | 4 +-
.../cluster/server/PullSnapshotHintService.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 28 +-
.../resources/conf/iotdb-confignode.properties | 22 +-
.../confignode/client/SyncDataNodeClientPool.java | 46 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 8 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +
.../confignode/conf/ConfigNodeStartupCheck.java | 44 +-
.../consensus/request/ConfigRequest.java | 33 +-
.../consensus/request/auth/AuthorReq.java | 30 +-
.../request/read/CountStorageGroupReq.java | 10 +-
.../consensus/request/read/GetDataNodeInfoReq.java | 8 +-
.../request/read/GetDataPartitionReq.java | 43 +-
.../request/read/GetNodePathsPartitionReq.java | 7 +-
.../request/read/GetSchemaPartitionReq.java | 26 +-
.../request/write/ApplyConfigNodeReq.java | 8 +-
.../request/write/CreateDataPartitionReq.java | 87 +-
.../consensus/request/write/CreateFunctionReq.java | 13 +-
.../consensus/request/write/CreateRegionsReq.java | 26 +-
.../request/write/CreateSchemaPartitionReq.java | 57 +-
.../request/write/DeleteProcedureReq.java | 7 +-
.../consensus/request/write/DeleteRegionsReq.java | 42 +-
.../request/write/DeleteStorageGroupReq.java | 27 +-
.../consensus/request/write/DropFunctionReq.java | 7 +-
.../request/write/PreDeleteStorageGroupReq.java | 9 +-
.../request/write/RegisterDataNodeReq.java | 8 +-
.../request/write/SetDataReplicationFactorReq.java | 9 +-
.../write/SetSchemaReplicationFactorReq.java | 9 +-
.../request/write/SetStorageGroupReq.java | 7 +-
.../consensus/request/write/SetTTLReq.java | 9 +-
.../request/write/SetTimePartitionIntervalReq.java | 9 +-
.../request/write/UpdateProcedureReq.java | 7 +-
.../consensus/response/DataPartitionResp.java | 10 +
.../consensus/response/SchemaPartitionResp.java | 10 +
.../statemachine/PartitionRegionStateMachine.java | 4 +-
.../exception/StorageGroupNotExistsException.java | 11 +-
.../confignode/exception/TimeoutException.java | 11 +-
.../confignode/manager/ClusterSchemaManager.java | 43 +-
.../iotdb/confignode/manager/ConfigManager.java | 56 +-
.../iotdb/confignode/manager/ConsensusManager.java | 10 +-
.../apache/iotdb/confignode/manager/Manager.java | 8 +-
.../iotdb/confignode/manager/PartitionManager.java | 466 ++++---
.../confignode/manager/PermissionManager.java | 36 +-
.../iotdb/confignode/manager/ProcedureManager.java | 5 +-
.../iotdb/confignode/manager/load/LoadManager.java | 125 +-
.../manager/load/balancer/PartitionBalancer.java | 71 +
.../manager/load/balancer/RegionBalancer.java | 21 +-
.../partition/GreedyPartitionAllocator.java | 124 ++
.../balancer/partition/IPartitionAllocator.java | 53 +
.../CopySetRegionAllocator.java | 15 +-
.../{allocator => region}/IRegionAllocator.java | 6 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 29 +-
.../confignode/persistence/ClusterSchemaInfo.java | 131 +-
.../iotdb/confignode/persistence/NodeInfo.java | 4 +-
.../confignode/persistence/PartitionInfo.java | 645 ---------
.../executor/ConfigRequestExecutor.java | 16 +-
.../persistence/partition/PartitionInfo.java | 595 ++++++++
.../persistence/partition/RegionGroup.java | 97 ++
.../partition/StorageGroupPartitionTable.java | 331 +++++
.../procedure/CompletedProcedureRecycler.java | 3 -
.../confignode/procedure/InternalProcedure.java | 3 -
.../iotdb/confignode/procedure/Procedure.java | 47 +-
.../confignode/procedure/ProcedureExecutor.java | 12 -
.../procedure/StateMachineProcedure.java | 9 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 9 +-
.../impl/DeleteStorageGroupProcedure.java | 11 +-
.../confignode/procedure/store/ProcedureWAL.java | 12 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 51 +-
.../consensus/request/ConfigRequestSerDeTest.java | 274 ++--
.../hash/DeviceGroupHashExecutorManualTest.java | 2 +-
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 84 +-
.../confignode/procedure/entity/IncProcedure.java | 8 +-
.../procedure/entity/SleepProcedure.java | 8 +-
.../procedure/entity/StuckSTMProcedure.java | 9 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 24 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 11 +-
.../org/apache/iotdb/consensus/common/Peer.java | 7 +-
.../common/request/ByteBufferConsensusRequest.java | 4 +-
.../common/request/IConsensusRequest.java | 15 +-
.../common/request/IndexedConsensusRequest.java | 19 +-
.../iotdb/consensus/config/ConsensusConfig.java | 97 ++
.../iotdb/consensus/config/MultiLeaderConfig.java | 257 ++++
.../apache/iotdb/consensus/config/RatisConfig.java | 695 +++++++++
.../multileader/MultiLeaderConsensus.java | 17 +-
.../multileader/MultiLeaderServerImpl.java | 45 +-
.../multileader/client/DispatchLogHandler.java | 7 +-
.../client/MultiLeaderConsensusClientPool.java | 16 +-
.../conf/MultiLeaderConsensusConfig.java | 40 -
.../multileader/logdispatcher/LogDispatcher.java | 55 +-
.../multileader/logdispatcher/SyncStatus.java | 8 +-
.../multileader/service/MultiLeaderRPCService.java | 12 +-
.../service/MultiLeaderRPCServiceProcessor.java | 2 +-
.../multileader/wal/GetConsensusReqReaderPlan.java | 5 +-
.../ratis/ApplicationStateMachineProxy.java | 10 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 49 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 32 +-
.../iotdb/consensus/ratis/RequestMessage.java | 18 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 59 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 65 +
.../consensus/standalone/StandAloneConsensus.java | 7 +-
.../multileader/MultiLeaderConsensusTest.java | 25 +-
.../multileader/logdispatcher/SyncStatusTest.java | 79 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 7 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 11 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 7 +-
.../standalone/StandAloneConsensusTest.java | 15 +-
docs/Development/HowtoContributeCode.md | 160 +++
docs/Download/README.md | 20 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 8 +-
.../UserGuide/API/Programming-Python-Native-API.md | 140 ++
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 12 +-
docs/UserGuide/Reference/Keywords.md | 24 -
docs/UserGuide/Reference/Syntax-Conventions.md | 24 +-
docs/UserGuide/UDF-Library/String-Processing.md | 656 +++++++--
docs/zh/Development/HowtoContributeCode.md | 154 ++
docs/zh/Download/README.md | 21 +-
.../UserGuide/API/Programming-Java-Native-API.md | 8 +-
.../UserGuide/API/Programming-Python-Native-API.md | 139 ++
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 11 +-
docs/zh/UserGuide/Reference/Keywords.md | 24 -
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 29 +-
docs/zh/UserGuide/UDF-Library/String-Processing.md | 652 +++++++--
.../iotdb/SyntaxConventionRelatedExample.java | 161 +++
.../iotdb/SyntaxConventionRelatedExample.java | 145 ++
.../java/org/apache/iotdb/flink/IoTDBSink.java | 1 +
integration-test/README.md | 27 +-
integration-test/checkstyle.xml | 7 +-
integration-test/import-control.xml | 6 +-
integration-test/pom.xml | 2 +-
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 125 +-
.../org/apache/iotdb/it/env/ClusterEnvConfig.java | 40 +
.../org/apache/iotdb/it/env/ConfigFactory.java | 11 +-
.../java/org/apache/iotdb/it/env/ConfigNode.java | 20 +-
.../java/org/apache/iotdb/it/env/DataNode.java | 14 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +
.../org/apache/iotdb/it/env/IoTDBTestRunner.java | 44 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 4 +
.../apache/iotdb/itbase/constant/TestConstant.java | 143 ++
.../org/apache/iotdb/itbase/env/BaseConfig.java | 40 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 2 +
.../itbase/runtime/ClusterResultSetMetaData.java | 239 ++++
.../itbase/runtime/ClusterTestConnection.java | 333 +++++
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 1178 ++++++++++++++++
.../iotdb/itbase/runtime/ClusterTestStatement.java | 297 ++++
.../itbase/runtime/InconsistentDataException.java | 15 +-
.../iotdb/itbase/runtime/NodeConnection.java | 85 ++
.../itbase/runtime/ParallelRequestDelegate.java | 60 +
.../iotdb/itbase/runtime/RequestDelegate.java | 86 ++
.../iotdb/itbase/runtime/RequestThreadPool.java | 45 +-
.../itbase/runtime/SerialRequestDelegate.java | 39 +-
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 17 +-
.../iotdb/db/it/IoTDBExampleParallel1IT.java | 82 --
.../iotdb/db/it/IoTDBExampleParallel2IT.java | 99 --
.../iotdb/db/it/IoTDBExampleParallel3IT.java | 116 --
.../iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java | 1233 ++++++++++++++++
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 149 ++
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 61 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 61 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1475 ++++++++++++++++++++
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 120 ++
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 121 ++
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 78 ++
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 284 ++++
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 77 +
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 323 +++++
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 63 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 169 +--
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 81 ++
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 80 ++
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 80 ++
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 407 +++---
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 8 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 67 +
integration/checkstyle.xml | 189 +--
integration/import-control.xml | 6 +-
.../db/engine/trigger/example/Accumulator.java | 0
.../iotdb/db/engine/trigger/example/Counter.java | 0
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 6 +
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 14 +-
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 ------
.../db/integration/aligned/IoTDBLastQuery2IT.java | 65 -
.../aligned/IoTDBLastQueryWithDeletion2IT.java | 80 --
.../aligned/IoTDBLastQueryWithDeletionIT.java | 379 -----
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 68 -
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 381 -----
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 85 --
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 383 -----
.../IoTDBRawQueryWithoutValueFilter2IT.java | 66 -
.../IoTDBRawQueryWithoutValueFilter3IT.java | 63 -
.../aligned/IoTDBRawQueryWithoutValueFilterIT.java | 633 ---------
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 83 --
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 4 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 27 +-
.../apache/iotdb/metrics/utils/MetricsUtils.java | 16 +-
.../reporter/MicrometerPrometheusReporter.java | 1 +
.../micrometer/MicrometerMetricManagerTest.java | 12 +
metrics/pom.xml | 41 +
node-commons/pom.xml | 5 +
.../commons/client/ClientFactoryProperty.java | 2 +-
.../threadpool/ScheduledExecutorUtil.java | 188 +++
.../WrappedScheduledExecutorService.java | 2 +
.../WrappedSingleThreadScheduledExecutor.java | 2 +
.../iotdb/commons/partition/DataPartition.java | 207 +--
.../commons/partition/DataPartitionTable.java | 183 +++
.../iotdb/commons/partition/SchemaPartition.java | 171 +--
.../commons/partition/SchemaPartitionTable.java | 177 +++
.../commons/partition/SeriesPartitionTable.java | 192 +++
.../org/apache/iotdb/commons/path/PartialPath.java | 17 +
.../org/apache/iotdb/commons/path/PathType.java | 10 +-
.../BuiltinTimeSeriesGeneratingFunction.java | 21 +
.../commons/udf/builtin/String/UDTFConcat.java | 76 +
.../commons/udf/builtin/String/UDTFEndsWith.java | 53 +
.../commons/udf/builtin/String/UDTFLower.java | 50 +
.../commons/udf/builtin/String/UDTFStartsWith.java | 52 +
.../commons/udf/builtin/String/UDTFStrCompare.java | 57 +
.../commons/udf/builtin/String/UDTFStrLength.java | 50 +
.../commons/udf/builtin/String/UDTFStrLocate.java | 62 +
.../commons/udf/builtin/String/UDTFSubstr.java | 72 +
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 50 +
.../commons/udf/builtin/String/UDTFUpper.java | 50 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 37 +
.../commons/utils/BasicStructureSerDeUtil.java | 86 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 12 +
.../org/apache/iotdb/commons/utils/PathUtils.java | 4 +
.../commons/utils/ThriftCommonsSerDeUtils.java | 34 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 10 +
.../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 4 +-
.../commons/{ => client}/ClientManagerTest.java | 87 +-
.../client/mock/MockInternalRPCService.java | 45 +-
.../client/mock/MockInternalRPCServiceMBean.java | 5 +-
.../commons/partition/DataPartitionTableTest.java | 124 ++
.../iotdb/commons/partition/DataPartitionTest.java | 69 -
.../partition/SchemaPartitionTableTest.java | 101 ++
.../commons/partition/SchemaPartitionTest.java | 65 -
.../partition/SeriesPartitionTableTest.java | 111 ++
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 94 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 14 -
pom.xml | 20 +-
server/pom.xml | 4 +
.../resources/conf/iotdb-engine.properties | 41 +-
.../src/assembly/resources/sbin/start-datanode.sh | 63 +
.../assembly/resources/sbin/start-new-server.bat | 126 ++
.../sbin/{start-server.sh => start-new-server.sh} | 67 +-
server/src/assembly/resources/sbin/start-server.sh | 63 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityFetcher.java | 182 ---
.../apache/iotdb/db/auth/AuthorizerManager.java | 218 +--
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 364 +++++
.../IAuthorityFetcher.java} | 29 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 131 ++
.../apache/iotdb/db/client/ConfigNodeClient.java | 34 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 +
.../db/consensus/DataRegionConsensusImpl.java | 27 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 10 +-
.../consensus/statemachine/BaseStateMachine.java | 18 +-
.../statemachine/DataRegionStateMachine.java | 14 +-
.../statemachine/SchemaRegionStateMachine.java | 4 +-
.../statemachine/visitor/DataExecutionVisitor.java | 10 -
.../org/apache/iotdb/db/engine/StorageEngine.java | 46 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 182 +--
.../engine/compaction/CompactionTaskManager.java | 47 +-
.../utils/AlignedSeriesCompactionExecutor.java | 8 +-
.../utils/SingleSeriesCompactionExecutor.java | 10 +-
.../compaction/task/AbstractCompactionTask.java | 2 +-
.../writer/AbstractCompactionWriter.java | 4 +-
.../iotdb/db/engine/cq/ContinuousQueryService.java | 4 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 60 +-
.../db/engine/storagegroup/TsFileResource.java | 6 +-
.../dataregion/StorageGroupManager.java | 4 +-
.../runtime/SerializationRunTimeException.java | 10 +-
.../sql/MeasurementNotExistException.java | 12 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 505 ++++++-
.../localconfignode/LocalDataPartitionTable.java | 50 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 17 +
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 24 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 1 +
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 1 +
.../apache/iotdb/db/metadata/path/AlignedPath.java | 29 +
.../iotdb/db/metadata/path/MeasurementPath.java | 21 +
.../db/metadata/schemaregion/SchemaEngine.java | 7 +
.../metadata/schemaregion/SchemaRegionUtils.java | 5 +
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 6 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 14 -
.../TimeRangeIteratorFactory.java | 14 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 14 +-
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 9 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 6 +
.../iotdb/db/mpp/common/header/DatasetHeader.java | 4 +
.../db/mpp/common/schematree/PathPatternNode.java | 13 +
.../db/mpp/common/schematree/PathPatternTree.java | 6 +
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 7 +-
.../execution/datatransfer/DataBlockManager.java | 199 +--
.../execution/datatransfer/DataBlockService.java | 21 +-
.../execution/datatransfer/LocalSinkHandle.java | 8 +-
.../execution/datatransfer/LocalSourceHandle.java | 46 +-
.../execution/datatransfer/SharedTsBlockQueue.java | 6 +-
.../db/mpp/execution/datatransfer/SinkHandle.java | 89 +-
.../mpp/execution/datatransfer/SourceHandle.java | 349 ++---
.../fragment/FragmentInstanceExecution.java | 35 +-
.../fragment/FragmentInstanceManager.java | 82 +-
.../fragment/FragmentInstanceStateMachine.java | 7 +-
.../operator/process/AggregationOperator.java | 24 +-
.../operator/process/LastQueryMergeOperator.java | 7 +-
.../schema/NodeManageMemoryMergeOperator.java | 7 +-
.../operator/schema/NodePathsConvertOperator.java | 5 +-
.../operator/schema/NodePathsCountOperator.java | 38 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 74 +-
.../source/SeriesAggregationScanOperator.java | 6 +-
.../execution/schedule/AbstractDriverThread.java | 13 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 119 +-
.../mpp/execution/schedule/DriverTaskThread.java | 6 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 60 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 67 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 47 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 70 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 9 +-
.../mpp/plan/analyze/GroupByLevelController.java | 61 +-
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 6 +-
.../plan/analyze/StandalonePartitionFetcher.java | 151 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 237 +++-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 10 +
.../DataNodeEndPoints.java} | 30 +-
.../db/mpp/plan/execution/IQueryExecution.java | 2 +
.../db/mpp/plan/execution/QueryExecution.java | 141 +-
.../execution/config/AuthorizerConfigTask.java | 87 --
.../mpp/plan/execution/config/AuthorizerTask.java | 48 +
.../mpp/plan/execution/config/ConfigExecution.java | 32 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 +-
.../execution/config/CountStorageGroupTask.java | 51 +-
.../plan/execution/config/CreateFunctionTask.java | 74 +-
.../execution/config/DeleteStorageGroupTask.java | 69 +-
.../plan/execution/config/DropFunctionTask.java | 65 +-
.../db/mpp/plan/execution/config/FlushTask.java | 66 +
.../db/mpp/plan/execution/config/IConfigTask.java | 7 +-
.../plan/execution/config/SetStorageGroupTask.java | 66 +-
.../db/mpp/plan/execution/config/SetTTLTask.java | 58 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 65 +-
.../plan/execution/config/ShowFunctionsTask.java | 7 +-
.../execution/config/ShowStorageGroupTask.java | 64 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 85 +-
.../config/executor/ClusterConfigTaskExecutor.java | 328 +++++
.../config/executor/IConfigTaskExecutor.java | 61 +
.../executor/StandsloneConfigTaskExecutor.java | 259 ++++
.../plan/execution/memory/MemorySourceHandle.java | 4 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 14 +
.../plan/expression/binary/BinaryExpression.java | 7 +
.../mpp/plan/expression/leaf/ConstantOperand.java | 7 +
.../plan/expression/leaf/TimeSeriesOperand.java | 6 +
.../mpp/plan/expression/leaf/TimestampOperand.java | 6 +
.../plan/expression/multi/FunctionExpression.java | 13 +-
.../db/mpp/plan/expression/unary/InExpression.java | 18 +-
.../mpp/plan/expression/unary/LikeExpression.java | 16 +-
.../plan/expression/unary/RegularExpression.java | 16 +-
.../mpp/plan/expression/unary/UnaryExpression.java | 6 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 47 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 112 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 2 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 1 +
.../distribution/DistributionPlanContext.java | 6 +
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 19 +-
.../plan/planner/distribution/SourceRewriter.java | 41 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 56 +-
.../db/mpp/plan/planner/plan/PlanFragment.java | 16 +-
.../plan/planner/plan/node/DeleteRegionNode.java | 109 --
.../plan/planner/plan/node/PlanGraphPrinter.java | 63 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 44 +-
.../db/mpp/plan/planner/plan/node/PlanNodeId.java | 8 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 23 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 6 +-
.../node/metedata/read/CountSchemaMergeNode.java | 7 +
.../plan/node/metedata/read/DevicesCountNode.java | 9 +
.../node/metedata/read/DevicesSchemaScanNode.java | 12 +
.../metedata/read/LevelTimeSeriesCountNode.java | 10 +
.../read/NodeManagementMemoryMergeNode.java | 12 +
.../node/metedata/read/NodePathsConvertNode.java | 7 +
.../node/metedata/read/NodePathsCountNode.java | 7 +
.../metedata/read/NodePathsSchemaScanNode.java | 9 +
.../node/metedata/read/SchemaFetchMergeNode.java | 7 +
.../node/metedata/read/SchemaFetchScanNode.java | 9 +
.../node/metedata/read/SchemaQueryMergeNode.java | 7 +
.../metedata/read/SchemaQueryOrderByHeatNode.java | 40 +-
.../node/metedata/read/TimeSeriesCountNode.java | 9 +
.../metedata/read/TimeSeriesSchemaScanNode.java | 15 +
.../node/metedata/write/AlterTimeSeriesNode.java | 51 +-
.../write/CreateAlignedTimeSeriesNode.java | 67 +
.../metedata/write/CreateMultiTimeSeriesNode.java | 16 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 52 +
.../node/metedata/write/DeleteTimeSeriesNode.java | 11 +
.../metedata/write/InvalidateSchemaCacheNode.java | 16 +
.../plan/node/metedata/write/MeasurementGroup.java | 63 +-
.../planner/plan/node/process/AggregationNode.java | 20 +-
.../planner/plan/node/process/DeviceMergeNode.java | 13 +
.../planner/plan/node/process/DeviceViewNode.java | 25 +
.../planner/plan/node/process/ExchangeNode.java | 15 +
.../plan/planner/plan/node/process/FillNode.java | 8 +
.../plan/planner/plan/node/process/FilterNode.java | 14 +
.../planner/plan/node/process/FilterNullNode.java | 8 +
.../plan/node/process/GroupByLevelNode.java | 18 +
.../plan/node/process/LastQueryMergeNode.java | 16 +-
.../plan/planner/plan/node/process/LimitNode.java | 8 +
.../plan/planner/plan/node/process/OffsetNode.java | 8 +
.../planner/plan/node/process/ProjectNode.java | 11 +
.../node/process/SlidingWindowAggregationNode.java | 18 +
.../plan/planner/plan/node/process/SortNode.java | 8 +
.../planner/plan/node/process/TimeJoinNode.java | 8 +
.../planner/plan/node/process/TransformNode.java | 13 +
.../planner/plan/node/sink/FragmentSinkNode.java | 11 +
.../plan/node/source/AlignedLastQueryScanNode.java | 12 +-
.../source/AlignedSeriesAggregationScanNode.java | 35 +
.../plan/node/source/AlignedSeriesScanNode.java | 27 +-
.../plan/node/source/LastQueryScanNode.java | 8 +
.../node/source/SeriesAggregationScanNode.java | 26 +
.../planner/plan/node/source/SeriesScanNode.java | 23 +
.../planner/plan/node/write/DeleteDataNode.java | 13 +
.../plan/node/write/InsertMultiTabletsNode.java | 21 +-
.../plan/planner/plan/node/write/InsertNode.java | 20 +-
.../planner/plan/node/write/InsertRowNode.java | 94 +-
.../planner/plan/node/write/InsertRowsNode.java | 23 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 53 +-
.../planner/plan/node/write/InsertTabletNode.java | 165 ++-
.../plan/parameter/AggregationDescriptor.java | 27 +-
.../planner/plan/parameter/AggregationStep.java | 7 +
.../planner/plan/parameter/FillDescriptor.java | 9 +
.../plan/parameter/FilterNullParameter.java | 10 +
.../plan/parameter/GroupByLevelDescriptor.java | 8 +
.../plan/parameter/GroupByTimeParameter.java | 25 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 12 +-
.../scheduler/FixedRateFragInsStateTracker.java | 9 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 63 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 89 --
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 90 +-
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../plan/statement/crud/InsertBaseStatement.java | 4 +
.../crud/InsertMultiTabletsStatement.java | 18 +
.../plan/statement/crud/InsertRowStatement.java | 12 +
.../crud/InsertRowsOfOneDeviceStatement.java | 9 +
.../plan/statement/crud/InsertRowsStatement.java | 17 +
.../plan/statement/crud/InsertTabletStatement.java | 14 +
.../mpp/plan/statement/literal/BooleanLiteral.java | 8 +
.../mpp/plan/statement/literal/DoubleLiteral.java | 8 +
.../db/mpp/plan/statement/literal/Literal.java | 4 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 8 +
.../db/mpp/plan/statement/literal/NullLiteral.java | 7 +
.../mpp/plan/statement/literal/StringLiteral.java | 8 +
.../db/mpp/plan/statement/sys/FlushStatement.java | 92 ++
.../dag/transformer/unary/InTransformer.java | 14 +-
.../dag/transformer/unary/RegularTransformer.java | 4 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 9 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 13 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 26 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 14 +-
.../db/query/control/SessionTimeoutManager.java | 4 +-
.../query/reader/chunk/MemAlignedPageReader.java | 52 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 127 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 37 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 +-
.../iotdb/db/service/{IoTDB.java => NewIoTDB.java} | 87 +-
.../org/apache/iotdb/db/service/NewIoTDBMBean.java | 9 +-
.../db/service/basic/QueryFrequencyRecorder.java | 4 +-
.../iotdb/db/service/metrics/enums/Metric.java | 1 +
.../metrics/recorder/CacheMetricsRecorder.java | 65 +
.../recorder/CompactionMetricsRecorder.java} | 20 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 102 +-
.../service/thrift/impl/InternalServiceImpl.java | 242 ++--
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 4 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 12 +
.../iotdb/db/sync/sender/service/MsgManager.java | 2 +-
.../db/sync/sender/service/SenderService.java | 5 +
.../db/sync/sender/service/TransportHandler.java | 21 +-
.../db/sync/transport/client/ClientWrapper.java | 125 ++
.../db/sync/transport/client/ITransportClient.java | 2 +
.../db/sync/transport/client/TransportClient.java | 258 ++--
.../transport/server/TransportServiceImpl.java | 29 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 22 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 12 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 18 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 38 +-
.../db/mpp/aggregation/TimeRangeIteratorTest.java | 22 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 13 +
.../db/mpp/execution/ConfigExecutionTest.java | 7 +-
.../datatransfer/LocalSourceHandleTest.java | 2 +-
.../operator/AggregationOperatorTest.java | 3 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 149 ++
.../plan/analyze/AggregationDescriptorTest.java | 41 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 15 +-
.../distribution/AggregationDistributionTest.java | 2 +-
.../distribution/NoDataRegionPlanningTest.java | 84 ++
.../node/process/GroupByLevelNodeSerdeTest.java | 12 +-
.../plan/node/write/DeleteRegionNodeSerdeTest.java | 60 -
.../plan/scheduler/StandaloneSchedulerTest.java | 518 +++++++
.../iotdb/db/service/InternalServiceImplTest.java | 95 +-
.../datanode1conf/iotdb-engine.properties | 2 +-
.../datanode2conf/iotdb-engine.properties | 2 +-
.../datanode3conf/iotdb-engine.properties | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 13 +-
.../java/org/apache/iotdb/session/Session.java | 43 +-
.../apache/iotdb/session/SessionConnection.java | 8 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 150 +-
site/src/main/.vuepress/config.js | 2 +
thrift-commons/src/main/thrift/common.thrift | 6 +
.../src/main/thrift/confignode.thrift | 31 +-
.../src/main/thrift/mutlileader.thrift | 8 +-
thrift/src/main/thrift/mpp.thrift | 56 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 15 +-
.../block/column/BinaryArrayColumnEncoder.java | 5 +-
.../block/column/ByteArrayColumnEncoder.java | 5 +-
.../read/common/block/column/ColumnEncoder.java | 9 +-
.../common/block/column/ColumnEncoderFactory.java | 3 +-
.../read/common/block/column/ColumnEncoding.java | 6 +-
.../block/column/Int32ArrayColumnEncoder.java | 8 +-
.../block/column/Int64ArrayColumnEncoder.java | 21 +-
.../block/column/RunLengthColumnEncoder.java | 54 +
.../block/column/RunLengthEncodedColumn.java | 2 +-
.../read/common/block/column/TsBlockSerde.java | 19 +-
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 43 +-
.../java/org/apache/iotdb/tsfile/utils/Pair.java | 8 +
.../common/block/BinaryArrayColumnEncoderTest.java | 8 +-
.../common/block/ByteArrayColumnEncoderTest.java | 9 +-
.../common/block/Int32ArrayColumnEncoderTest.java | 15 +-
.../common/block/Int64ArrayColumnEncoderTest.java | 17 +-
...erTest.java => RunLengthColumnEncoderTest.java} | 75 +-
560 files changed, 25053 insertions(+), 10417 deletions(-)
create mode 100644 client-py/iotdb/dbapi/Connection.py
create mode 100644 client-py/iotdb/dbapi/Cursor.py
copy server/src/test/resources/datanode1conf/iotdb-engine.properties =>
client-py/iotdb/dbapi/Exceptions.py (60%)
copy server/src/test/resources/datanode2conf/iotdb-engine.properties =>
client-py/iotdb/dbapi/__init__.py (60%)
copy client-py/iotdb/{ => dbapi/tests}/__init__.py (100%)
create mode 100644 client-py/iotdb/dbapi/tests/test_connection.py
create mode 100644 client-py/iotdb/dbapi/tests/test_cursor.py
copy server/src/test/resources/datanode2conf/iotdb-engine.properties =>
client-py/iotdb/template/InternalNode.py (55%)
create mode 100644 client-py/iotdb/template/MeasurementNode.py
create mode 100644 client-py/iotdb/template/Template.py
copy server/src/test/resources/datanode3conf/iotdb-engine.properties =>
client-py/iotdb/template/TemplateNode.py (60%)
copy server/src/test/resources/datanode2conf/iotdb-engine.properties =>
client-py/iotdb/template/TemplateQueryType.py (60%)
copy client-py/iotdb/{ => template}/__init__.py (100%)
copy client-py/iotdb/{ => tsfile}/__init__.py (100%)
copy client-py/iotdb/{ => tsfile/common}/__init__.py (100%)
copy server/src/test/resources/datanode2conf/iotdb-engine.properties =>
client-py/iotdb/tsfile/common/constant/TsFileConstant.py (60%)
copy client-py/iotdb/{ => tsfile/common/constant}/__init__.py (100%)
copy server/src/test/resources/datanode2conf/iotdb-engine.properties =>
client-py/iotdb/tsfile/utils/Pair.py (60%)
create mode 100644 client-py/iotdb/tsfile/utils/ReadWriteIOUtils.py
copy client-py/iotdb/{ => tsfile/utils}/__init__.py (100%)
create mode 100644 client-py/tests/test_template.py
copy
consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/exception/StorageGroupNotExistsException.java
(75%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/exception/TimeoutException.java
(82%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/GreedyPartitionAllocator.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/IPartitionAllocator.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/{allocator
=> region}/CopySetRegionAllocator.java (94%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/{allocator
=> region}/IRegionAllocator.java (87%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/PartitionInfo.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionGroup.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/StorageGroupPartitionTable.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/config/ConsensusConfig.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/config/RatisConfig.java
delete mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/conf/MultiLeaderConsensusConfig.java
create mode 100644 docs/Development/HowtoContributeCode.md
create mode 100644 docs/zh/Development/HowtoContributeCode.md
create mode 100644
example/jdbc/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java
create mode 100644
example/session/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/IoTDBTestRunner.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/constant/TestConstant.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterResultSetMetaData.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestStatement.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/multileader/wal/GetConsensusReqReaderPlan.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/InconsistentDataException.java
(71%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/NodeConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ParallelRequestDelegate.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestDelegate.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/NullLiteral.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestThreadPool.java
(51%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/partition/DataPartitionRule.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/SerialRequestDelegate.java
(51%)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleParallel1IT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleParallel2IT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleParallel3IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/AlignedWriteUtil.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletion2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
rename
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryIT.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java
(59%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
(52%)
rename integration/src/{test =>
main}/java/org/apache/iotdb/db/engine/trigger/example/Accumulator.java (100%)
rename integration/src/{test =>
main}/java/org/apache/iotdb/db/engine/trigger/example/Counter.java (100%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBInsertAlignedValuesIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQuery2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCache2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter3IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/ScheduledExecutorUtil.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionTable.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartitionTable.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/partition/SeriesPartitionTable.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFConcat.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFEndsWith.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFLower.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStartsWith.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrCompare.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLength.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLocate.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFSubstr.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFTrim.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFUpper.java
rename node-commons/src/test/java/org/apache/iotdb/commons/{ =>
client}/ClientManagerTest.java (92%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCService.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java
(54%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/SeriesPartitionSlotBalancer.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCServiceMBean.java
(88%)
create mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/partition/DataPartitionTableTest.java
delete mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/partition/DataPartitionTest.java
create mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/partition/SchemaPartitionTableTest.java
delete mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/partition/SchemaPartitionTest.java
create mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/partition/SeriesPartitionTableTest.java
create mode 100644 server/src/assembly/resources/sbin/start-new-server.bat
copy server/src/assembly/resources/sbin/{start-server.sh =>
start-new-server.sh} (56%)
mode change 100755 => 100644
delete mode 100644
server/src/main/java/org/apache/iotdb/db/auth/AuthorityFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/execution/IQueryExecution.java
=> auth/IAuthorityFetcher.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java
=>
server/src/main/java/org/apache/iotdb/db/exception/runtime/SerializationRunTimeException.java
(77%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java
=>
server/src/main/java/org/apache/iotdb/db/exception/sql/MeasurementNotExistException.java
(75%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/{planner/distribution/DistributionPlanContext.java
=> constant/DataNodeEndPoints.java} (52%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/AuthorizerConfigTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/AuthorizerTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/FlushTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/IConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandsloneConfigTaskExecutor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/DeleteRegionNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/FlushStatement.java
copy server/src/main/java/org/apache/iotdb/db/service/{IoTDB.java =>
NewIoTDB.java} (79%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java
=> server/src/main/java/org/apache/iotdb/db/service/NewIoTDBMBean.java (80%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CacheMetricsRecorder.java
rename
server/src/main/java/org/apache/iotdb/db/{engine/compaction/CompactionMetricsManager.java
=> service/metrics/recorder/CompactionMetricsRecorder.java} (92%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/transport/client/ClientWrapper.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/StandaloneCoordinatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/NoDataRegionPlanningTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/DeleteRegionNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneSchedulerTest.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/RunLengthColumnEncoder.java
copy
tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/{BinaryArrayColumnEncoderTest.java
=> RunLengthColumnEncoderTest.java} (53%)
