This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch lwh/1.3-cp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from aad83fbedd9 Support debug for query (#17178)
add f06fbeea01f [To dev/1.3] Fix forced Exchange branch isolation in
distributed align-by-device planning
add 29ae788e59c [To dev/1.3] Make IoTDBLastQueryAliasITs query ordered
add 3d535db48a4 Fix fast last empty cache handling in 1.3 (#17743)
add ac090721589 Pipe: Implemented batch logic for air-gap sink (#17667)
(#17727)
add afcc36f0c76 Upgrade Netty for CVE fixes (#17760)
add 7721cab0392 Pipe: Do not listen to tsFiles when no sources need
(#17669) (#17761)
add b061ffd003a [To dev/1.3] Add historical transfer summary logs (#17763)
add 7cc3851892a Pipe: Stablized the tree model IoTDBPipeClusterIT (#17729)
(#17762)
add c7a8f6e1011 Fixed TTL problems (#17735) (#17758)
add 17e73ee7126 [To dev/1.3] [Pipe] Optimize memory usage (#17775)
add 93275a6e975 fix(client-cpp): ignore 0.0.0.0 in write redirection
add 0f253d8e65b Degraded the UT logs (#17782)
add ca52520f482 [To dev/1.3] Fix pipe drop event discard with
restart-aware committer keys (#17748) (#17778)
add 5d4277a49a1 Pipe: Removed the useless ban on async file transfer for
non realtime-first pipes (#17785)
add ddeb23b53ce [To dev/1.3] Pipe Log: Reduce repeatable logs (#17700)
(#17793)
add 0507f0b1516 Load: Stablized the IoTDBLoadTsFileWithModIT (#17787)
add e94f0e8ed11 [dev/1.3] Pipe: Harden legacy pipe file transfer
validation and access checks (#17791)
add 3c959c399e2 Excluded system & audit from COUNT TIMESERIES and included
views (#17703) (#17792)
add 13faa155d32 Added flags to mark whether a device has device
descendants to optimize query like select xx from xxx.** (#17672) (#17802)
add 7a258736ea5 Pipe: Fixed the bug that drop pipe may stuck when
disruptor is interrupted or ring buffer full (#17673) (#17818)
add 24be79aba9c Fix CQ recovery gap and stale callback contamination
(#17734) (#17820)
add b0033afcaf5 Optimized the overall performance of IoTDB & Fixed the NPE
in LimitOperatorTest (#17664) (#17819)
add 5e1587f67e3 Revert "Fix CQ recovery gap and stale callback
contamination (#17734) (#17820)" (#17826)
add cb8fd4ceb00 Reapply "Fix CQ recovery gap and stale callback
contamination (#17734) (#17820)" (#17826) (#17829)
add 7d0b74b9437 [to dev/1.3] C++ client: backport thread-safe SessionPool
(#17800) (#17817)
add 44cb7c2f6fb Fix flaky space quota IT (#17812) (#17824)
add 23d1367f6d1 Pipe IT: Stabilize tree model leader stop test (#17825)
add cc6ec312118 Ratis CI: Fixed the ratis CI port clash & Optimized the
logs to avoid printing JVM crash (#17675) (#17830)
add 30b4d49fa6b [to dev/1.3] Pipe: account page decode memory in scan
parser (#17807) (#17833)
add 4052320c6c0 Fixed UDF jar metadata handling in `UDFInfo` when multiple
UDFs share the same jar (#17732) (#17835)
add 251125ae7f4 Fix pipe tsfile receiver database handling (#17815)
(#17836)
add 0288aab9d2b Optimize InsertTabletStatement tablet conversion (#17805)
(#17842)
add b8852699a49 Fix operator tests for transient null TsBlocks (#17838)
(#17847)
add 1cb4bf26a75 Fix flaky stamped lock test (#17832) (#17839)
add 9d0d750da74 Fix pipe permission retry and table parser progress
(#17844) (#17848)
add 3af79aa3b47 [to dev/1.3] Fix count and show timeseries follow-up
(#17837)
add 78a4790efb1 Fix PBTree schema cache release after pre-delete (#17834)
(#17852)
add 6348c2db2a0 [to dev/1.3] Pipe: backport auto split fixes (#17866)
add abcc51ca992 Fix pipe receiver type conversion load path (#17849)
(#17873)
add 6a59cf43a41 Optimize local load TsFile piece dispatch (#17851) (#17876)
add d39d22fa63a Support sink config key for pipe request slicing (#17858)
(#17883)
add 7cffde507d6 Optimize load partition routing (#17863) (#17884)
add de0a48fc6e6 Optimize pipe event batching and listener stop (#17864)
(#17885)
add d906c6a496b Fix Windows path segment validation (#17868) (#17888)
add 56a0fcce1c9 [to dev/1.3] Fix tree model WAL serialized sizes (#17886)
add 85b7038f4d7 [To dev/1.3] refactor client-cpp (#17803)
add 290842e77df [To dev/1.3] Fix driver scheduler ready queue reservation
leak (#17920)
add cef9184c294 Pipe: avoid blocking startup on hardlink dir cleanup
(#17932) (#17943)
add 458b5479f96 Fix aggregate write-back output database metadata (#17938)
(#17965)
add ddb9c7cf0a9 [To dev/1.3] Fix pipe schema snapshot database creation
(#17944)
add efdd472b7d1 Fix pipe runtime meta push blocking user operations
(#17909) (#17953)
add 9442a1cbb7e Fix tree model load type mismatch conversion (#17949)
(#17957)
add ef53e32ac82 Fix active load cleanup lifecycle (#17947) (#17963)
add 352da912e21 Throttle async pipe sink on receiver reject (#17928)
(#17966)
add 44ed8578073 [To dev/1.3] Pipe: improve progress coverage checks
(#17967)
add fc581dcbd6a Fix pipe lifecycle restart order in IT (#17962) (#17968)
add 4e06a94d06b Pipe: serialize sink transfers by region (#17946) (#17970)
add 91ee3016d18 Fix duplicate scheduling in procedure execution (#17902)
(#17969)
add d1df10405e0 Stop running AINode (AIClusterIT) integration tests
(#17982)
add aaa5729075a Fix PBTree flush for negative child address (#17955)
(#17978)
add bfb538a15c9 Fix tree schema snapshot database creation on master
(#17964) (#17979)
add 96d55ed221b Improve IT cluster readiness diagnostics (#17903) (#17989)
add eb41f567f54 [to dev/1.3] Fix compaction writer size checkpointing
add f0dc49ec0be Fix pipe text date conversion (#17984) (#17997)
add 9e383898899 Fix SingleDeviceViewOperatorTest row assertion (#17995)
(#18003)
add 073625ad9c1 Fix short reads in fixed-length deserialization (#17870)
(#18007)
add 818b6fc5581 [To dev/1.3] Optimize aggregation metric recording
add 2717029cbb7 Pipe: isolate async sink client resources by endpoint
(#18015) (#18028)
add a7c7e54cb7f [To dev/1.3] Load: Optimize fallback logic for corrupted
TsFile (#18004)
add 896fb6ebdca Fix flaky multilevel priority queue test (#18013) (#18027)
add 617c0a82e12 Support unified pipe pattern inclusion keys (#18017)
add 7fdccc916a4 Limit concurrent load tsfile type conversions (#18014)
(#18030)
add 476f67f8a83 Fix empty deleteTimeseries requests (#18012) (#18037)
add ceaae51b35a Pipe: Fix tablet event alignment and row count handling
(#18034)
add 94bf8a2754f Fix internal procedure deduplication (#18036) (#18043)
add 65d2582cb05 Pipe: merge batched aligned chunks in scan parser (#18010)
(#18041)
add 9ad7c19788c Pipe: Retry history LoadTsFile while waiting for schema
(#18031) (#18042)
add a35a115e409 Fix encrypted password pull consumer commit mode (#18044)
(#18064)
add 59243c5cd29 Pipe: Implemented schema batch for meta transfer (#17665)
(#18067)
add d00d476970e Stabilize ZSTD compressor level pipe IT (#17917) (#18066)
add c0f674cfb1b Throttle empty subscription poll logs (#18063) (#18070)
add a653aeeff1e Avoid copying measurements when updating last cache
(#18059) (#18071)
add 9b124e4f131 Fix tag index memory accounting (#18029) (#18040)
add eb42ffbed2d [to dev/1.3] Add copy fallback for compaction hard links
(#18083)
add 1794e0c128e [To dev/1.3] Support target database in write-back sink
(#18086)
add 8e213ddfffe Pipe: add ConfigNode memory control for log reducer
(#18069) (#18087)
add a3f04b5e7b1 Disable IoTV1 region reconstruct IT (#18107)
add 7188fc510ff [Pipe] Improve pipe control-flow lock responsiveness
(#18076) (#18085)
add 187a4d8da77 [dev/1.3] Pipe: preserve TsFile parse OOM cause (#18105)
add 23e40d4b97c Pipe: Remove Ratis data region source restriction (#18089)
(#18100)
add 5b92817bd00 Avoid login lock for pipe auth retry (#18048) (#18101)
add b7285afdc34 Fix stale pipe runtime error messages (#18061) (#18102)
add 170cd74ae4e Pipe: fix manual IT pipe memory config (#18109)
add c8e0935d5d7 Pipe: improve incremental memory estimation (#18049)
(#18113)
add c7c54941e32 Fix StateMachineProcedure EOF state re-execution (#18099)
(#18122)
add f83a5d59858 Fix aligned memtable flush after deleting measurements
(#18116) (#18126)
add a6643abc42d Fix RegionGroupCache activation race (#18128) (#18136)
add 46badda5628 Improve pipe runtime memory allocation (#18051) (#18135)
add 197c137acc1 Pipe: throttle TsFile parser retries under memory pressure
(#18141) (#18152)
add 912bf892f55 Improve pipe receiver session handling (#18084) (#18137)
add f7bdf3294e8 Improve metadata OOM diagnostics (#18039) (#18115)
add e46587e6111 Fix downgraded resource may not serialize normally (#18157)
add 7d0565a6ad3 Fix metadata cache and pipe edge cases (#18147) (#18156)
add 0d81bbce431 Avoid parsing fully matched historical table TsFiles
(#18123) (#18134)
add 12d10a0d416 Pipe: disable serialize-by-region by default (#18140)
add 9ec2add768c [To dev/1.3] Fix the clear logic of specified info of one
operator when print plan in explain analyze (#18168)
add 4df9f9961a9 Add pipe receiver memory protection (#18090) (#18133)
add 3e3414a7c55 Fix subscription consumer lifecycle state ordering
(#18151) (#18169)
add db233b76cf0 Pipe: manage ConfigNode receiver temporary memory (#18144)
(#18170)
add 15db6e58e0d Reduce pipe type conversion log frequency (#18161) (#18173)
add 427d4028bea fix the IoTDBRegionMigrateNormalIT (#18181)
add aa2e761f694 Fix IT log directory test class names (#18131) (#18174)
add 81f59fa39f2 Reduce pipe load success log noise (#18106) (#18183)
add 2c089d39326 Pipe: use session context in legacy receiver loaders
(#18111) (#18184)
add d3fb1eac571 Fix pipe drop stuck on blocking sink reconnect (#18145)
(#18188)
add 9b66d5e528e [Backport 1.3] Avoid read lock when restoring degraded
time index (#18190)
add e2014ff5329 Reduce repeated failure logs (#18175) (#18193)
add f0e8ba2637f [To dev/1.3] Enforce REST query row limit as hard cap
(#18149) (#18197)
add db2dfe965a9 Pipe IT: disable pipe memory control in overridden setups
(#18198) (#18205)
add 54132275259 Pipe: optimize InsertRows schema aggregation (#18195)
(#18207)
add 5b0040f0b0f Merge branch 'dev/1.3' of github.com:apache/iotdb into 1.3
No new revisions were added by this update.
Summary of changes:
.github/scripts/package-client-cpp-manylinux228.sh | 101 +
.github/workflows/client-cpp-package.yml | 454 ++++
.github/workflows/cluster-it-1c1d1a.yml | 64 -
.github/workflows/multi-language-client.yml | 52 +-
.github/workflows/pipe-it-2cluster.yml | 6 +
.gitignore | 10 +-
.mvn/wrapper/maven-wrapper.properties | 2 +-
LICENSE-binary | 22 +-
distribution/pom.xml | 66 +-
example/client-cpp-example/README.md | 248 ++-
example/client-cpp-example/README_zh.md | 252 +++
example/client-cpp-example/pom.xml | 136 +-
.../src/AlignedTimeseriesSessionExample.cpp | 639 +++---
example/client-cpp-example/src/CMakeLists.txt | 137 +-
.../client-cpp-example/src/MultiSvrNodeClient.cpp | 116 ++
example/client-cpp-example/src/SessionExample.cpp | 689 ++++---
example/client-cpp-example/src/tree_example.c | 118 ++
integration-test/pom.xml | 8 +-
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 9 +-
.../it/env/cluster/config/MppCommonConfig.java | 20 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 25 +
.../env/cluster/config/MppSharedCommonConfig.java | 20 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 236 ++-
.../iotdb/it/env/cluster/env/MultiClusterEnv.java | 9 +
.../it/env/remote/config/RemoteCommonConfig.java | 12 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 17 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 8 +
.../pass/IoTDBRegionMigrateNormalIT.java | 34 +
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 3 +-
.../iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java | 226 ++
.../iotdb/db/it/IoTDBLoadTsFileWithModIT.java | 249 +++
.../iotdb/db/it/last/IoTDBLastQueryAliasIT.java | 16 +-
.../IoTDBExplainAnalyzePrintIT.java} | 101 +-
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 30 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 28 +
.../regionscan/IoTDBActiveSchemaQueryIT.java | 47 +
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 8 +
.../framework/IoTDBTestRunnerWithParameters.java | 15 +-
.../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 92 +-
.../pipe/it/autocreate/IoTDBPipeAutoSplitIT.java | 55 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 197 +-
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 2 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 16 +-
.../it/autocreate/IoTDBPipeSinkCompressionIT.java | 180 +-
.../it/autocreate/IoTDBPipeSinkParallelIT.java | 1 +
.../pipe/it/autocreate/IoTDBPipeSourceIT.java | 60 +-
...emoryIT.java => IoTDBPipeTsFileParseOOMIT.java} | 63 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 10 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 13 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 4 +
.../manual/IoTDBPipeTypeConversionISessionIT.java | 1 +
...RegionIT.java => IoTDBPipeWriteBackSinkIT.java} | 64 +-
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 217 ++
.../IoTDBEncryptedPasswordPullConsumerIT.java | 1 +
iotdb-client/client-cpp/CMakeLists.txt | 271 +++
iotdb-client/client-cpp/README.md | 396 +++-
iotdb-client/client-cpp/cmake/FetchBoost.cmake | 130 ++
.../client-cpp/cmake/FetchBuildTools.cmake | 266 +++
iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake | 121 ++
iotdb-client/client-cpp/cmake/FetchThrift.cmake | 277 +++
.../client-cpp/cmake/GenerateThriftSources.cmake | 126 ++
.../client-cpp/cmake/iotdb-session-config.cmake.in | 56 +
.../client-cpp/cmake/iotdb-session.pc.in | 18 +-
iotdb-client/client-cpp/pom.xml | 427 ++--
.../client-cpp/src/assembly/client-cpp.xml | 59 +-
.../package-metadata/third_party/DEPENDENCIES.md | 14 +-
.../src/include/AbstractSessionBuilder.h | 65 +
iotdb-client/client-cpp/src/include/Column.h | 364 ++++
.../client-cpp/src/include/ColumnDecoder.h | 83 +
iotdb-client/client-cpp/src/include/Common.h | 428 ++++
iotdb-client/client-cpp/src/include/Date.h | 65 +
.../client-cpp/src/include/Endpoint.h | 32 +-
.../client-cpp/src/include/Export.h | 25 +-
iotdb-client/client-cpp/src/include/Optional.h | 57 +
iotdb-client/client-cpp/src/include/Session.h | 828 ++++++++
.../client-cpp/src/include/SessionBuilder.h | 101 +
iotdb-client/client-cpp/src/include/SessionC.h | 399 ++++
.../client-cpp/src/include/SessionConfig.h | 23 +-
.../client-cpp/src/include/SessionDataSet.h | 124 ++
iotdb-client/client-cpp/src/include/SessionPool.h | 352 ++++
.../client-cpp/src/include/Status.h | 16 +-
iotdb-client/client-cpp/src/include/TsBlock.h | 54 +
iotdb-client/client-cpp/src/main/CMakeLists.txt | 53 -
iotdb-client/client-cpp/src/main/Column.cpp | 359 ----
iotdb-client/client-cpp/src/main/Column.h | 353 ----
iotdb-client/client-cpp/src/main/ColumnDecoder.cpp | 181 --
iotdb-client/client-cpp/src/main/ColumnDecoder.h | 75 -
iotdb-client/client-cpp/src/main/Common.cpp | 498 -----
iotdb-client/client-cpp/src/main/Common.h | 492 -----
iotdb-client/client-cpp/src/main/DeviceID.h | 161 --
.../client-cpp/src/main/IoTDBRpcDataSet.cpp | 558 -----
iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.h | 150 --
iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 222 --
iotdb-client/client-cpp/src/main/NodesSupplier.h | 137 --
iotdb-client/client-cpp/src/main/Session.cpp | 2048 ------------------
iotdb-client/client-cpp/src/main/Session.h | 1014 ---------
.../client-cpp/src/main/SessionConnection.cpp | 673 ------
.../client-cpp/src/main/SessionConnection.h | 364 ----
.../client-cpp/src/main/SessionDataSet.cpp | 252 ---
iotdb-client/client-cpp/src/main/SessionDataSet.h | 142 --
.../client-cpp/src/main/ThriftConnection.cpp | 170 --
.../client-cpp/src/main/ThriftConnection.h | 71 -
iotdb-client/client-cpp/src/main/TsBlock.cpp | 121 --
iotdb-client/client-cpp/src/main/TsBlock.h | 55 -
.../client-cpp/src/rpc/IoTDBRpcDataSet.cpp | 734 +++++++
iotdb-client/client-cpp/src/rpc/IoTDBRpcDataSet.h | 164 ++
iotdb-client/client-cpp/src/rpc/NodesSupplier.cpp | 247 +++
iotdb-client/client-cpp/src/rpc/NodesSupplier.h | 144 ++
iotdb-client/client-cpp/src/rpc/RpcCommon.cpp | 216 ++
iotdb-client/client-cpp/src/rpc/RpcCommon.h | 86 +
.../client-cpp/src/rpc/SessionConnection.cpp | 680 ++++++
.../client-cpp/src/rpc/SessionConnection.h | 364 ++++
.../SessionDataSetFactory.h} | 39 +-
iotdb-client/client-cpp/src/rpc/SessionImpl.h | 230 +++
.../client-cpp/src/rpc/ThriftConnection.cpp | 187 ++
iotdb-client/client-cpp/src/rpc/ThriftConnection.h | 79 +
iotdb-client/client-cpp/src/rpc/ThriftConvert.cpp | 62 +
.../ThriftConvert.h} | 39 +-
iotdb-client/client-cpp/src/session/Column.cpp | 459 +++++
.../client-cpp/src/session/ColumnDecoder.cpp | 207 ++
iotdb-client/client-cpp/src/session/Common.cpp | 315 +++
iotdb-client/client-cpp/src/session/Date.cpp | 65 +
iotdb-client/client-cpp/src/session/Session.cpp | 2174 ++++++++++++++++++++
iotdb-client/client-cpp/src/session/SessionC.cpp | 1410 +++++++++++++
.../client-cpp/src/session/SessionDataSet.cpp | 341 +++
.../client-cpp/src/session/SessionPool.cpp | 266 +++
iotdb-client/client-cpp/src/session/TsBlock.cpp | 116 ++
iotdb-client/client-cpp/src/test/CMakeLists.txt | 64 -
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 797 -------
iotdb-client/client-cpp/test/CMakeLists.txt | 94 +
iotdb-client/client-cpp/test/catch2/.gitignore | 4 +
iotdb-client/client-cpp/test/cpp/sessionCIT.cpp | 748 +++++++
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 1042 ++++++++++
iotdb-client/client-cpp/{src => }/test/main.cpp | 37 +-
iotdb-client/client-cpp/test/main_c.cpp | 52 +
iotdb-client/client-cpp/third-party/.gitignore | 7 +
iotdb-client/client-cpp/third-party/README.md | 75 +
.../client-cpp/third-party/linux/.gitignore | 2 +
iotdb-client/client-cpp/third-party/mac/.gitignore | 2 +
.../client-cpp/third-party/windows/.gitignore | 2 +
iotdb-client/client-go | 2 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 39 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 47 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 8 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +-
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 25 +
.../java/org/apache/iotdb/session/Session.java | 130 +-
.../apache/iotdb/session/SessionConnection.java | 3 +
.../org/apache/iotdb/session/pool/SessionPool.java | 3 +
.../iotdb/session/SessionConnectionTest.java | 8 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 11 +
.../src/test/resources/iotdb-common.properties | 3 +-
iotdb-client/subscription/pom.xml | 10 +
.../consumer/EmptyPollLogThrottler.java | 62 +
.../consumer/SubscriptionProviders.java | 6 +
.../consumer/SubscriptionPullConsumer.java | 32 +-
.../consumer/SubscriptionPushConsumer.java | 31 +-
.../consumer/EmptyPollLogThrottlerTest.java | 63 +
.../SubscriptionConsumerLifecycleTest.java | 214 ++
iotdb-core/confignode/pom.xml | 4 -
.../async/AsyncAINodeHeartbeatClientPool.java | 27 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 27 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 33 +-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 2 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 2 +-
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 12 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 2 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 2 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 2 +-
.../confignode/conf/ConfigNodeDescriptor.java | 9 +
.../confignode/conf/ConfigNodeMemoryConfig.java | 82 +
.../consensus/request/read/cq/ShowCQPlan.java | 13 +
.../consensus/request/write/cq/ActiveCQPlan.java | 20 +-
.../consensus/request/write/cq/AddCQPlan.java | 20 +-
.../consensus/request/write/cq/DropCQPlan.java | 20 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 23 +-
.../response/pipe/task/PipeTableResp.java | 6 +
.../iotdb/confignode/manager/TTLManager.java | 4 +
.../iotdb/confignode/manager/cq/CQManager.java | 102 +-
.../confignode/manager/cq/CQScheduleTask.java | 58 +-
.../load/cache/region/RegionGroupCache.java | 8 +-
.../manager/partition/PartitionManager.java | 8 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 10 +
.../runtime/heartbeat/PipeHeartbeatParser.java | 32 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 13 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 13 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 90 +-
.../resource/PipeConfigNodeResourceManager.java | 7 +
.../memory/PipeConfigNodeMemoryManager.java | 115 ++
.../confignode/persistence/ProcedureInfo.java | 13 +-
.../iotdb/confignode/persistence/TTLInfo.java | 33 +-
.../iotdb/confignode/persistence/UDFInfo.java | 54 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 76 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 43 +-
.../iotdb/confignode/procedure/Procedure.java | 20 +
.../confignode/procedure/ProcedureExecutor.java | 114 +-
.../procedure/TimeoutExecutorThread.java | 46 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 236 ++-
.../procedure/impl/StateMachineProcedure.java | 18 +-
.../procedure/impl/cq/CreateCQProcedure.java | 82 +-
.../procedure/impl/node/AbstractNodeProcedure.java | 12 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 69 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 4 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 4 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 6 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 39 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 2 +-
.../impl/schema/DeleteDatabaseProcedure.java | 2 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../procedure/impl/schema/SetTTLProcedure.java | 241 ++-
.../AbstractOperateSubscriptionProcedure.java | 20 +
.../runtime/ConsumerGroupMetaSyncProcedure.java | 10 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 9 +-
.../impl/trigger/CreateTriggerProcedure.java | 2 +-
.../impl/trigger/DropTriggerProcedure.java | 2 +-
.../confignode/procedure/scheduler/LockQueue.java | 10 +-
.../scheduler/SimpleProcedureScheduler.java | 37 +-
.../procedure/state/schema/SetTTLState.java | 4 +-
.../writelog/io/SingleFileLogReader.java | 5 +-
.../conf/ConfigNodeMemoryConfigTest.java | 19 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../apache/iotdb/confignode/cq/CQManagerTest.java | 107 +
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 129 +-
.../task/PipeTaskCoordinatorLockTest.java | 60 +
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 18 +
...eConfigPhysicalPlanPatternParseVisitorTest.java | 42 +
.../iotdb/confignode/persistence/CQInfoTest.java | 64 +-
.../iotdb/confignode/persistence/TTLInfoTest.java | 68 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 71 +-
.../pipe/PipeTaskInfoAutoRestartTest.java | 28 +
.../confignode/procedure/STMProcedureTest.java | 70 +
.../iotdb/confignode/procedure/TestLockRegime.java | 23 +
.../procedure/TestProcedureExecutor.java | 102 +
.../procedure/entity/SimpleLockProcedure.java | 11 +-
.../procedure/impl/CreateCQProcedureTest.java | 26 +
.../impl/cq/CreateCQProcedureRecoveryTest.java | 117 ++
.../pipe/AbstractOperatePipeProcedureV2Test.java | 169 ++
.../PipeHandleLeaderChangeProcedureTest.java | 47 +
.../procedure/impl/schema/SetTTLProcedureTest.java | 327 +++
.../iotdb/consensus/ratis/RecoverReadTest.java | 9 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 70 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 +-
...java => LoadAnalyzeMissingSchemaException.java} | 6 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 26 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 407 ++--
.../task/builder/PipeDataNodeTaskBuilder.java | 92 +-
.../agent/task/connection/PipeEventCollector.java | 14 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 5 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 10 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 212 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 9 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 108 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 5 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 53 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 8 +-
.../common/tablet/PipeRawTabletEventConverter.java | 50 +
.../common/tablet/PipeRawTabletInsertionEvent.java | 133 +-
.../event/common/tablet/PipeTabletCollector.java | 34 +
.../pipe/event/common/tablet/PipeTabletUtils.java | 245 +++
.../tablet/TabletInsertionDataContainer.java | 73 +-
.../event/common/terminate/PipeTerminateEvent.java | 179 ++
.../common/tsfile/PipeTsFileInsertionEvent.java | 156 +-
.../container/TsFileInsertionDataContainer.java | 36 +-
.../query/TsFileInsertionQueryDataContainer.java | 108 +-
.../TsFileInsertionQueryDataTabletIterator.java | 45 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 55 +-
.../scan/MemoryControlledChunkReader.java | 71 +
.../container/scan/SinglePageWholeChunkReader.java | 216 +-
.../scan/TsFileInsertionScanDataContainer.java | 737 ++++---
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 58 +
.../processor/aggregate/AggregateProcessor.java | 16 +-
.../downsampling/DownSamplingProcessor.java | 3 +
.../receiver/TwoStageAggregateReceiver.java | 11 +
.../exchange/sender/TwoStageAggregateSender.java | 75 +-
.../twostage/plugin/TwoStageCountProcessor.java | 31 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 122 +-
.../protocol/legacy/loader/DeletionLoader.java | 12 +-
.../receiver/protocol/legacy/loader/ILoader.java | 3 +-
.../protocol/legacy/loader/TsFileLoader.java | 9 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 348 +++-
.../transform/converter/ValueConverter.java | 30 +-
.../statement/PipeConvertedInsertRowStatement.java | 29 +-
.../PipeConvertedInsertTabletStatement.java | 14 +-
...peStatementDataTypeConvertExecutionVisitor.java | 8 +-
.../visitor/PipeStatementExceptionVisitor.java | 8 +
.../visitor/PipeStatementTSStatusVisitor.java | 4 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 257 ++-
.../resource/log/PipePeriodicalLogReducer.java | 91 -
.../db/pipe/resource/memory/PipeMemoryManager.java | 98 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 28 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 70 +-
.../batch/PipeSchemaRegionWritePlanEventBatch.java | 555 +++++
.../evolvable/batch/PipeTabletEventBatch.java | 84 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 12 +-
.../batch/PipeTabletEventTsFileBatch.java | 36 +-
.../batch/PipeTransferBatchReqBuilder.java | 54 +-
.../evolvable/request/PipeTransferPlanNodeReq.java | 38 +-
.../request/PipeTransferTabletBatchReq.java | 6 +-
.../request/PipeTransferTabletRawReq.java | 19 +-
.../request/PipeTransferTsFileSealWithModReq.java | 68 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 322 ++-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 169 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 46 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 5 +-
.../pipeconsensus/PipeConsensusSyncSink.java | 20 +-
.../PipeConsensusTabletBatchEventHandler.java | 14 +-
.../PipeConsensusTabletInsertionEventHandler.java | 20 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 44 +-
.../PipeConsensusTransferBatchReqBuilder.java | 106 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 181 +-
.../handler/PipeTransferTrackableHandler.java | 54 +-
.../async/handler/PipeTransferTsFileHandler.java | 70 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 157 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 177 +-
.../websocket/WebSocketConnectorServer.java | 51 +-
.../sink/protocol/websocket/WebSocketSink.java | 8 +
.../sink/protocol/writeback/WriteBackSink.java | 212 +-
.../db/pipe/sink/util/PipeTabletEventSorter.java | 8 +
.../source/dataregion/IoTDBDataRegionSource.java | 11 -
.../PipeHistoricalDataRegionTsFileSource.java | 124 +-
.../realtime/PipeRealtimeDataRegionSource.java | 6 +-
.../realtime/assigner/DisruptorQueue.java | 19 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 89 +-
.../PipeTsFileEpochProgressIndexKeeper.java | 80 +-
.../realtime/disruptor/BatchEventProcessor.java | 11 +-
.../realtime/disruptor/MultiProducerSequencer.java | 21 +
.../dataregion/realtime/disruptor/RingBuffer.java | 22 +-
.../realtime/epoch/TsFileEpochManager.java | 69 +-
.../listener/PipeInsertionDataNodeListener.java | 49 +-
.../protocol/rest/handler/QueryRowLimitUtils.java | 68 +
.../rest/v1/handler/QueryDataSetHandler.java | 114 +-
.../rest/v1/impl/GrafanaApiServiceImpl.java | 19 +-
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 8 +-
.../protocol/rest/v2/handler/FastLastHandler.java | 59 +-
.../rest/v2/handler/QueryDataSetHandler.java | 114 +-
.../rest/v2/impl/GrafanaApiServiceImpl.java | 19 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 43 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 105 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 75 +-
.../thrift/impl/DataNodeRegionManager.java | 7 +-
.../thrift/impl/PushMultiPipeMetaHelper.java | 85 +
.../db/queryengine/common/MPPQueryContext.java | 307 ++-
.../db/queryengine/common/TimeseriesContext.java | 294 ++-
.../common/schematree/ClusterSchemaTree.java | 8 +
.../execution/aggregation/Aggregator.java | 92 +-
.../fragment/FragmentInstanceContext.java | 52 +
.../fragment/FragmentInstanceExecution.java | 1 -
.../execution/operator/OperatorContext.java | 24 +
.../operator/process/AggregationOperator.java | 25 +-
.../process/RawDataAggregationOperator.java | 129 +-
.../operator/process/TagAggregationOperator.java | 15 +-
.../schema/CountGroupByLevelScanOperator.java | 15 +-
.../operator/schema/SchemaCountOperator.java | 4 +
.../operator/schema/source/ISchemaSource.java | 13 +
.../schema/source/SchemaSourceFactory.java | 15 +-
.../schema/source/TimeSeriesSchemaSource.java | 12 +
.../AbstractSeriesAggregationScanOperator.java | 26 +-
.../source/ActiveTimeSeriesRegionScanOperator.java | 92 +-
.../execution/schedule/DriverScheduler.java | 15 +-
.../queue/IndexedBlockingReserveQueue.java | 36 +-
.../multilevelqueue/MultilevelPriorityQueue.java | 10 +
.../execution/schedule/task/DriverTask.java | 13 +
.../metric/DriverSchedulerMetricSet.java | 13 +
.../metric/QueryExecutionMetricSet.java | 15 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 15 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 188 +-
.../plan/analyze/ClusterPartitionFetcher.java | 38 +-
.../queryengine/plan/analyze/ExpressionUtils.java | 2 +
.../analyze/cache/schema/DeviceCacheEntry.java | 20 +-
.../plan/analyze/cache/schema/DeviceLastCache.java | 36 +-
.../analyze/cache/schema/DeviceNormalSchema.java | 11 +-
.../analyze/cache/schema/DeviceSchemaCache.java | 4 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 135 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 9 +
.../config/executor/ClusterConfigTaskExecutor.java | 62 +-
.../plan/planner/LogicalPlanBuilder.java | 12 +-
.../plan/planner/LogicalPlanVisitor.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 39 +-
.../plan/planner/distribution/SourceRewriter.java | 10 +-
.../plan/node/load/LoadSingleTsFileNode.java | 40 +-
.../metedata/read/LevelTimeSeriesCountNode.java | 34 +-
.../node/metedata/read/TimeSeriesCountNode.java | 28 +-
.../plan/node/source/TimeseriesRegionScanNode.java | 7 +
.../planner/plan/node/write/DeleteDataNode.java | 12 +-
.../plan/planner/plan/node/write/InsertNode.java | 121 +-
.../planner/plan/node/write/InsertRowNode.java | 46 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 7 +-
.../planner/plan/node/write/InsertTabletNode.java | 60 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 76 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 101 +-
.../plan/statement/crud/InsertTabletStatement.java | 166 +-
.../plan/statement/crud/LoadTsFileStatement.java | 39 +
.../plan/statement/metadata/CountStatement.java | 81 +
.../metadata/CountTimeSeriesStatement.java | 33 +-
.../statistics/SpecifiedInfoMergerFactory.java | 13 +
.../statistics/StatisticsMergeUtil.java | 2 -
.../datastructure/SerializableList.java | 3 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 17 +-
.../schemaregion/SchemaRegionLoader.java | 8 +-
.../logfile/FakeCRC32Deserializer.java | 5 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 130 +-
.../mtree/impl/mem/mnode/IMemMNode.java | 30 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 34 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 83 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 69 +-
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 17 +
.../mtree/impl/pbtree/mnode/ICachedMNode.java | 19 +
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 40 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 3 +-
.../pbtree/schemafile/log/SchemaFileLogReader.java | 7 +-
.../pbtree/schemafile/pagemgr/PageIOChannel.java | 3 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 9 +-
.../schemaregion/mtree/traverser/Traverser.java | 103 +
.../traverser/basic/MeasurementTraverser.java | 5 +
.../schemaengine/schemaregion/tag/TagLogFile.java | 12 +-
.../schemaengine/schemaregion/tag/TagManager.java | 125 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 9 +-
.../iotdb/db/storageengine/StorageEngine.java | 19 +-
.../db/storageengine/dataregion/DataRegion.java | 36 +-
.../RepairUnsortedFileCompactionPerformer.java | 9 +-
.../execute/task/InnerSpaceCompactionTask.java | 13 +-
.../task/InsertionCrossSpaceCompactionTask.java | 13 +-
.../task/RepairUnsortedFileCompactionTask.java | 7 +-
.../utils/writer/AbstractCompactionWriter.java | 164 +-
.../writer/AbstractCrossCompactionWriter.java | 3 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../utils/writer/FastInnerCompactionWriter.java | 10 +-
.../writer/ReadPointCrossCompactionWriter.java | 5 +-
.../writer/ReadPointInnerCompactionWriter.java | 5 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 4 +-
.../dataregion/memtable/AbstractMemTable.java | 5 +-
.../memtable/AlignedWritableMemChunk.java | 95 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 8 +-
.../dataregion/modification/Deletion.java | 39 +-
.../dataregion/modification/ModificationFile.java | 3 +-
.../filescan/impl/ClosedFileScanHandleImpl.java | 45 +-
.../filescan/impl/UnclosedFileScanHandleImpl.java | 83 +-
.../dataregion/tsfile/TsFileManager.java | 21 +-
.../dataregion/tsfile/TsFileResource.java | 25 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 9 +-
.../dataregion/wal/io/WALFileVersion.java | 4 +-
.../dataregion/wal/io/WALInputStream.java | 32 +-
.../dataregion/wal/io/WALMetaData.java | 12 +-
.../dataregion/wal/recover/WALRepairWriter.java | 3 +-
.../dataregion/wal/utils/WALReadUtils.java | 101 +
.../dataregion/wal/utils/WALWriteUtils.java | 16 +-
.../db/storageengine/load/LoadTsFileManager.java | 13 +
.../storageengine/load/active/ActiveLoadAgent.java | 6 +
.../load/active/ActiveLoadDirScanner.java | 18 +-
.../active/ActiveLoadFailedMessageHandler.java | 16 +
.../load/active/ActiveLoadPathHelper.java | 30 +
.../active/ActiveLoadScheduledExecutorService.java | 21 +-
.../load/active/ActiveLoadTsFileLoader.java | 27 +-
.../load/config/LoadTsFileConfigurator.java | 7 +
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 16 +-
.../converter/LoadTreeTsFileTabletIterator.java | 560 +++++
.../converter/LoadTsFileDataTypeConverter.java | 95 +
.../load/splitter/AlignedChunkData.java | 13 +-
.../load/splitter/NonAlignedChunkData.java | 14 +
.../storageengine/rescon/disk/FolderManager.java | 11 +-
.../rescon/quotas/DefaultOperationQuota.java | 28 +-
.../response/SubscriptionEventTsFileResponse.java | 11 +-
.../subtask/SubscriptionSinkSubtaskLifeCycle.java | 4 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 7 +-
.../{ParameterUtils.java => BitMapUtils.java} | 33 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 19 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 179 +-
.../iotdb/db/utils/sort/FileSpillerReader.java | 4 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 74 +
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 76 +
.../mtree/lock/StampedWriterPreferredLockTest.java | 42 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 33 +
.../schemaRegion/SchemaRegionBasicTest.java | 22 +
.../schemaRegion/SchemaStatisticsTest.java | 61 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 16 +
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 71 +
.../task/PipeProcessorSubtaskExecutorTest.java | 99 +
.../task/builder/PipeDataNodeTaskBuilderTest.java | 111 +
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 95 +
.../task/subtask/sink/PipeSinkSubtaskTest.java | 248 ++-
.../pipe/event/PipeTabletInsertionEventTest.java | 141 +-
.../event/TsFileInsertionDataContainerTest.java | 688 +++++++
.../event/common/tablet/PipeTabletUtilsTest.java | 72 +
.../schema/PipeSchemaRegionSinkMetricsTest.java | 154 ++
.../db/pipe/pattern/PipePatternPruningTest.java | 56 +-
.../plugin/TwoStageCountProcessorTest.java | 57 +
.../receiver/PipeStatementTsStatusVisitorTest.java | 46 +
.../legacy/IoTDBLegacyPipeReceiverAgentTest.java | 123 ++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 155 ++
.../transform/converter/ValueConverterTest.java | 70 +
.../sink/IoTDBDataNodeAsyncClientManagerTest.java | 102 +
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 85 +
.../iotdb/db/pipe/sink/PipeReceiverTest.java | 70 +-
.../db/pipe/sink/PipeSchemaRegionSinkTest.java | 376 ++++
.../PipeSchemaRegionWritePlanEventBatchTest.java | 463 +++++
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 171 ++
.../handler/PipeTransferTrackableHandlerTest.java | 38 +-
.../db/pipe/source/PipeRealtimeExtractTest.java | 157 ++
.../PipeHistoricalDataRegionTsFileSourceTest.java | 169 ++
.../PipeTsFileEpochProgressIndexKeeperTest.java | 160 ++
.../realtime/disruptor/DisruptorShutdownTest.java | 56 +
.../epoch/TsFileEpochManagerPerformanceTest.java | 210 ++
.../realtime/epoch/TsFileEpochManagerTest.java | 109 +
.../rest/handler/QueryRowLimitUtilsTest.java | 59 +
.../rest/v1/handler/QueryDataSetHandlerTest.java | 200 ++
.../rest/v2/handler/FastLastHandlerTest.java | 108 +
...nternalRPCServiceImplPushMultiPipeMetaTest.java | 246 +++
.../db/queryengine/common/MPPQueryContextTest.java | 125 ++
.../fragment/FragmentInstanceContextTest.java | 200 ++
.../AlignedSeriesAggregationScanOperatorTest.java | 33 +-
.../execution/operator/FillOperatorTest.java | 7 +-
.../operator/HorizontallyConcatOperatorTest.java | 3 +-
.../execution/operator/LimitOperatorTest.java | 3 +
.../execution/operator/LinearFillOperatorTest.java | 5 +-
.../execution/operator/MergeSortOperatorTest.java | 3 +-
.../execution/operator/OffsetOperatorTest.java | 19 +-
.../execution/operator/OperatorTestUtils.java | 53 +
.../SeriesAggregationScanOperatorTest.java | 33 +-
.../execution/operator/SeriesScanOperatorTest.java | 3 +-
.../operator/SingleDeviceViewOperatorTest.java | 9 +-
.../operator/UpdateLastCacheOperatorTest.java | 7 +-
.../operator/schema/SchemaCountOperatorTest.java | 113 +
.../schema/source/TimeSeriesSchemaSourceTest.java | 143 ++
.../schedule/DefaultDriverSchedulerTest.java | 41 +
.../queue/MultilevelPriorityQueueTest.java | 13 +-
.../distribution/RegionScanPlanningTest.java | 81 +
.../logical/RegionScanLogicalPlannerTest.java | 47 +
.../metadata/read/SchemaCountNodeSerdeTest.java | 6 +-
.../node/write/DeleteDataNodeSerdeTest.java | 28 +
.../planner/node/write/InsertRowNodeSerdeTest.java | 12 +-
.../node/write/InsertTabletNodeSerdeTest.java | 12 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 10 +
.../load/LoadTsFileDispatcherImplTest.java | 98 +
.../logfile/FakeCRC32DeserializerTest.java | 108 +
.../mtree/impl/mem/MTreeBelowSGMemoryImplTest.java | 253 +++
.../impl/pbtree/MTreeBelowSGCachedImplTest.java | 217 ++
.../schemaregion/tag/TagLogFileTest.java | 57 +
.../schemaregion/tag/TagManagerTest.java | 216 ++
.../utils/writer/AbstractCompactionWriterTest.java | 156 ++
.../dataregion/modification/DeletionTest.java} | 41 +-
.../dataregion/tsfile/TsFileResourceTest.java | 18 +-
.../dataregion/wal/io/WALFileTest.java | 12 +-
.../active/ActiveLoadFailedMessageHandlerTest.java | 51 +
.../load/active/ActiveLoadTsFileLoaderTest.java | 146 ++
...dInsertTabletStatementExceptionVisitorTest.java | 54 +
...atementDataTypeConvertExecutionVisitorTest.java | 396 ++++
.../load/splitter/ChunkDataDirectWriteTest.java | 89 +
.../rescon/quotas/DefaultOperationQuotaTest.java | 64 +
.../src/test/resources/iotdb-common.properties | 3 +-
.../src/test/resources/iotdb-system.properties | 4 +-
.../conf/iotdb-system.properties.template | 22 +-
.../Triple.java => audit/UserEntity.java} | 40 +-
.../client/request/AsyncRequestManager.java | 45 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 43 +-
.../commons/consensus/index/ProgressIndex.java | 11 +
.../index/impl/TimeWindowStateProgressIndex.java | 9 +-
.../commons/executable/ExecutableManager.java | 3 +-
.../executable/ReferenceCountedJarMetaKeeper.java | 136 ++
.../commons/log/LoggerPeriodicalLogReducer.java | 115 ++
.../iotdb/commons/partition/DataPartition.java | 16 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 10 +
.../throwing/ThrowingExceptionProcessor.java | 28 +
.../plugin/constructor/PipeSinkConstructor.java | 8 +-
.../meta/ConfigNodePipePluginMetaKeeper.java | 50 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 49 +-
.../task/connection/BlockingPendingQueue.java | 39 +-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 18 +
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 4 +
.../task/progress/PipeEventCommitManager.java | 5 +
.../task/subtask/PipeAbstractSinkSubtask.java | 127 +-
.../agent/task/subtask/PipeReportableSubtask.java | 51 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 2 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 4 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 24 +-
.../pipe/config/constant/PipeSinkConstant.java | 25 +
.../pipe/config/constant/PipeSourceConstant.java | 8 +
.../env/PipeTaskProcessorRuntimeEnvironment.java | 23 +
.../pipe/datastructure/pattern/PipePattern.java | 82 +-
.../queue/serializer/PlainQueueSerializer.java | 3 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 149 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 4 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 29 +
.../commons/pipe/resource/log/PipeLogger.java | 12 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 6 +-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../thrift/common/PipeTransferSliceReqHandler.java | 37 +
.../thrift/request/PipeTransferCompressedReq.java | 21 +
.../pipe/sink/protocol/IoTDBAirGapSink.java | 23 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 8 +
.../protocol/PipeConnectorWithEventDiscard.java | 7 +
.../node/common/AbstractAboveDatabaseMNode.java | 4 +
.../commons/schema/node/utils/IMNodeIterator.java | 2 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 4 +
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 21 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 24 +-
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 47 +-
.../client/request/AsyncRequestManagerTest.java | 221 ++
.../ReferenceCountedJarMetaKeeperTest.java | 116 ++
.../log/LoggerPeriodicalLogReducerTest.java | 66 +
.../commons/pipe/config/PipeDescriptorTest.java | 65 +
.../pattern/PipePatternParseTest.java | 83 +
.../pipe/receiver/IoTDBFileReceiverTest.java | 184 +-
.../common/PipeTransferSliceReqBuilderTest.java | 53 +
.../request/PipeTransferCompressedReqTest.java | 149 ++
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 26 +
.../commons/pipe/task/PipeSleepIntervalTest.java | 86 +-
.../apache/iotdb/commons/utils/FileUtilsTest.java | 8 +
.../apache/iotdb/commons/utils/IOUtilsTest.java | 147 ++
.../iotdb/commons/utils/WindowsOSUtilsTest.java | 53 +
.../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 1 +
.../openapi/src/main/openapi3/iotdb_rest_v2.yaml | 1 +
pom.xml | 7 +-
622 files changed, 44682 insertions(+), 14200 deletions(-)
create mode 100755 .github/scripts/package-client-cpp-manylinux228.sh
create mode 100644 .github/workflows/client-cpp-package.yml
delete mode 100644 .github/workflows/cluster-it-1c1d1a.yml
create mode 100644 example/client-cpp-example/README_zh.md
create mode 100644 example/client-cpp-example/src/MultiSvrNodeClient.cpp
create mode 100644 example/client-cpp-example/src/tree_example.c
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileWithModIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBFileTimeIndexIT.java
=> query/IoTDBExplainAnalyzePrintIT.java} (50%)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/{IoTDBPipeMemoryIT.java
=> IoTDBPipeTsFileParseOOMIT.java} (58%)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/{IoTDBPipeMultiSchemaRegionIT.java
=> IoTDBPipeWriteBackSinkIT.java} (54%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBLegacyPipeReceiverSecurityIT.java
create mode 100644 iotdb-client/client-cpp/CMakeLists.txt
create mode 100644 iotdb-client/client-cpp/cmake/FetchBoost.cmake
create mode 100644 iotdb-client/client-cpp/cmake/FetchBuildTools.cmake
create mode 100644 iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake
create mode 100644 iotdb-client/client-cpp/cmake/FetchThrift.cmake
create mode 100644 iotdb-client/client-cpp/cmake/GenerateThriftSources.cmake
create mode 100644 iotdb-client/client-cpp/cmake/iotdb-session-config.cmake.in
copy docker/src/main/DockerCompose/start-1c1d.sh =>
iotdb-client/client-cpp/cmake/iotdb-session.pc.in (74%)
mode change 100755 => 100644
copy code-coverage/README.md =>
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/DEPENDENCIES.md
(55%)
create mode 100644 iotdb-client/client-cpp/src/include/AbstractSessionBuilder.h
create mode 100644 iotdb-client/client-cpp/src/include/Column.h
create mode 100644 iotdb-client/client-cpp/src/include/ColumnDecoder.h
create mode 100644 iotdb-client/client-cpp/src/include/Common.h
create mode 100644 iotdb-client/client-cpp/src/include/Date.h
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeConnectionException.java
=> iotdb-client/client-cpp/src/include/Endpoint.h (61%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-client/client-cpp/src/include/Export.h (73%)
create mode 100644 iotdb-client/client-cpp/src/include/Optional.h
create mode 100644 iotdb-client/client-cpp/src/include/Session.h
create mode 100644 iotdb-client/client-cpp/src/include/SessionBuilder.h
create mode 100644 iotdb-client/client-cpp/src/include/SessionC.h
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java
=> iotdb-client/client-cpp/src/include/SessionConfig.h (67%)
create mode 100644 iotdb-client/client-cpp/src/include/SessionDataSet.h
create mode 100644 iotdb-client/client-cpp/src/include/SessionPool.h
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
=> iotdb-client/client-cpp/src/include/Status.h (83%)
create mode 100644 iotdb-client/client-cpp/src/include/TsBlock.h
delete mode 100644 iotdb-client/client-cpp/src/main/CMakeLists.txt
delete mode 100644 iotdb-client/client-cpp/src/main/Column.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/Column.h
delete mode 100644 iotdb-client/client-cpp/src/main/ColumnDecoder.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/ColumnDecoder.h
delete mode 100644 iotdb-client/client-cpp/src/main/Common.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/Common.h
delete mode 100644 iotdb-client/client-cpp/src/main/DeviceID.h
delete mode 100644 iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.h
delete mode 100644 iotdb-client/client-cpp/src/main/NodesSupplier.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/NodesSupplier.h
delete mode 100644 iotdb-client/client-cpp/src/main/Session.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/Session.h
delete mode 100644 iotdb-client/client-cpp/src/main/SessionConnection.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/SessionConnection.h
delete mode 100644 iotdb-client/client-cpp/src/main/SessionDataSet.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/SessionDataSet.h
delete mode 100644 iotdb-client/client-cpp/src/main/ThriftConnection.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/ThriftConnection.h
delete mode 100644 iotdb-client/client-cpp/src/main/TsBlock.cpp
delete mode 100644 iotdb-client/client-cpp/src/main/TsBlock.h
create mode 100644 iotdb-client/client-cpp/src/rpc/IoTDBRpcDataSet.cpp
create mode 100644 iotdb-client/client-cpp/src/rpc/IoTDBRpcDataSet.h
create mode 100644 iotdb-client/client-cpp/src/rpc/NodesSupplier.cpp
create mode 100644 iotdb-client/client-cpp/src/rpc/NodesSupplier.h
create mode 100644 iotdb-client/client-cpp/src/rpc/RpcCommon.cpp
create mode 100644 iotdb-client/client-cpp/src/rpc/RpcCommon.h
create mode 100644 iotdb-client/client-cpp/src/rpc/SessionConnection.cpp
create mode 100644 iotdb-client/client-cpp/src/rpc/SessionConnection.h
copy iotdb-client/client-cpp/src/{main/AbstractSessionBuilder.h =>
rpc/SessionDataSetFactory.h} (53%)
create mode 100644 iotdb-client/client-cpp/src/rpc/SessionImpl.h
create mode 100644 iotdb-client/client-cpp/src/rpc/ThriftConnection.cpp
create mode 100644 iotdb-client/client-cpp/src/rpc/ThriftConnection.h
create mode 100644 iotdb-client/client-cpp/src/rpc/ThriftConvert.cpp
rename iotdb-client/client-cpp/src/{main/AbstractSessionBuilder.h =>
rpc/ThriftConvert.h} (59%)
create mode 100644 iotdb-client/client-cpp/src/session/Column.cpp
create mode 100644 iotdb-client/client-cpp/src/session/ColumnDecoder.cpp
create mode 100644 iotdb-client/client-cpp/src/session/Common.cpp
create mode 100644 iotdb-client/client-cpp/src/session/Date.cpp
create mode 100644 iotdb-client/client-cpp/src/session/Session.cpp
create mode 100644 iotdb-client/client-cpp/src/session/SessionC.cpp
create mode 100644 iotdb-client/client-cpp/src/session/SessionDataSet.cpp
create mode 100644 iotdb-client/client-cpp/src/session/SessionPool.cpp
create mode 100644 iotdb-client/client-cpp/src/session/TsBlock.cpp
delete mode 100644 iotdb-client/client-cpp/src/test/CMakeLists.txt
delete mode 100644 iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp
create mode 100644 iotdb-client/client-cpp/test/CMakeLists.txt
create mode 100644 iotdb-client/client-cpp/test/catch2/.gitignore
create mode 100644 iotdb-client/client-cpp/test/cpp/sessionCIT.cpp
create mode 100644 iotdb-client/client-cpp/test/cpp/sessionIT.cpp
rename iotdb-client/client-cpp/{src => }/test/main.cpp (52%)
create mode 100644 iotdb-client/client-cpp/test/main_c.cpp
create mode 100644 iotdb-client/client-cpp/third-party/.gitignore
create mode 100644 iotdb-client/client-cpp/third-party/README.md
create mode 100644 iotdb-client/client-cpp/third-party/linux/.gitignore
create mode 100644 iotdb-client/client-cpp/third-party/mac/.gitignore
create mode 100644 iotdb-client/client-cpp/third-party/windows/.gitignore
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/EmptyPollLogThrottler.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/EmptyPollLogThrottlerTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumerLifecycleTest.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfig.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/memory/PipeConfigNodeMemoryManager.java
copy
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java
=>
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfigTest.java
(57%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/cq/CQManagerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLockTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedureRecoveryTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2Test.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{DirectoryNotLegalException.java
=> LoadAnalyzeMissingSchemaException.java} (85%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/scan/MemoryControlledChunkReader.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/log/PipePeriodicalLogReducer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeSchemaRegionWritePlanEventBatch.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/handler/QueryRowLimitUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/PushMultiPipeMetaHelper.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALReadUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeTsFileTabletIterator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/{ParameterUtils.java
=> BitMapUtils.java} (59%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/schema/PipeSchemaRegionSinkMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/legacy/IoTDBLegacyPipeReceiverAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiverTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/IoTDBDataNodeAsyncClientManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSchemaRegionSinkTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSchemaRegionWritePlanEventBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/airgap/IoTDBDataRegionAirGapSinkTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileSourceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexKeeperTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/handler/QueryRowLimitUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/v1/handler/QueryDataSetHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/v2/handler/FastLastHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplPushMultiPipeMetaTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/common/MPPQueryContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/OperatorTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/TimeSeriesSchemaSourceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImplTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/logfile/FakeCRC32DeserializerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/MTreeBelowSGMemoryImplTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/MTreeBelowSGCachedImplTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagLogFileTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/AbstractCompactionWriterTest.java
copy
iotdb-core/{confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedureTest.java
=>
datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/modification/DeletionTest.java}
(51%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatementExceptionVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/splitter/ChunkDataDirectWriteTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/quotas/DefaultOperationQuotaTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/datastructure/Triple.java
=> audit/UserEntity.java} (57%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/executable/ReferenceCountedJarMetaKeeper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/log/LoggerPeriodicalLogReducer.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/request/AsyncRequestManagerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/executable/ReferenceCountedJarMetaKeeperTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/log/LoggerPeriodicalLogReducerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/config/PipeDescriptorTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/pattern/PipePatternParseTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferCompressedReqTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/IOUtilsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/WindowsOSUtilsTest.java
