This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch expr_catch_up
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a5bf5ed66f Merge branch 'master' into expr_catch_up
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)
new 44a1ef6fb1 Merge branch 'master' into expr_catch_up
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:
.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 | 114 +-
client-py/SessionExample.py | 55 +-
client-py/iotdb/Session.py | 254 +++-
client-py/iotdb/dbapi/Connection.py | 91 ++
client-py/iotdb/dbapi/Cursor.py | 282 ++++
.../{tsfile/utils/Pair.py => dbapi/Exceptions.py} | 47 +-
.../{tsfile/utils/Pair.py => dbapi/__init__.py} | 12 +-
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 ++
client-py/iotdb/template/Template.py | 5 +-
client-py/iotdb/template/TemplateNode.py | 3 +-
.../Pair.py => template/TemplateQueryType.py} | 25 +-
client-py/iotdb/{ => tsfile}/__init__.py | 0
client-py/iotdb/{ => tsfile/common}/__init__.py | 0
client-py/iotdb/tsfile/utils/Pair.py | 4 +-
client-py/tests/test_template.py | 130 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 7 +-
.../{PhysicalPlanLog.java => RequestLog.java} | 0
.../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 | 8 +-
.../confignode/client/SyncDataNodeClientPool.java | 46 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 8 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 40 +-
.../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 | 2 -
.../apache/iotdb/confignode/manager/Manager.java | 8 +-
.../iotdb/confignode/manager/PartitionManager.java | 464 +++---
.../confignode/manager/PermissionManager.java | 36 +-
.../iotdb/confignode/manager/ProcedureManager.java | 3 +-
.../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 +-
.../confignode/persistence/PartitionInfo.java | 645 ---------
.../executor/ConfigRequestExecutor.java | 16 +-
.../persistence/partition/PartitionInfo.java | 595 ++++++++
.../persistence/partition/RegionGroup.java | 97 ++
.../partition/StorageGroupPartitionTable.java | 331 +++++
.../confignode/procedure/InternalProcedure.java | 3 -
.../iotdb/confignode/procedure/Procedure.java | 45 +-
.../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 +-
.../org/apache/iotdb/consensus/common/Peer.java | 7 +-
.../common/request/ByteBufferConsensusRequest.java | 4 +-
.../common/request/IConsensusRequest.java | 15 +-
.../common/request/IndexedConsensusRequest.java | 19 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 2 +-
.../multileader/MultiLeaderServerImpl.java | 30 +-
.../multileader/logdispatcher/LogDispatcher.java | 16 +-
.../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 | 2 +-
.../iotdb/consensus/ratis/RequestMessage.java | 18 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 59 +-
.../multileader/MultiLeaderConsensusTest.java | 18 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 11 +-
.../standalone/StandAloneConsensusTest.java | 8 +-
docs/Download/README.md | 20 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 8 +-
.../UserGuide/API/Programming-Python-Native-API.md | 113 +-
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/Download/README.md | 21 +-
.../UserGuide/API/Programming-Java-Native-API.md | 8 +-
.../UserGuide/API/Programming-Python-Native-API.md | 112 +-
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/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 | 12 +-
.../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 | 3 +
.../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 +
.../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 +-
.../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 | 92 ++
.../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 | 21 +-
server/pom.xml | 4 +
.../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 +++++
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 22 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 131 ++
.../apache/iotdb/db/client/ConfigNodeClient.java | 34 +
.../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 | 166 +--
.../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 | 12 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 14 +-
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 9 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 6 +
.../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 +-
.../schema/NodeManageMemoryMergeOperator.java | 7 +-
.../operator/schema/NodePathsConvertOperator.java | 5 +-
.../operator/schema/NodePathsCountOperator.java | 38 +-
.../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 | 64 +-
.../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 | 57 +-
.../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 | 99 +-
.../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 | 11 +
.../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 | 60 +-
.../distribution/DistributionPlanContext.java | 6 +
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 19 +-
.../plan/planner/distribution/SourceRewriter.java | 5 +-
.../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 | 20 +-
.../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 | 11 +-
.../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 | 7 +
.../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 | 21 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 24 +-
.../planner/plan/node/write/InsertTabletNode.java | 165 ++-
.../plan/parameter/AggregationDescriptor.java | 14 +
.../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 +
.../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 | 99 +-
.../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 +-
.../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 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 149 ++
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 15 +-
.../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 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 16 +-
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 +-
.../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 +-
495 files changed, 22436 insertions(+), 9472 deletions(-)
create mode 100644 client-py/iotdb/dbapi/Connection.py
create mode 100644 client-py/iotdb/dbapi/Cursor.py
copy client-py/iotdb/{tsfile/utils/Pair.py => dbapi/Exceptions.py} (61%)
copy client-py/iotdb/{tsfile/utils/Pair.py => dbapi/__init__.py} (77%)
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 client-py/iotdb/{tsfile/utils/Pair.py => template/TemplateQueryType.py}
(62%)
copy client-py/iotdb/{ => tsfile}/__init__.py (100%)
copy client-py/iotdb/{ => tsfile/common}/__init__.py (100%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/{PhysicalPlanLog.java
=> RequestLog.java} (100%)
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
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/common/request/IConsensusRequest.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%)
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%)
create mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java
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 integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java
=> server/src/main/java/org/apache/iotdb/db/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%)
