This is an automated email from the ASF dual-hosted git repository.
VGalaxies pushed a change to branch subscription-topic-owner-fencing
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ed418844851 Implement subscription topic owner lease renewal
add 65cd197600d Degraded the UT logs
add 623532a23a1 Pipe: Fixed the test for #17770 (#17779)
add 329fa102a49 Pipe: Removed the useless ban on async file transfer for
non realtime-first pipes
add 152ee1daeed Fixed the Chinese logger of schema (#17721)
add 7e488ffcaca modify the antlr syntax to adapt the calc-point project
(#17783)
add 209a3a77703 Load: Stablized the IoTDBLoadTsFileWithModIT
add 312d3841a97 Excluded system & audit from COUNT TIMESERIES and included
views (#17703)
add 4e3bb11312a Fix source scan race in plan visitor test (#17786)
add 2ba29144921 Pipe: Mask sensitive attributes in sink subtask display
strings (#17737)
add 93438bf34ba fix: supply the key word in antlr module (#17789)
add 33c3ef7196b Pipe: Harden legacy pipe file transfer validation and
access checks (#17741)
add b616502aec0 Pipe Log: Added the remaining chinese logs & Further
reduced the repeatable logs (#17700)
add a2368b2955f Fix C++ client reading FLOAT inference columns declared as
DOUBLE (#17759)
add 084837923f7 Update IoTDBLegacyPipeReceiverSecurityIT.java (#17795)
(#17796)
add 958ce45b137 Fix repeated RPC dispatch reusing a released
FragmentInstanceContext (NPE) (#17794)
add a565a068253 Added flags to mark whether a device has device
descendants to optimize query like select xx from xxx.** (#17672)
add 44d4f6d962e Optimized write performace by reducing separators (#17670)
add 89730b14397 Optimized the overall performance of IoTDB & Fixed the NPE
in LimitOperatorTest (#17664)
add b614d6d16b5 Pipe: Fixed the bug that drop pipe may stuck when
disruptor is interrupted or ring buffer full (#17673)
add 29d0d51dc74 Fix CQ recovery gap and stale callback contamination
(#17734)
add 7a8079d1524 Table: Ignore null attribute values in insert (#17790)
add d9fdf0c6655 C++ client: add thread-safe SessionPool, enable RPC
compression, and harden buffers (#17800)
add f4d7ec4a8ae Fix alter pipe password check after restart for write-back
sink. (#17771)
add f5d2cd82177 Pipe IT: Stabilize leader stop test (#17809)
add 99f0af16c89 Fix flaky space quota IT (#17812)
add 011bdecb77c Fix WAL search index freezing (#17811)
add a4206813a06 Revert "Fix CQ recovery gap and stale callback
contamination (#17734)" (#17827)
add a077c04d57e Reapply "Fix CQ recovery gap and stale callback
contamination (#17734)" (#17827) (#17828)
add 2a6f35c6c09 Ratis CI: Fixed the ratis CI port clash & Optimized the
logs to avoid printing JVM crash (#17675)
add 59b79efb17e Pipe: account page decode memory in scan parser (#17807)
add f44d9b7bf3b Fix count and show timeseries follow-up (#17804)
add b46c58b324d Fix pipe tsfile receiver database handling (#17815)
add c818b289e79 Feature/iotconsensus snap multi dir (#16811)
add e2322e9e9e5 [AINode] Remove Chronos2 DataLoader pin_memory option
(#17822)
add 709145cc00b Fixed UDF jar metadata handling in `UDFInfo` when multiple
UDFs share the same jar (#17732)
add 2fd70b9d1b1 Fix flaky stamped lock test (#17832)
add 66d0c07bb09 Remove useless ProjectNode after SortElimination (#17806)
add dacbf9268db Optimize InsertTabletStatement tablet conversion (#17805)
add 99bf6d4c6b1 Add statistical type aggregate functions, including
autocorrelation, skewness, and linear regression (#17292)
add 187e4547c0c Fix table delete with renamed time column (#17841)
add 1d8b23a8e54 Ignore non-exist object folder when removing a region
(#17840)
add 543e03e9fa2 Fix account unlock propagation for pipe password checks
(#17814)
add eaa5bcb012e Fix pipe permission retry and table parser progress
(#17844)
add 373af669686 Set keepSameDiskWhenLoadingSnapshot default to true
(#17845)
add 16d3669edb1 Fix operator tests for transient null TsBlocks (#17838)
add 594fb879c4d Support table-less SELECT queries without FROM clause
(#17437)
add 63dfac842f7 Fix window function state reset across batches (#17813)
add d182c87a401 Fix PBTree schema cache release after pre-delete (#17834)
add d563cd046e2 Improve query modification loading memory control (#17788)
add eb4409d8b02 Add threat model + security-model discoverability
(AGENTS.md -> SECURITY.md -> THREAT_MODEL.md) (#17823)
add 90055d55b6e Fix pipe receiver type conversion load path (#17849)
add 4747d5f243f Optimize local load TsFile piece dispatch (#17851)
add d09785eaaba Support sink config key for pipe request slicing (#17858)
add 4d55d5121df Optimize load partition routing (#17863)
add 6532d297bca Optimize pipe event batching and listener stop (#17864)
add ab887eb98ea Fix relational delete node serialization (#17867)
add 3d98ea5fd78 Fix Windows path segment validation (#17868)
add faba002feb9 Refactor/cpp client sdk (#17801)
add 0987f6a9a48 Subscription: implement IoTConsensus-based subscription
(#17238)
add ffddfde81ec [IOTDB-17798] Implement table model NEXT fill (#17810)
add a437cd469b7 Add SLIDE parameter support to CAPACITY table-valued
function (#17456)
add c032ea00049 Fix Windows C++ client README commands (#17881)
add c3e74a2a68e Fix AddConfigNode retry idempotency (#17874)
add 07b9cb086a9 Fix empty snapshot loading and region cleanup (#17880)
add df69ece42cb Merge origin/master into subscription-topic-owner-fencing
No new revisions were added by this update.
Summary of changes:
.github/scripts/package-client-cpp-manylinux228.sh | 140 +
.github/workflows/client-cpp-package.yml | 465 +-
.github/workflows/cluster-it-1c1d.yml | 8 +
.github/workflows/cluster-it-1c1d1a.yml | 8 +
.github/workflows/cluster-it-1c3d.yml | 8 +
.github/workflows/compile-check.yml | 8 +
.github/workflows/dependency-check.yml | 8 +
.github/workflows/multi-language-client.yml | 66 +-
.github/workflows/pipe-it.yml | 8 +
.github/workflows/sonar-codecov.yml | 8 +
.github/workflows/table-cluster-it-1c1d.yml | 8 +
.github/workflows/table-cluster-it-1c3d.yml | 8 +
.github/workflows/unit-test.yml | 8 +
.gitignore | 10 +-
CLAUDE.md | 9 +-
CONTRIBUTING.md | 3 -
SECURITY.md | 29 +
THREAT_MODEL.md | 208 +
distribution/pom.xml | 66 +-
distribution/src/assembly/client-cpp.xml | 6 +-
example/client-c-example/README.md | 68 -
example/client-c-example/pom.xml | 150 -
example/client-c-example/src/table_example.c | 152 -
example/client-c-example/src/tree_example.c | 114 -
example/client-cpp-example/pom.xml | 200 -
example/client-cpp-example/src/CMakeLists.txt | 151 -
example/pom.xml | 9 -
.../ConsensusSubscriptionWalFileAnalyzer.java | 528 +
.../iotdb/ConsensusSubscriptionSessionExample.java | 198 +
...sensusTableModelSubscriptionSessionExample.java | 201 +
.../it/env/cluster/config/MppCommonConfig.java | 2 +-
.../constant/BuiltinAggregationFunctionEnum.java | 9 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 28 +
.../iotdb/ainode/it/AINodeSharedClusterIT.java | 83 +
.../iotdb/db/it/IoTDBLoadTsFileWithModIT.java | 22 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 18 +-
.../aggregation/IoTDBStatisticalAggregationIT.java | 590 +
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 30 +-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 7 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 28 +
.../regionscan/IoTDBActiveSchemaQueryIT.java | 47 +
.../pipe/it/dual/TypeConversionSemanticCase.java | 315 +
.../manual/enhanced/IoTDBPipeClusterIT.java | 28 +-
.../IoTDBPipeTypeConversionSemanticIT.java | 255 +
.../auto/enhanced/IoTDBPipeClusterIT.java | 28 +-
.../IoTDBPipeTypeConversionSemanticIT.java | 259 +
.../treemodel/manual/IoTDBPipePermissionIT.java | 1 +
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 113 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 21 +
.../relational/it/db/it/IoTDBInsertTableIT.java | 35 +
.../db/it/IoTDBWindowFunctionBatchedResultIT.java | 94 +
.../relational/it/db/it/IoTDBWindowTVFIT.java | 101 +
.../it/query/recent/IoTDBComplexQueryIT.java | 28 +
.../it/query/recent/IoTDBFillTableIT.java | 155 +
.../it/query/recent/IoTDBTableAggregationIT.java | 225 +
.../it/schema/IoTDBAlterColumnTypeIT.java | 9 +-
.../AbstractSubscriptionConsensusLocalIT.java | 55 +
.../local/ConsensusSubscriptionITSupport.java | 670 +
.../local/IoTDBConsensusSubscriptionBasicIT.java | 141 +
.../IoTDBConsensusSubscriptionConsumerGroupIT.java | 156 +
.../local/IoTDBConsensusSubscriptionDataIT.java | 173 +
.../IoTDBConsensusSubscriptionRecoveryIT.java | 98 +
.../local/IoTDBConsensusSubscriptionSeekIT.java | 202 +
.../ConsensusSubscriptionTableITSupport.java | 516 +
.../IoTDBConsensusSubscriptionBasicTableIT.java | 88 +
.../IoTDBConsensusSubscriptionDataTableIT.java | 137 +
.../IoTDBConsensusSubscriptionFilterTableIT.java | 272 +
...usSubscriptionSubscribeBeforeRegionTableIT.java | 71 +
.../IoTDBEncryptedPasswordPullConsumerIT.java | 5 +-
.../api/customizer/parameter/PipeParameters.java | 1 +
iotdb-client/client-cpp/CMakeLists.txt | 305 +
iotdb-client/client-cpp/README.md | 613 +-
iotdb-client/client-cpp/README_zh.md | 277 +
iotdb-client/client-cpp/cmake/CheckCxx11Abi.cmake | 59 +
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 | 278 +
.../client-cpp/cmake/GenerateThriftSources.cmake | 126 +
.../client-cpp/cmake/iotdb-session-config.cmake.in | 56 +
iotdb-client/client-cpp/cmake/iotdb-session.pc.in | 26 +
.../examples}/AlignedTimeseriesSessionExample.cpp | 25 +-
iotdb-client/client-cpp/examples/CMakeLists.txt | 187 +
.../client-cpp/examples}/MultiSvrNodeClient.cpp | 8 +-
iotdb-client/client-cpp/examples/README.md | 260 +
iotdb-client/client-cpp/examples/README_zh.md | 253 +
.../client-cpp/examples}/SessionExample.cpp | 33 +-
.../examples}/TableModelSessionExample.cpp | 0
iotdb-client/client-cpp/examples/table_example.c | 153 +
iotdb-client/client-cpp/examples/tree_example.c | 114 +
iotdb-client/client-cpp/pom.xml | 370 +-
.../client-cpp/src/assembly/client-cpp.xml | 69 +-
.../package-metadata/third_party/DEPENDENCIES.md | 42 +-
.../src/{main => include}/AbstractSessionBuilder.h | 10 +-
.../client-cpp/src/{main => include}/Column.h | 5 +
.../src/{main => include}/ColumnDecoder.h | 0
.../client-cpp/src/{main => include}/Common.h | 146 +-
iotdb-client/client-cpp/src/include/Date.h | 74 +
.../client-cpp/src/{main => include}/DeviceID.h | 0
.../client-cpp/src/include/Endpoint.h | 30 +-
.../client-cpp/src/include/Export.h | 22 +-
iotdb-client/client-cpp/src/include/Optional.h | 77 +
.../client-cpp/src/{main => include}/Session.h | 354 +-
.../src/{main => include}/SessionBuilder.h | 0
.../client-cpp/src/{main => include}/SessionC.h | 0
.../client-cpp/src/include/SessionConfig.h | 23 +-
.../client-cpp/src/include/SessionDataSet.h | 124 +
iotdb-client/client-cpp/src/include/SessionPool.h | 392 +
.../client-cpp/src/include/Status.h | 20 +-
.../src/{main => include}/TableSession.h | 0
.../src/{main => include}/TableSessionBuilder.h | 0
.../client-cpp/src/{main => include}/TsBlock.h | 0
iotdb-client/client-cpp/src/main/CMakeLists.txt | 90 -
.../client-cpp/src/main/SessionDataSet.cpp | 25 +-
iotdb-client/client-cpp/src/main/SessionDataSet.h | 124 -
.../src/{main => rpc}/IoTDBRpcDataSet.cpp | 74 +-
.../client-cpp/src/{main => rpc}/IoTDBRpcDataSet.h | 51 +-
.../client-cpp/src/{main => rpc}/NodesSupplier.cpp | 11 +-
.../client-cpp/src/{main => rpc}/NodesSupplier.h | 9 +-
iotdb-client/client-cpp/src/rpc/RpcCommon.cpp | 214 +
iotdb-client/client-cpp/src/rpc/RpcCommon.h | 81 +
.../src/{main => rpc}/SessionConnection.cpp | 34 +-
.../src/{main => rpc}/SessionConnection.h | 20 +-
.../client-cpp/src/rpc/SessionDataSetFactory.h | 42 +
iotdb-client/client-cpp/src/rpc/SessionImpl.h | 231 +
.../src/{main => rpc}/ThriftConnection.cpp | 16 +-
.../src/{main => rpc}/ThriftConnection.h | 4 +-
iotdb-client/client-cpp/src/rpc/ThriftConvert.cpp | 61 +
.../client-cpp/src/rpc/ThriftConvert.h | 28 +-
.../client-cpp/src/{main => session}/Column.cpp | 20 +
.../src/{main => session}/ColumnDecoder.cpp | 0
.../client-cpp/src/{main => session}/Common.cpp | 226 +-
iotdb-client/client-cpp/src/session/Date.cpp | 63 +
.../client-cpp/src/{main => session}/Session.cpp | 490 +-
.../client-cpp/src/{main => session}/SessionC.cpp | 0
.../client-cpp/src/session/SessionDataSet.cpp | 320 +
.../client-cpp/src/session/SessionPool.cpp | 281 +
.../src/{main => session}/TableSession.cpp | 0
.../client-cpp/src/{main => session}/TsBlock.cpp | 0
iotdb-client/client-cpp/src/test/CMakeLists.txt | 152 -
iotdb-client/client-cpp/src/test/catch2/catch.hpp | 17974 -------------------
iotdb-client/client-cpp/test/CMakeLists.txt | 104 +
iotdb-client/client-cpp/test/catch2/.gitignore | 4 +
.../client-cpp/{src => }/test/cpp/sessionCIT.cpp | 0
.../{src => }/test/cpp/sessionCRelationalIT.cpp | 0
.../client-cpp/{src => }/test/cpp/sessionIT.cpp | 164 +-
.../{src => }/test/cpp/sessionRelationalIT.cpp | 7 +-
iotdb-client/client-cpp/{src => }/test/main.cpp | 0
.../client-cpp/{src => }/test/main_Relational.cpp | 0
iotdb-client/client-cpp/{src => }/test/main_c.cpp | 0
.../{src => }/test/main_c_Relational.cpp | 0
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 +
.../org/apache/iotdb/isession/SessionDataSet.java | 27 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 47 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 14 +-
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 13 +-
.../iotdb/session/AbstractSessionBuilder.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 188 +-
.../apache/iotdb/session/SessionConnection.java | 4 +
iotdb-client/subscription/pom.xml | 5 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 89 +-
.../rpc/subscription/config/TopicConstant.java | 11 +
.../subscription/payload/poll/RegionProgress.java | 85 +
.../payload/poll/SubscriptionCommitContext.java | 222 +-
.../payload/poll/SubscriptionPollRequest.java | 49 +-
.../payload/poll/SubscriptionPollResponse.java | 10 +-
.../payload/poll/SubscriptionPollResponseType.java | 7 +
.../subscription/payload/poll/TopicProgress.java | 94 +
.../payload/poll/WatermarkPayload.java | 82 +
.../rpc/subscription/payload/poll/WriterId.java | 77 +
.../subscription/payload/poll/WriterProgress.java | 77 +
.../payload/request/PipeSubscribeRequestType.java | 1 +
.../payload/request/SubscriptionHeartbeatReq.java | 128 +
.../payload/request/SubscriptionSeekReq.java | 164 +
.../payload/response/PipeSubscribeCommitResp.java | 85 +-
.../PipeSubscribeSeekResp.java} | 47 +-
.../SubscriptionTableSessionBuilder.java | 5 +
.../SubscriptionTreeSessionBuilder.java | 5 +
.../consumer/ISubscriptionTablePullConsumer.java | 25 +
.../consumer/ISubscriptionTreePullConsumer.java | 25 +
.../base/AbstractSubscriptionConsumer.java | 629 +-
.../base/AbstractSubscriptionProvider.java | 161 +-
.../base/AbstractSubscriptionProviders.java | 5 +-
.../base/AbstractSubscriptionPullConsumer.java | 411 +-
.../base/AbstractSubscriptionPushConsumer.java | 16 +
.../consumer/base/ColumnAlignProcessor.java | 186 +
.../base/SubscriptionMessageProcessor.java | 82 +
.../consumer/base/WatermarkProcessor.java | 335 +
.../consumer/table/SubscriptionTableProvider.java | 7 +-
.../table/SubscriptionTablePullConsumer.java | 27 +
.../consumer/tree/SubscriptionTreeProvider.java | 7 +-
.../tree/SubscriptionTreePullConsumer.java | 27 +
.../session/subscription/payload/PollResult.java | 67 +
.../subscription/payload/SubscriptionMessage.java | 57 +-
.../payload/SubscriptionMessageType.java | 1 +
.../poll/SubscriptionCommitContextTest.java | 148 +
.../payload/poll/SubscriptionPollRequestTest.java | 62 +
.../payload/request/SubscriptionSeekReqTest.java | 53 +
.../consumer/base/ColumnAlignProcessorTest.java | 255 +
.../consumer/base/WatermarkProcessorTest.java | 224 +
.../request_scheduler/basic_request_scheduler.py | 19 +-
.../core/model/chronos2/pipeline_chronos2.py | 1 -
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 3 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 27 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 12 +
.../src/main/codegen/templates/nextFill.ftl | 101 +
.../aggregation/CentralMomentAccumulator.java | 302 +
.../aggregation/CorrelationAccumulator.java | 261 +
.../aggregation/CovarianceAccumulator.java | 250 +
.../aggregation/RegressionAccumulator.java | 265 +
.../operator/process/TableNextFillOperator.java | 81 +
.../process/TableNextFillWithGroupOperator.java | 165 +
.../operator/process/fill/next/NextFill.java | 182 +
.../process/window/TableWindowOperator.java | 2 +-
.../window/partition/PartitionExecutor.java | 11 +-
.../relational/aggregation/AccumulatorFactory.java | 69 +
.../aggregation/TableCentralMomentAccumulator.java | 298 +
.../aggregation/TableCorrelationAccumulator.java | 277 +
.../aggregation/TableCovarianceAccumulator.java | 272 +
.../aggregation/TableRegressionAccumulator.java | 283 +
.../grouped/GroupedCentralMomentAccumulator.java | 270 +
.../grouped/GroupedCorrelationAccumulator.java | 246 +
.../grouped/GroupedCovarianceAccumulator.java | 242 +
.../grouped/GroupedRegressionAccumulator.java | 263 +
.../calc/plan/planner/CommonOperatorUtils.java | 105 +-
.../calc/plan/planner/TableOperatorGenerator.java | 65 +-
.../planner/memory/MemoryReservationManager.java | 8 +
.../iotdb/calc/utils/constant/SqlConstant.java | 7 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 4 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 4 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 14 +-
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 13 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 10 +
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 16 +-
.../ConsumerGroupPushMetaRPCHandler.java | 11 +-
...dler.java => PullCommitProgressRPCHandler.java} | 28 +-
.../rpc/subscription/TopicPushMetaRPCHandler.java | 11 +-
.../consensus/request/ConfigPhysicalPlan.java | 6 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
.../request/ConfigPhysicalPlanVisitor.java | 12 +
.../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 +-
.../CommitProgressHandleMetaChangePlan.java | 78 +
.../iotdb/confignode/manager/ConfigManager.java | 77 +
.../iotdb/confignode/manager/ProcedureManager.java | 34 +
.../manager/consensus/ConsensusManager.java | 23 +-
.../iotdb/confignode/manager/cq/CQManager.java | 102 +-
.../confignode/manager/cq/CQScheduleTask.java | 58 +-
.../iotdb/confignode/manager/load/LoadManager.java | 2 +
.../manager/subscription/SubscriptionManager.java | 15 +
.../subscription/SubscriptionMetaSyncer.java | 7 +
.../runtime/SubscriptionLeaderChangeHandler.java | 43 +
.../runtime/SubscriptionRuntimeCoordinator.java | 160 +
.../iotdb/confignode/persistence/UDFInfo.java | 54 +-
.../confignode/persistence/auth/AuthorInfo.java | 6 +-
.../persistence/auth/AuthorPlanExecutor.java | 12 +
.../iotdb/confignode/persistence/cq/CQInfo.java | 76 +-
.../persistence/executor/ConfigPlanExecutor.java | 8 +-
.../persistence/subscription/SubscriptionInfo.java | 262 +
.../procedure/env/ConfigNodeProcedureEnv.java | 86 +
.../procedure/impl/cq/CreateCQProcedure.java | 80 +-
.../AbstractOperateSubscriptionProcedure.java | 1 +
.../impl/subscription/SubscriptionOperation.java | 2 +
.../runtime/CommitProgressSyncProcedure.java | 316 +
.../SubscriptionHandleLeaderChangeProcedure.java | 444 +
.../subscription/CreateSubscriptionProcedure.java | 85 +-
.../subscription/DropSubscriptionProcedure.java | 14 +
.../impl/sync/AuthOperationProcedure.java | 6 +
.../procedure/store/ProcedureFactory.java | 12 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 16 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../apache/iotdb/confignode/cq/CQManagerTest.java | 107 +
.../manager/consensus/ConsensusManagerTest.java | 116 +
.../iotdb/confignode/persistence/CQInfoTest.java | 64 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 92 +-
.../persistence/auth/AuthorPlanExecutorTest.java | 80 +
.../SubscriptionInfoTopicValidationTest.java | 220 +
.../procedure/impl/CreateCQProcedureTest.java | 26 +
.../impl/cq/CreateCQProcedureRecoveryTest.java | 117 +
.../DropSubscriptionProcedureTest.java | 3 +
.../impl/sync/AuthOperationProcedureTest.java | 56 +
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 47 +
.../DeserializedBatchIndexedConsensusRequest.java | 29 +-
.../common/request/IndexedConsensusRequest.java | 66 +-
.../iotdb/consensus/config/ConsensusConfig.java | 15 +
.../iotdb/consensus/config/IoTConsensusConfig.java | 33 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 68 +-
.../consensus/iot/IoTConsensusServerImpl.java | 433 +-
.../iot/SubscriptionWalRetentionPolicy.java} | 39 +-
.../org/apache/iotdb/consensus/iot/WriterMeta.java | 112 +
.../consensus/iot/WriterSafeFrontierTracker.java | 145 +
.../consensus/iot/client/DispatchLogHandler.java | 45 +-
.../consensus/iot/log/ConsensusReqReader.java | 90 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 82 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 4 +
.../service/IoTConsensusRPCServiceProcessor.java | 31 +
.../subscription/SubscriptionQueueRegistry.java | 124 +
.../SubscriptionWalRetentionCalculator.java | 126 +
.../apache/iotdb/consensus/iot/ReplicateTest.java | 27 +
.../apache/iotdb/consensus/iot/StabilityTest.java | 8 +
.../apache/iotdb/consensus/iot/WriterMetaTest.java | 76 +
.../iot/WriterSafeFrontierTrackerTest.java | 56 +
.../consensus/iot/util/FakeConsensusReqReader.java | 20 +
.../iotdb/consensus/iot/util/TestStateMachine.java | 8 +-
.../iotdb/consensus/ratis/RecoverReadTest.java | 9 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 70 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 16 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 21 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 16 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 74 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 10 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 35 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 7 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 13 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 11 +
.../db/consensus/DataRegionConsensusImpl.java | 6 +
.../dataregion/DataExecutionVisitor.java | 14 +-
.../dataregion/DataRegionStateMachine.java | 3 +
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 22 +-
.../task/execution/PipeSubtaskExecutorManager.java | 24 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 54 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 10 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 2 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 55 +-
.../parser/scan/MemoryControlledChunkReader.java | 76 +
.../parser/scan/SinglePageWholeChunkReader.java | 193 +-
.../scan/TsFileInsertionEventScanParser.java | 53 +-
.../table/TsFileInsertionEventTableParser.java | 197 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 10 +-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 6 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 40 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 104 +-
.../visitor/PipeStatementExceptionVisitor.java | 7 +
.../client/IoTDBDataNodeAsyncClientManager.java | 28 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 22 +-
.../batch/PipeTransferBatchReqBuilder.java | 43 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 5 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 103 +-
.../handler/IoTConsensusV2DeleteEventHandler.java | 16 +-
.../IoTConsensusV2TabletBatchEventHandler.java | 20 +-
.../IoTConsensusV2TabletInsertionEventHandler.java | 17 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 18 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 29 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 40 +-
.../handler/PipeTransferTrackableHandler.java | 21 +-
.../async/handler/PipeTransferTsFileHandler.java | 23 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 5 +-
.../sink/protocol/writeback/WriteBackSink.java | 21 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 6 +-
.../PipeRealtimeDataRegionHybridSource.java | 4 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 5 +-
.../realtime/PipeRealtimeDataRegionSource.java | 8 +-
.../PipeRealtimeDataRegionTsFileSource.java | 5 +-
.../realtime/assigner/DisruptorQueue.java | 19 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 41 +-
.../realtime/disruptor/BatchEventProcessor.java | 11 +-
.../realtime/disruptor/MultiProducerSequencer.java | 21 +
.../dataregion/realtime/disruptor/RingBuffer.java | 22 +-
.../listener/PipeInsertionDataNodeListener.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 8 +
.../iotdb/db/protocol/session/SessionManager.java | 6 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 63 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 87 +-
.../db/queryengine/common/TimeseriesContext.java | 294 +-
.../execution/aggregation/AccumulatorFactory.java | 39 +
.../SlidingWindowAggregatorFactory.java | 7 +
.../execution/executor/RegionReadExecutor.java | 23 +-
.../fragment/FragmentInstanceContext.java | 90 +-
.../fragment/FragmentInstanceManager.java | 79 +-
.../execution/fragment/QueryContext.java | 20 +-
.../fragment/QueryModificationLoader.java | 314 +
.../schema/CountGroupByLevelScanOperator.java | 15 +-
.../operator/schema/SchemaCountOperator.java | 4 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../schema/source/SchemaSourceFactory.java | 18 +-
.../schema/source/TimeSeriesSchemaSource.java | 20 +
.../source/ActiveTimeSeriesRegionScanOperator.java | 92 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 14 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 189 +-
.../plan/analyze/ClusterPartitionFetcher.java | 38 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 12 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 31 +-
.../config/executor/ClusterConfigTaskExecutor.java | 29 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 19 +-
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../plan/planner/LogicalPlanVisitor.java | 8 +-
.../plan/planner/OperatorTreeGenerator.java | 52 +-
.../plan/planner/distribution/SourceRewriter.java | 10 +-
.../memory/FakedMemoryReservationManager.java | 3 +
.../NotThreadSafeMemoryReservationManager.java | 9 +
.../memory/ThreadSafeMemoryReservationManager.java | 5 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 15 +
.../plan/node/load/LoadSingleTsFileNode.java | 36 +-
.../metadata/read/LevelTimeSeriesCountNode.java | 48 +-
.../node/metadata/read/TimeSeriesCountNode.java | 49 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 55 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 44 +
.../plan/node/source/TimeseriesRegionScanNode.java | 7 +
.../planner/plan/node/write/DeleteDataNode.java | 17 +-
.../plan/node/write/InsertMultiTabletsNode.java | 24 +
.../plan/planner/plan/node/write/InsertNode.java | 13 +
.../planner/plan/node/write/InsertRowNode.java | 12 +-
.../planner/plan/node/write/InsertRowsNode.java | 34 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 21 +
.../planner/plan/node/write/InsertTabletNode.java | 57 +-
.../plan/planner/plan/node/write/ObjectNode.java | 10 +-
.../plan/node/write/RelationalDeleteDataNode.java | 36 +-
.../plan/node/write/RelationalInsertRowNode.java | 6 +-
.../plan/node/write/RelationalInsertRowsNode.java | 7 +-
.../node/write/RelationalInsertTabletNode.java | 14 +-
.../plan/planner/plan/node/write/SearchNode.java | 114 +
.../plan/parameter/AggregationDescriptor.java | 21 +
.../plan/relational/analyzer/Analysis.java | 26 +
.../relational/analyzer/StatementAnalyzer.java | 22 +
.../relational/metadata/TableMetadataImpl.java | 46 +
.../fetcher/TableDeviceSchemaValidator.java | 44 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 6 +-
.../plan/relational/planner/PredicateUtils.java | 28 +-
.../plan/relational/planner/QueryPlanner.java | 34 +-
.../planner/iterative/rule/PruneFillColumns.java | 5 +
.../iterative/rule/PruneTableScanColumns.java | 54 +-
.../PushLimitOffsetIntoTableScan.java | 7 +
.../planner/optimizations/SortElimination.java | 46 +
.../optimizations/UnaliasSymbolReferences.java | 46 +
.../security/TreeAccessCheckVisitor.java | 99 +-
.../plan/relational/sql/ast/InsertTablet.java | 17 +-
.../plan/relational/sql/parser/AstBuilder.java | 38 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 15 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 8 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 88 +-
.../plan/statement/crud/InsertTabletStatement.java | 118 +-
.../plan/statement/crud/LoadTsFileStatement.java | 25 +
.../plan/statement/metadata/CountStatement.java | 9 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 9 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 81 +-
.../mtree/impl/mem/mnode/IMemMNode.java | 23 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 21 +-
.../impl/mem/mnode/impl/AboveDatabaseMNode.java | 10 -
.../mtree/impl/mem/mnode/impl/DatabaseMNode.java | 10 -
.../impl/mem/mnode/impl/MeasurementMNode.java | 10 -
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 83 +-
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 17 +
.../mtree/impl/pbtree/mnode/ICachedMNode.java | 19 +
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 40 +-
.../schemaregion/mtree/traverser/Traverser.java | 103 +
.../traverser/basic/MeasurementTraverser.java | 5 +
.../iotdb/db/storageengine/StorageEngine.java | 16 +-
.../db/storageengine/dataregion/DataRegion.java | 165 +-
.../execute/task/InnerSpaceCompactionTask.java | 2 +-
.../impl/SizeTieredCompactionSelector.java | 2 +-
.../dataregion/modification/DeletionPredicate.java | 9 +-
.../dataregion/modification/IDPredicate.java | 13 +-
.../dataregion/modification/ModEntry.java | 12 +-
.../dataregion/modification/TreeDeletionEntry.java | 11 +-
.../dataregion/modification/v1/Deletion.java | 10 +-
.../filescan/impl/ClosedFileScanHandleImpl.java | 35 +-
.../filescan/impl/UnclosedFileScanHandleImpl.java | 83 +-
.../dataregion/snapshot/SnapshotLoader.java | 144 +-
.../dataregion/tsfile/TsFileManager.java | 21 +-
.../dataregion/tsfile/TsFileResource.java | 18 +-
.../tsfile/generator/TsFileNameGenerator.java | 4 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 2 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 31 +-
.../allocation/AbstractNodeAllocationStrategy.java | 6 +-
.../dataregion/wal/buffer/WALBuffer.java | 36 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 52 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 3 +-
.../dataregion/wal/io/ProgressWALReader.java | 85 +
.../dataregion/wal/io/WALByteBufReader.java | 73 +
.../dataregion/wal/io/WALFileVersion.java | 5 +-
.../dataregion/wal/io/WALInputStream.java | 8 +-
.../dataregion/wal/io/WALMetaData.java | 242 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 22 +-
.../dataregion/wal/node/WALFakeNode.java | 30 +
.../storageengine/dataregion/wal/node/WALNode.java | 130 +-
.../dataregion/wal/utils/WALFileUtils.java | 211 +
.../dataregion/wal/utils/WALWriteUtils.java | 16 +-
.../db/storageengine/load/LoadTsFileManager.java | 6 +-
.../storageengine/load/disk/ILoadDiskSelector.java | 2 +-
.../InheritSystemMultiDisksStrategySelector.java | 2 +-
.../db/storageengine/load/disk/MinIOSelector.java | 2 +-
.../load/splitter/AlignedChunkData.java | 9 +
.../load/splitter/NonAlignedChunkData.java | 16 +
.../iotdb/db/storageengine/load/util/LoadUtil.java | 6 +-
.../db/storageengine/rescon/disk/TierManager.java | 11 +-
.../agent/SubscriptionBrokerAgent.java | 734 +-
.../agent/SubscriptionConsumerAgent.java | 56 +-
.../agent/SubscriptionRuntimeAgent.java | 7 +-
.../subscription/agent/SubscriptionTopicAgent.java | 16 +-
.../broker/ConsensusSubscriptionBroker.java | 836 +
.../subscription/broker/ISubscriptionBroker.java | 93 +
.../db/subscription/broker/SubscriptionBroker.java | 64 +-
.../broker/SubscriptionPrefetchingQueue.java | 69 +
.../consensus/ConsensusLogToTabletConverter.java | 799 +
.../consensus/ConsensusPrefetchingQueue.java | 3443 ++++
.../consensus/ConsensusRegionRuntimeState.java | 86 +
.../ConsensusSubscriptionCommitManager.java | 1673 ++
.../ConsensusSubscriptionSetupHandler.java | 694 +
.../broker/consensus/PrefetchRoundResult.java | 62 +
.../broker/consensus/ProgressWALIterator.java | 517 +
.../consensus/SubscriptionConsensusProgress.java | 200 +
.../db/subscription/event/SubscriptionEvent.java | 20 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 246 +
.../subscription/metric/SubscriptionMetrics.java | 2 +
.../receiver/SubscriptionReceiverV1.java | 288 +-
.../ConsensusSubscriptionPrefetchExecutor.java | 160 +
...nsensusSubscriptionPrefetchExecutorManager.java | 74 +
.../task/subtask/ConsensusPrefetchSubtask.java | 244 +
.../task/subtask/SubscriptionSinkSubtask.java | 27 +-
.../subtask/SubscriptionSinkSubtaskLifeCycle.java | 11 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 57 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 171 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 49 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 58 +-
.../org/apache/iotdb/db/auth/TreeAccessTest.java | 133 +
.../strategy/DirectoryStrategyTest.java | 10 +-
.../i18n/DataNodeSchemaMessagesZhFormatTest.java | 99 +
.../cache/TreeDeviceSchemaCacheManagerTest.java | 49 +
.../mtree/lock/StampedWriterPreferredLockTest.java | 42 +-
.../schemaRegion/SchemaRegionBasicTest.java | 22 +
.../schemaRegion/SchemaStatisticsTest.java | 61 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 346 +-
.../plugin/TwoStageCountProcessorTest.java} | 41 +-
.../receiver/PipeStatementTsStatusVisitorTest.java | 14 +
.../legacy/IoTDBLegacyPipeReceiverAgentTest.java | 122 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 143 +
.../realtime/disruptor/DisruptorShutdownTest.java | 56 +
.../execution/executor/RegionReadExecutorTest.java | 46 +
.../fragment/QueryModificationLoaderTest.java | 358 +
.../AlignedSeriesAggregationScanOperatorTest.java | 33 +-
.../operator/DeviceViewIntoOperatorTest.java | 16 +-
.../execution/operator/FillOperatorTest.java | 7 +-
.../operator/HorizontallyConcatOperatorTest.java | 3 +-
.../execution/operator/LimitOperatorTest.java | 3 +
.../operator/MergeTreeSortOperatorTest.java | 3 +-
.../execution/operator/OffsetOperatorTest.java | 20 +-
.../execution/operator/OperatorTestUtils.java | 55 +
.../SeriesAggregationScanOperatorTest.java | 33 +-
.../execution/operator/SeriesScanOperatorTest.java | 3 +-
.../execution/operator/TreeIntoOperatorTest.java | 6 +-
.../operator/TreeLinearFillOperatorTest.java | 5 +-
.../operator/UpdateLastCacheOperatorTest.java | 7 +-
.../operator/process/fill/NextFillTest.java | 299 +
.../operator/schema/SchemaCountOperatorTest.java | 113 +
.../schema/source/TimeSeriesSchemaSourceTest.java | 183 +
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 55 +
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 69 +-
.../distribution/RegionScanPlanningTest.java | 81 +
.../logical/RegionScanLogicalPlannerTest.java | 47 +
.../metadata/read/SchemaCountNodeSerdeTest.java | 8 +-
.../node/write/DeleteDataNodeSerdeTest.java | 28 +
.../planner/node/write/InsertRowNodeSerdeTest.java | 114 +-
.../node/write/InsertRowsNodeSerdeTest.java | 141 +
.../node/write/InsertTabletNodeSerdeTest.java | 91 +-
.../IPlanVisitorInheritanceConstraintTest.java | 54 +-
.../node/write/RelationalDeleteDataNodeTest.java | 9 +-
.../plan/relational/analyzer/SortTest.java | 44 +
.../fetcher/TableDeviceSchemaValidatorTest.java | 29 +-
.../relational/planner/NextFillNodeSerdeTest.java | 112 +
.../relational/planner/PredicateUtilsTest.java | 13 +
.../plan/relational/sql/ast/InsertTabletTest.java | 69 +
.../relational/sql/parser/FillStatementTest.java | 68 +
.../load/LoadTsFileDispatcherImplTest.java | 98 +
.../mtree/impl/mem/MTreeBelowSGMemoryImplTest.java | 281 +
.../impl/pbtree/MTreeBelowSGCachedImplTest.java | 217 +
.../iotdb/db/storageengine/dataregion/TTLTest.java | 4 +-
.../BatchedCompactionWithTsFileSplitterTest.java | 16 +-
...actionWithReadPointPerformerValidationTest.java | 4 +-
.../utils/CompactionFileGeneratorUtils.java | 2 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 7 +-
.../modification/TableDeletionEntryTest.java | 8 +-
.../modification/TreeDeletionEntryTest.java | 5 +-
.../dataregion/modification/v1/DeletionTest.java | 52 +
.../dataregion/snapshot/IoTDBSnapshotTest.java | 141 +-
.../wal/compression/WALCompressionTest.java | 37 +-
.../dataregion/wal/io/ProgressWALReaderTest.java | 93 +
.../dataregion/wal/io/WALFileTest.java | 58 +
.../wal/io/WALMetaDataV3CompatibilityTest.java | 185 +
.../wal/node/ConsensusReqReaderTest.java | 17 +
.../dataregion/wal/node/WALNodeTest.java | 66 +
.../wal/node/WALNodeWaitForRollFileTest.java | 29 +-
.../dataregion/wal/utils/WALFileUtilsTest.java | 74 +
.../load/splitter/ChunkDataDirectWriteTest.java | 91 +
.../rescon/disk/FolderManagerTest.java | 5 +-
.../ConsensusLogToTabletConverterTest.java | 208 +
.../ConsensusSubscriptionCommitStateTest.java | 314 +
.../broker/consensus/ProgressWALIteratorTest.java | 323 +
.../resources/conf/iotdb-system.properties | 1 -
.../conf/iotdb-system.properties.template | 15 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 14 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 13 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 14 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 13 +
.../iotdb/commons/concurrent/ThreadName.java | 6 +
.../apache/iotdb/commons/conf/CommonConfig.java | 166 +-
.../iotdb/commons/conf/CommonDescriptor.java | 118 +
.../apache/iotdb/commons}/disk/FolderManager.java | 53 +-
.../commons}/disk/strategy/DirectoryStrategy.java | 12 +-
.../disk/strategy/DirectoryStrategyType.java | 2 +-
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 4 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 8 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../commons}/disk/strategy/SequenceStrategy.java | 4 +-
.../exception/DiskSpaceInsufficientException.java | 4 +-
.../executable/ReferenceCountedJarMetaKeeper.java | 136 +
.../org/apache/iotdb/commons/path/PartialPath.java | 28 +-
.../meta/ConfigNodePipePluginMetaKeeper.java | 50 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 8 +-
.../plugin/env/PipeTaskSinkRuntimeEnvironment.java | 9 +
.../pipe/datastructure/pattern/TreePattern.java | 36 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 7 +-
.../plan/node/CommonPlanNodeDeserializer.java | 3 +
.../planner/plan/node/ICoreQueryPlanVisitor.java | 5 +
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../{PreviousFillNode.java => NextFillNode.java} | 27 +-
.../relational/planner/node/PreviousFillNode.java | 5 +-
.../plan/relational/planner/node/ValuesNode.java | 5 +
.../queryengine/plan/relational/sql/ast/Fill.java | 22 +-
.../sql/util/CommonQuerySqlFormatter.java | 3 +-
.../plan/statement/component/FillPolicy.java | 1 +
.../plan/udf/BuiltinAggregationFunction.java | 23 +-
.../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 | 4 +
.../subscription/config/SubscriptionConfig.java | 71 +
.../meta/consumer/CommitProgressKeeper.java | 190 +
.../meta/consumer/ConsumerGroupMeta.java | 25 +
.../TableBuiltinAggregationFunction.java | 16 +-
.../relational/tvf/CapacityTableFunction.java | 69 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 3 +
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 47 +-
.../ReferenceCountedJarMetaKeeperTest.java | 116 +
.../commons/pipe/config/PipeDescriptorTest.java | 65 +
.../meta/consumer/CommitProgressKeeperTest.java | 163 +
.../relational/tvf/CapacityTableFunctionTest.java | 204 +
.../apache/iotdb/commons/utils/FileUtilsTest.java | 8 +
.../iotdb/commons/utils/WindowsOSUtilsTest.java | 12 +
.../db/relational/grammar/sql/RelationalSql.g4 | 1 +
.../thrift-commons/src/main/thrift/common.thrift | 7 +
.../src/main/thrift/confignode.thrift | 15 +
.../src/main/thrift/iotconsensus.thrift | 16 +-
.../src/main/thrift/datanode.thrift | 43 +-
660 files changed, 49366 insertions(+), 23132 deletions(-)
create mode 100755 .github/scripts/package-client-cpp-manylinux228.sh
create mode 100644 SECURITY.md
create mode 100644 THREAT_MODEL.md
delete mode 100644 example/client-c-example/README.md
delete mode 100644 example/client-c-example/pom.xml
delete mode 100644 example/client-c-example/src/table_example.c
delete mode 100644 example/client-c-example/src/tree_example.c
delete mode 100644 example/client-cpp-example/pom.xml
delete mode 100644 example/client-cpp-example/src/CMakeLists.txt
create mode 100644
example/session/src/main/java/org/apache/iotdb/ConsensusSubscriptionWalFileAnalyzer.java
create mode 100644
example/subscription/src/main/java/org/apache/iotdb/ConsensusSubscriptionSessionExample.java
create mode 100644
example/subscription/src/main/java/org/apache/iotdb/ConsensusTableModelSubscriptionSessionExample.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBStatisticalAggregationIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/TypeConversionSemanticCase.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionSemanticIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeTypeConversionSemanticIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBLegacyPipeReceiverSecurityIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBWindowFunctionBatchedResultIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/AbstractSubscriptionConsensusLocalIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/ConsensusSubscriptionITSupport.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/IoTDBConsensusSubscriptionBasicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/IoTDBConsensusSubscriptionConsumerGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/IoTDBConsensusSubscriptionDataIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/IoTDBConsensusSubscriptionRecoveryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/IoTDBConsensusSubscriptionSeekIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/ConsensusSubscriptionTableITSupport.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionBasicTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionDataTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionFilterTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionSubscribeBeforeRegionTableIT.java
create mode 100644 iotdb-client/client-cpp/CMakeLists.txt
create mode 100644 iotdb-client/client-cpp/README_zh.md
create mode 100644 iotdb-client/client-cpp/cmake/CheckCxx11Abi.cmake
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
create mode 100644 iotdb-client/client-cpp/cmake/iotdb-session.pc.in
rename {example/client-cpp-example/src =>
iotdb-client/client-cpp/examples}/AlignedTimeseriesSessionExample.cpp (98%)
create mode 100644 iotdb-client/client-cpp/examples/CMakeLists.txt
rename {example/client-cpp-example/src =>
iotdb-client/client-cpp/examples}/MultiSvrNodeClient.cpp (96%)
create mode 100644 iotdb-client/client-cpp/examples/README.md
create mode 100644 iotdb-client/client-cpp/examples/README_zh.md
rename {example/client-cpp-example/src =>
iotdb-client/client-cpp/examples}/SessionExample.cpp (97%)
rename {example/client-cpp-example/src =>
iotdb-client/client-cpp/examples}/TableModelSessionExample.cpp (100%)
create mode 100644 iotdb-client/client-cpp/examples/table_example.c
create mode 100644 iotdb-client/client-cpp/examples/tree_example.c
rename example/client-cpp-example/README.md =>
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/DEPENDENCIES.md
(55%)
rename iotdb-client/client-cpp/src/{main => include}/AbstractSessionBuilder.h
(83%)
rename iotdb-client/client-cpp/src/{main => include}/Column.h (97%)
rename iotdb-client/client-cpp/src/{main => include}/ColumnDecoder.h (100%)
rename iotdb-client/client-cpp/src/{main => include}/Common.h (74%)
create mode 100644 iotdb-client/client-cpp/src/include/Date.h
rename iotdb-client/client-cpp/src/{main => include}/DeviceID.h (100%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java
=> iotdb-client/client-cpp/src/include/Endpoint.h (61%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/utils/IMNodeIterator.java
=> iotdb-client/client-cpp/src/include/Export.h (73%)
create mode 100644 iotdb-client/client-cpp/src/include/Optional.h
rename iotdb-client/client-cpp/src/{main => include}/Session.h (72%)
rename iotdb-client/client-cpp/src/{main => include}/SessionBuilder.h (100%)
rename iotdb-client/client-cpp/src/{main => include}/SessionC.h (100%)
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
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/strategy/DirectoryStrategyType.java
=> iotdb-client/client-cpp/src/include/Status.h (76%)
rename iotdb-client/client-cpp/src/{main => include}/TableSession.h (100%)
rename iotdb-client/client-cpp/src/{main => include}/TableSessionBuilder.h
(100%)
rename iotdb-client/client-cpp/src/{main => include}/TsBlock.h (100%)
delete mode 100644 iotdb-client/client-cpp/src/main/CMakeLists.txt
delete mode 100644 iotdb-client/client-cpp/src/main/SessionDataSet.h
rename iotdb-client/client-cpp/src/{main => rpc}/IoTDBRpcDataSet.cpp (88%)
rename iotdb-client/client-cpp/src/{main => rpc}/IoTDBRpcDataSet.h (72%)
rename iotdb-client/client-cpp/src/{main => rpc}/NodesSupplier.cpp (97%)
rename iotdb-client/client-cpp/src/{main => rpc}/NodesSupplier.h (94%)
create mode 100644 iotdb-client/client-cpp/src/rpc/RpcCommon.cpp
create mode 100644 iotdb-client/client-cpp/src/rpc/RpcCommon.h
rename iotdb-client/client-cpp/src/{main => rpc}/SessionConnection.cpp (93%)
rename iotdb-client/client-cpp/src/{main => rpc}/SessionConnection.h (93%)
create mode 100644 iotdb-client/client-cpp/src/rpc/SessionDataSetFactory.h
create mode 100644 iotdb-client/client-cpp/src/rpc/SessionImpl.h
rename iotdb-client/client-cpp/src/{main => rpc}/ThriftConnection.cpp (93%)
rename iotdb-client/client-cpp/src/{main => rpc}/ThriftConnection.h (95%)
create mode 100644 iotdb-client/client-cpp/src/rpc/ThriftConvert.cpp
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/ICachedMNode.java
=> iotdb-client/client-cpp/src/rpc/ThriftConvert.h (59%)
rename iotdb-client/client-cpp/src/{main => session}/Column.cpp (96%)
rename iotdb-client/client-cpp/src/{main => session}/ColumnDecoder.cpp (100%)
rename iotdb-client/client-cpp/src/{main => session}/Common.cpp (52%)
create mode 100644 iotdb-client/client-cpp/src/session/Date.cpp
rename iotdb-client/client-cpp/src/{main => session}/Session.cpp (81%)
rename iotdb-client/client-cpp/src/{main => session}/SessionC.cpp (100%)
create mode 100644 iotdb-client/client-cpp/src/session/SessionDataSet.cpp
create mode 100644 iotdb-client/client-cpp/src/session/SessionPool.cpp
rename iotdb-client/client-cpp/src/{main => session}/TableSession.cpp (100%)
rename iotdb-client/client-cpp/src/{main => session}/TsBlock.cpp (100%)
delete mode 100644 iotdb-client/client-cpp/src/test/CMakeLists.txt
delete mode 100644 iotdb-client/client-cpp/src/test/catch2/catch.hpp
create mode 100644 iotdb-client/client-cpp/test/CMakeLists.txt
create mode 100644 iotdb-client/client-cpp/test/catch2/.gitignore
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionCIT.cpp (100%)
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionCRelationalIT.cpp
(100%)
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionIT.cpp (86%)
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionRelationalIT.cpp (98%)
rename iotdb-client/client-cpp/{src => }/test/main.cpp (100%)
rename iotdb-client/client-cpp/{src => }/test/main_Relational.cpp (100%)
rename iotdb-client/client-cpp/{src => }/test/main_c.cpp (100%)
rename iotdb-client/client-cpp/{src => }/test/main_c_Relational.cpp (100%)
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/rpc/subscription/payload/poll/RegionProgress.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TopicProgress.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/WatermarkPayload.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/WriterId.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/WriterProgress.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/SubscriptionHeartbeatReq.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/SubscriptionSeekReq.java
rename
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/{request/PipeSubscribeHeartbeatReq.java
=> response/PipeSubscribeSeekResp.java} (50%)
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/ColumnAlignProcessor.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionMessageProcessor.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/WatermarkProcessor.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/PollResult.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionCommitContextTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequestTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/payload/request/SubscriptionSeekReqTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/ColumnAlignProcessorTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/WatermarkProcessorTest.java
create mode 100644
iotdb-core/calc-commons/src/main/codegen/templates/nextFill.ftl
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/aggregation/CentralMomentAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/aggregation/CorrelationAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/aggregation/CovarianceAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/aggregation/RegressionAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/TableNextFillOperator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/TableNextFillWithGroupOperator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/fill/next/NextFill.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/TableCentralMomentAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/TableCorrelationAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/TableCovarianceAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/TableRegressionAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedCentralMomentAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedCorrelationAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedCovarianceAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedRegressionAccumulator.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/subscription/{TopicPushMetaRPCHandler.java
=> PullCommitProgressRPCHandler.java} (73%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/subscription/consumer/runtime/CommitProgressHandleMetaChangePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/runtime/SubscriptionLeaderChangeHandler.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/runtime/SubscriptionRuntimeCoordinator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/runtime/CommitProgressSyncProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/runtime/SubscriptionHandleLeaderChangeProcedure.java
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/consensus/ConsensusManagerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/auth/AuthorPlanExecutorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfoTopicValidationTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedureRecoveryTest.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskSinkRuntimeEnvironment.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/iot/SubscriptionWalRetentionPolicy.java}
(50%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/WriterMeta.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/WriterSafeFrontierTracker.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRegistry.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionWalRetentionCalculator.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/WriterMetaTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/WriterSafeFrontierTrackerTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/MemoryControlledChunkReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryModificationLoader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/ProgressWALReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBroker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ISubscriptionBroker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusLogToTabletConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueue.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusRegionRuntimeState.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionCommitManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionSetupHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/PrefetchRoundResult.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ProgressWALIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/SubscriptionConsensusProgress.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/metric/ConsensusSubscriptionPrefetchingQueueMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/ConsensusSubscriptionPrefetchExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/ConsensusSubscriptionPrefetchExecutorManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/ConsensusPrefetchSubtask.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/i18n/DataNodeSchemaMessagesZhFormatTest.java
copy
iotdb-core/datanode/src/{main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CountStatement.java
=>
test/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java}
(53%)
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/queryengine/execution/fragment/QueryModificationLoaderTest.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/process/fill/NextFillTest.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/analyze/AnalyzeUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/NextFillNodeSerdeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/FillStatementTest.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/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/storageengine/dataregion/modification/v1/DeletionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/ProgressWALReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALMetaDataV3CompatibilityTest.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/subscription/broker/consensus/ConsensusLogToTabletConverterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionCommitStateTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ProgressWALIteratorTest.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/FolderManager.java
(72%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/DirectoryStrategy.java
(88%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/DirectoryStrategyType.java
(93%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/MaxDiskUsableSpaceFirstStrategy.java
(92%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/MinFolderOccupiedSpaceFirstStrategy.java
(87%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/RandomOnDiskUsableSpaceStrategy.java
(94%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/SequenceStrategy.java
(95%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/DiskSpaceInsufficientException.java
(91%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/executable/ReferenceCountedJarMetaKeeper.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/planner/node/{PreviousFillNode.java
=> NextFillNode.java} (88%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/subscription/meta/consumer/CommitProgressKeeper.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/pipe/config/PipeDescriptorTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/subscription/meta/consumer/CommitProgressKeeperTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/CapacityTableFunctionTest.java
