This is an automated email from the ASF dual-hosted git repository.
CRZbulabula pushed a change to branch improve-confignode-leader-confirm
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 7408a91c348 Update ConfigRegionStateMachine.java
omit e07433767a4 Serialize ConfigNode leader services lifecycle
omit 763315e0f40 Fix Sonar hotspot in simple consensus log parsing
omit f54b4847f09 Clean up leader warm-up heartbeat flow
omit de7eac98a5b Refine ConfigNode leader warm-up flow
omit c0840dac7fd Simplify consensus leader warm-up sampling
omit 2501efbe2a4 Fix ConfigNode leader warm-up recovery
omit a57680d2542 Refine ConfigNode leader warm-up readiness
omit 4e6d45f4e68 Improve ConfigNode leader warm-up gating
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 59028b2dac7 Improve ConfigNode leader warm-up gating
add 17e9c3b15a7 Refine ConfigNode leader warm-up readiness
add f724ea4440d Fix ConfigNode leader warm-up recovery
add a0fcc1dd394 Simplify consensus leader warm-up sampling
add bac0c607c8c Refine ConfigNode leader warm-up flow
add 8f9f175c7fd Clean up leader warm-up heartbeat flow
add 599a9bed1c3 Fix Sonar hotspot in simple consensus log parsing
add cadcac4ef0a Serialize ConfigNode leader services lifecycle
add 5c69640ae6b Update ConfigRegionStateMachine.java
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7408a91c348)
\
N -- N -- N refs/heads/improve-confignode-leader-confirm
(5c69640ae6b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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 +
.../aggregation/IoTDBStatisticalAggregationIT.java | 590 +
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 7 +-
.../regionscan/IoTDBActiveSchemaQueryIT.java | 13 +
.../pipe/it/dual/TypeConversionSemanticCase.java | 315 +
.../IoTDBPipeTypeConversionSemanticIT.java | 255 +
.../IoTDBPipeTypeConversionSemanticIT.java | 259 +
.../treemodel/manual/IoTDBPipePermissionIT.java | 1 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 21 +
.../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 +-
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 | 0
.../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 | 33 +-
.../client-cpp/src/include/Export.h | 20 +-
iotdb-client/client-cpp/src/include/Optional.h | 77 +
.../client-cpp/src/{main => include}/Session.h | 328 +-
.../src/{main => include}/SessionBuilder.h | 0
.../client-cpp/src/{main => include}/SessionC.h | 0
.../client-cpp/src/include/SessionConfig.h | 24 +-
.../client-cpp/src/include/SessionDataSet.h | 124 +
.../client-cpp/src/{main => include}/SessionPool.h | 0
.../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 -
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 | 30 +-
.../client-cpp/src/{main => session}/Column.cpp | 0
.../src/{main => session}/ColumnDecoder.cpp | 0
.../client-cpp/src/{main => session}/Common.cpp | 224 +-
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 +
.../src/{main => session}/SessionPool.cpp | 0
.../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 | 7 +-
.../{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 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
.../iotdb/session/AbstractSessionBuilder.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 2 +
.../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 -
.../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 +
.../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 +
.../CommitProgressHandleMetaChangePlan.java | 78 +
.../iotdb/confignode/manager/ConfigManager.java | 77 +
.../iotdb/confignode/manager/ProcedureManager.java | 34 +
.../manager/consensus/ConsensusManager.java | 23 +-
.../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 +
.../persistence/executor/ConfigPlanExecutor.java | 5 +
.../persistence/subscription/SubscriptionInfo.java | 263 +
.../procedure/env/ConfigNodeProcedureEnv.java | 86 +
.../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 +-
.../manager/consensus/ConsensusManagerTest.java | 116 +
.../iotdb/confignode/persistence/UDFInfoTest.java | 92 +-
.../persistence/auth/AuthorPlanExecutorTest.java | 80 +
.../SubscriptionInfoTopicValidationTest.java | 220 +
.../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} | 38 +-
.../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 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 16 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 35 +-
.../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 | 9 +-
.../dataregion/DataRegionStateMachine.java | 3 +
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../task/execution/PipeSubtaskExecutorManager.java | 24 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 55 +-
.../parser/scan/MemoryControlledChunkReader.java | 76 +
.../parser/scan/SinglePageWholeChunkReader.java | 193 +-
.../scan/TsFileInsertionEventScanParser.java | 53 +-
.../table/TsFileInsertionEventTableParser.java | 197 +-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 6 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 104 +-
.../visitor/PipeStatementExceptionVisitor.java | 7 +
.../evolvable/batch/PipeTabletEventPlainBatch.java | 22 +-
.../batch/PipeTransferBatchReqBuilder.java | 43 +-
.../sink/protocol/writeback/WriteBackSink.java | 21 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 6 +-
.../listener/PipeInsertionDataNodeListener.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 8 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 87 +-
.../db/queryengine/common/TimeseriesContext.java | 234 +-
.../execution/aggregation/AccumulatorFactory.java | 39 +
.../SlidingWindowAggregatorFactory.java | 7 +
.../fragment/FragmentInstanceContext.java | 90 +-
.../execution/fragment/QueryContext.java | 20 +-
.../fragment/QueryModificationLoader.java | 314 +
.../schema/source/SchemaSourceFactory.java | 19 +-
.../schema/source/TimeSeriesSchemaSource.java | 29 +-
.../source/ActiveTimeSeriesRegionScanOperator.java | 77 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 14 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 57 +-
.../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 | 7 +
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../plan/planner/LogicalPlanVisitor.java | 8 +-
.../plan/planner/OperatorTreeGenerator.java | 8 +-
.../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 | 8 +-
.../planner/plan/node/write/InsertRowsNode.java | 30 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 21 +
.../planner/plan/node/write/InsertTabletNode.java | 53 +-
.../plan/planner/plan/node/write/ObjectNode.java | 10 +-
.../plan/node/write/RelationalDeleteDataNode.java | 36 +-
.../plan/node/write/RelationalInsertRowNode.java | 2 +-
.../plan/node/write/RelationalInsertRowsNode.java | 3 +
.../node/write/RelationalInsertTabletNode.java | 14 +-
.../plan/planner/plan/node/write/SearchNode.java | 71 +-
.../plan/parameter/AggregationDescriptor.java | 21 +
.../plan/relational/analyzer/Analysis.java | 26 +
.../relational/analyzer/StatementAnalyzer.java | 22 +
.../relational/metadata/TableMetadataImpl.java | 46 +
.../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/parser/AstBuilder.java | 38 +
.../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 +
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 17 +
.../schemaregion/mtree/traverser/Traverser.java | 1 +
.../db/storageengine/dataregion/DataRegion.java | 79 +-
.../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 +-
.../dataregion/snapshot/SnapshotLoader.java | 106 +-
.../dataregion/tsfile/TsFileResource.java | 18 +-
.../tsfile/generator/TsFileNameGenerator.java | 4 +-
.../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 | 119 +-
.../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 +-
.../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 +-
.../mtree/lock/StampedWriterPreferredLockTest.java | 42 +-
.../schemaRegion/SchemaStatisticsTest.java | 61 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 303 +
.../plugin/TwoStageCountProcessorTest.java} | 41 +-
.../receiver/PipeStatementTsStatusVisitorTest.java | 14 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 143 +
.../fragment/QueryModificationLoaderTest.java | 358 +
.../AlignedSeriesAggregationScanOperatorTest.java | 33 +-
.../operator/DeviceViewIntoOperatorTest.java | 16 +-
.../execution/operator/FillOperatorTest.java | 7 +-
.../operator/HorizontallyConcatOperatorTest.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 +
.../schema/source/TimeSeriesSchemaSourceTest.java | 41 +-
.../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 | 28 +-
.../node/write/InsertTabletNodeSerdeTest.java | 28 +-
.../node/write/RelationalDeleteDataNodeTest.java | 9 +-
.../plan/relational/analyzer/SortTest.java | 44 +
.../relational/planner/NextFillNodeSerdeTest.java | 112 +
.../relational/planner/PredicateUtilsTest.java | 13 +
.../relational/sql/parser/FillStatementTest.java | 68 +
.../load/LoadTsFileDispatcherImplTest.java | 98 +
.../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 | 115 +-
.../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 +
.../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/UtilMessages.java | 13 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 13 +
.../iotdb/commons/concurrent/ThreadName.java | 6 +
.../apache/iotdb/commons/conf/CommonConfig.java | 174 +-
.../iotdb/commons/conf/CommonDescriptor.java | 122 +
.../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 +
.../meta/ConfigNodePipePluginMetaKeeper.java | 50 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 8 +-
.../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 +-
.../iotdb/commons/service/metric/enums/Metric.java | 4 +
.../subscription/config/SubscriptionConfig.java | 73 +-
.../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 | 16 +-
.../src/main/thrift/iotconsensus.thrift | 16 +-
.../src/main/thrift/datanode.thrift | 43 +-
540 files changed, 43851 insertions(+), 22232 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/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 (100%)
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/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/strategy/DirectoryStrategyType.java
=> iotdb-client/client-cpp/src/include/Endpoint.h (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/strategy/DirectoryStrategyType.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 (74%)
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/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/strategy/DirectoryStrategyType.java
=> iotdb-client/client-cpp/src/include/SessionConfig.h (64%)
create mode 100644 iotdb-client/client-cpp/src/include/SessionDataSet.h
rename iotdb-client/client-cpp/src/{main => include}/SessionPool.h (100%)
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/storageengine/rescon/disk/strategy/DirectoryStrategyType.java
=> iotdb-client/client-cpp/src/rpc/ThriftConvert.h (58%)
rename iotdb-client/client-cpp/src/{main => session}/Column.cpp (100%)
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
rename iotdb-client/client-cpp/src/{main => session}/SessionPool.cpp (100%)
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 (99%)
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/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
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionManager.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
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/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/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/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
