This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/show-receivers
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 74d7b59f963 Add show receivers lifecycle test coverage
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 ddd8faaff23 Improve ConfigNode leader warm-up before serving (#17821)
add 11a178a3672 Table: Support SELECT aliases in GROUP BY and ORDER BY
(#17843)
add 30305975373 Bound Ratis reconfiguration retries and add region
migration ITs (#17895)
add 983e927ce97 Add M4 table function implementation and integrate with
statement ana… (#17656)
add 86987e48667 Catch per-startup failures during ConfigNode leader
warm-up (#17898)
add c5240154a70 Clarify RemoveDataNode single-replica error and add
diagnostics for the no-available-RegionGroup race (#17878)
add a725ded2471 Fix overflow edge cases in query utilities (#17875)
add 90cc0279a17 support calculation point project with calc-graph of fuzzy
search by graph name or description (#17905)
add 69c0b18a83f Fix pipe logger format handling (#17900)
add feaeaa6ca71 Fix partial insert handling for null measurements (#17879)
add 41393abf9f6 Only send table deletion to related region groups (#17896)
add a440038f1e5 Support EXPLAIN FORMAT JSON for Table Model (#17430)
add aa7b275318c Pipe: Optimize pipe logging with shared
PipePeriodicalLogReducer (#17887)
add dbc4d4a27b6 Fix -pw without password may take incorrect args (#17914)
add e7bc4926df0 Support legacy pipe receiver requests (#17901)
add d328639dd0f Move query state machine support to calc commons (#17912)
add 283bce2f34c Cache non-exist timeseries metadata to reduce IO (#16606)
add 5d21e1eb960 Merge branch 'master' of https://github.com/apache/iotdb
into feat/show-receivers
No new revisions were added by this update.
Summary of changes:
.claude/settings.json => .codex/hooks.json | 0
.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 | 12 +-
CONTRIBUTING.md | 3 -
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 | 23 +-
.../env/cluster/config/MppSharedCommonConfig.java | 21 +
.../it/env/remote/config/RemoteCommonConfig.java | 15 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../iotdb/cli/it/ExplainJsonCliOutputIT.java | 345 +
.../IoTDBRegionMigrateITFrameworkForRatis.java | 29 +-
...IoTDBRegionOperationReliabilityITFramework.java | 128 +-
...oTDBRegionMigrateAddingPeerCrashForRatisIT.java | 48 +
.../IoTDBRegionMigrateClusterCrashForRatisIT.java | 76 +
...oTDBRegionMigrateConfigNodeCrashForRatisIT.java | 164 +
.../removedatanode/IoTDBRemoveLastDataNodeIT.java | 111 +
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 18 +-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 7 +-
.../pipe/it/dual/TypeConversionSemanticCase.java | 315 +
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 24 +-
.../IoTDBPipeTypeConversionSemanticIT.java | 255 +
.../IoTDBPipeTypeConversionSemanticIT.java | 259 +
.../manual/IoTDBPipeTypeConversionISessionIT.java | 2 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 435 +
.../it/insertquery/IoTDBInsertQueryIT.java | 4 +-
.../it/query/recent/IoTDBFillTableIT.java | 155 +
.../it/query/recent/IoTDBTableAggregationIT.java | 69 +
.../it/query/recent/IoTExplainJsonFormatIT.java | 855 +
.../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 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 46 +-
.../java/org/apache/iotdb/cli/AbstractCliTest.java | 83 +-
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 | 34 +-
.../client-cpp/src/include/Export.h | 27 +-
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 | 27 +-
.../client-cpp/src/include/SessionDataSet.h | 124 +
.../client-cpp/src/{main => include}/SessionPool.h | 0
.../client-cpp/src/include/Status.h | 25 +-
.../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 | 4 +-
.../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 +
iotdb-core/ainode/iotdb/ainode/core/constant.py | 1 +
iotdb-core/ainode/iotdb/ainode/core/rpc/client.py | 11 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +
iotdb-core/calc-commons/pom.xml | 5 +
.../src/main/codegen/templates/nextFill.ftl | 101 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 10 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 9 +
.../operator/process/TableNextFillOperator.java | 81 +
.../process/TableNextFillWithGroupOperator.java | 165 +
.../fill/filter/FixedIntervalFillFilter.java | 10 +-
.../operator/process/fill/next/NextFill.java | 182 +
.../relational/aggregation/ExtremeAccumulator.java | 32 +-
.../grouped/GroupedExtremeAccumulator.java | 70 +-
.../calc/plan/planner/CommonOperatorUtils.java | 105 +-
.../calc/plan/planner/TableOperatorGenerator.java | 142 +-
.../fill/filter/FixedIntervalFillFilterTest.java} | 24 +-
.../aggregation/ExtremeAccumulatorTest.java | 150 +
.../iotdb/confignode/i18n/ManagerMessages.java | 8 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 5 +
.../iotdb/confignode/i18n/ManagerMessages.java | 14 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 5 +
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 13 +
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 2 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 125 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 10 +
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 16 +-
.../ConsumerGroupPushMetaRPCHandler.java | 11 +-
...dler.java => PullCommitProgressRPCHandler.java} | 28 +-
.../rpc/subscription/TopicPushMetaRPCHandler.java | 11 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 40 +
.../confignode/conf/ConfigNodeDescriptor.java | 25 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../CommitProgressHandleMetaChangePlan.java | 78 +
.../statemachine/ConfigRegionStateMachine.java | 394 +-
.../iotdb/confignode/manager/ConfigManager.java | 81 +
.../iotdb/confignode/manager/ProcedureManager.java | 47 +-
.../manager/consensus/ConsensusManager.java | 104 +-
.../iotdb/confignode/manager/load/LoadManager.java | 75 +
.../balancer/router/leader/HashLeaderBalancer.java | 2 +-
.../manager/load/cache/AbstractLoadCache.java | 4 +
.../confignode/manager/load/cache/LoadCache.java | 27 +
.../load/cache/consensus/ConsensusGroupCache.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 4 +
.../manager/partition/PartitionManager.java | 18 +
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 17 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 21 +-
.../pipe/coordinator/runtime/PipeMetaSyncer.java | 26 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 43 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 7 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 8 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 10 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 4 +-
.../manager/subscription/SubscriptionManager.java | 15 +
.../subscription/SubscriptionMetaSyncer.java | 7 +
.../runtime/SubscriptionLeaderChangeHandler.java | 43 +
.../runtime/SubscriptionRuntimeCoordinator.java | 160 +
.../persistence/executor/ConfigPlanExecutor.java | 4 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 9 +-
.../persistence/subscription/SubscriptionInfo.java | 263 +
.../confignode/procedure/ProcedureExecutor.java | 13 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 93 +-
.../procedure/env/RemoveDataNodeHandler.java | 52 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 36 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 33 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 6 +-
.../impl/region/CreateRegionGroupsProcedure.java | 10 +-
.../AbstractOperateSubscriptionProcedure.java | 1 +
.../impl/subscription/SubscriptionOperation.java | 2 +
.../runtime/CommitProgressSyncProcedure.java | 316 +
.../SubscriptionHandleLeaderChangeProcedure.java | 444 +
.../subscription/CreateSubscriptionProcedure.java | 85 +-
.../subscription/DropSubscriptionProcedure.java | 14 +
.../procedure/store/ProcedureFactory.java | 12 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../iotdb/confignode/service/ConfigNode.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 16 +-
.../manager/consensus/ConsensusManagerTest.java | 116 +
.../confignode/manager/load/LoadManagerTest.java | 70 +
.../router/leader/HashLeaderBalancerTest.java | 65 +
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 191 +
.../SubscriptionInfoTopicValidationTest.java | 220 +
.../DropSubscriptionProcedureTest.java | 3 +
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 47 +
.../DeserializedBatchIndexedConsensusRequest.java | 29 +-
.../common/request/IndexedConsensusRequest.java | 66 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 33 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 22 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 36 +
.../consensus/iot/IoTConsensusServerImpl.java | 337 +-
.../iot/SubscriptionWalRetentionPolicy.java} | 38 +-
.../org/apache/iotdb/consensus/iot/WriterMeta.java | 112 +
.../consensus/iot/WriterSafeFrontierTracker.java | 145 +
.../iot/client/AsyncIoTConsensusServiceClient.java | 2 +-
.../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/ratis/RatisClient.java | 31 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +-
.../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-core/datanode/pom.xml | 4 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 16 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 9 -
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 16 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 9 -
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 18 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 29 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 +-
.../db/consensus/DataRegionConsensusImpl.java | 6 +
.../db/consensus/SchemaRegionConsensusImpl.java | 3 +
.../dataregion/DataExecutionVisitor.java | 9 +-
.../dataregion/DataRegionStateMachine.java | 3 +
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 14 +-
.../task/execution/PipeSubtaskExecutorManager.java | 24 +-
.../tablet/parser/TabletInsertionEventParser.java | 123 +-
.../downsampling/changing/ChangingValueFilter.java | 20 +-
.../sdt/SwingingDoorTrendingFilter.java | 19 +-
.../tumbling/TumblingTimeSamplingProcessor.java | 7 +-
.../exchange/sender/TwoStageAggregateSender.java | 2 +-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 50 +-
.../statement/PipeConvertedInsertRowStatement.java | 9 +
.../resource/log/PipePeriodicalLogReducer.java | 93 -
.../resource/memory/InsertNodeMemoryEstimator.java | 15 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 10 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 22 +-
.../batch/PipeTransferBatchReqBuilder.java | 43 +-
.../request/PipeTransferTabletRawReq.java | 89 +-
.../pipe/sink/util/TabletStatementConverter.java | 31 +-
.../listener/PipeInsertionDataNodeListener.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 55 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 80 +
.../db/queryengine/common/MPPQueryContext.java | 10 +
.../db/queryengine/execution/StateMachine.java | 8 +-
.../execution/aggregation/ExtremeAccumulator.java | 32 +-
.../SlidingWindowAggregatorFactory.java | 36 +-
.../execution/operator/ExplainAnalyzeOperator.java | 70 +-
.../execution/operator/window/SessionWindow.java | 24 +-
.../operator/window/SessionWindowManager.java | 2 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 17 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 34 +-
.../plan/analyze/ClusterPartitionFetcher.java | 38 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 31 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 29 +-
.../TableModelStatementMemorySourceVisitor.java | 54 +-
.../planner/DataNodeTableOperatorGenerator.java | 7 +-
.../plan/AbstractFragmentParallelPlanner.java | 3 +-
.../planner/plan/node/PlanGraphJsonPrinter.java | 225 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 15 +
.../plan/node/load/LoadSingleTsFileNode.java | 36 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 55 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 44 +
.../planner/plan/node/write/DeleteDataNode.java | 7 +-
.../plan/node/write/InsertMultiTabletsNode.java | 24 +
.../plan/planner/plan/node/write/InsertNode.java | 79 +-
.../planner/plan/node/write/InsertRowNode.java | 218 +-
.../planner/plan/node/write/InsertRowsNode.java | 24 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 26 +-
.../planner/plan/node/write/InsertTabletNode.java | 383 +-
.../plan/node/write/RelationalDeleteDataNode.java | 26 +-
.../plan/node/write/RelationalInsertRowNode.java | 63 +-
.../plan/node/write/RelationalInsertRowsNode.java | 48 +-
.../node/write/RelationalInsertTabletNode.java | 114 +-
.../plan/planner/plan/node/write/SearchNode.java | 65 +
.../plan/relational/analyzer/Analysis.java | 26 +
.../relational/analyzer/StatementAnalyzer.java | 326 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 4 +-
.../cache/TreeDeviceSchemaCacheManager.java | 9 +-
.../plan/relational/planner/CteMaterializer.java | 1 +
.../plan/relational/planner/QueryPlanner.java | 22 +
.../plan/relational/planner/RelationPlanner.java | 6 +-
.../relational/planner/TableLogicalPlanner.java | 3 +-
.../distribute/TableDistributedPlanner.java | 16 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 2 +
.../planner/iterative/rule/PruneFillColumns.java | 5 +
.../planner/node/ExplainAnalyzeNode.java | 39 +-
.../PushLimitOffsetIntoTableScan.java | 7 +
.../optimizations/UnaliasSymbolReferences.java | 35 +-
.../plan/relational/sql/ast/Explain.java | 28 +-
.../plan/relational/sql/ast/ExplainAnalyze.java | 37 +-
.../relational/sql/ast/ExplainOutputFormat.java} | 28 +-
.../plan/relational/sql/ast/InsertRow.java | 5 +-
.../plan/relational/sql/ast/InsertRows.java | 14 +-
.../plan/relational/sql/ast/InsertTablet.java | 13 +-
.../relational/sql/ast/WrappedInsertStatement.java | 22 +-
.../plan/relational/sql/parser/AstBuilder.java | 73 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 8 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 88 +-
.../plan/statement/crud/InsertBaseStatement.java | 210 +-
.../plan/statement/crud/InsertRowStatement.java | 128 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 12 +
.../plan/statement/crud/InsertTabletStatement.java | 161 +-
.../FragmentInstanceStatisticsJsonDrawer.java | 372 +
.../buffer/TimeSeriesMetadataCache.java | 43 +-
.../db/storageengine/dataregion/DataRegion.java | 80 +-
.../dataregion/memtable/AbstractMemTable.java | 120 +-
.../memtable/AbstractWritableMemChunk.java | 17 +
.../memtable/AlignedWritableMemChunk.java | 7 +-
.../dataregion/memtable/TsFileProcessor.java | 162 +-
.../dataregion/memtable/WritableMemChunk.java | 7 +-
.../dataregion/memtable/WritableMemChunkGroup.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 | 46 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 31 +-
.../dataregion/wal/buffer/WALBuffer.java | 22 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 9 +-
.../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 +-
.../load/splitter/AlignedChunkData.java | 9 +
.../load/splitter/NonAlignedChunkData.java | 16 +
.../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 | 843 +
.../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 +-
.../SubscriptionPipeEventBatchSegmentLock.java | 4 +-
...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 +-
.../db/trigger/executor/TriggerFireVisitor.java | 53 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 71 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 81 +
.../changing/ChangingValueFilterTest.java | 55 +
.../sdt/SwingingDoorTrendingFilterTest.java | 56 +
.../TumblingTimeSamplingProcessorTest.java | 192 +
.../plugin/TwoStageCountProcessorTest.java} | 29 +-
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 43 +-
.../PipeConvertedInsertRowStatementTest.java | 55 +
.../memory/InsertNodeMemoryEstimatorTest.java | 12 +
.../tsfile/PipeTsFileResourceSegmentLockTest.java | 71 +
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 484 +
.../sink/util/TabletStatementConverterTest.java | 64 +
.../execution/aggregation/AccumulatorTest.java | 46 +
.../SlidingWindowAggregatorFactoryTest.java} | 26 +-
.../operator/ExplainAnalyzeOperatorTest.java | 96 +
.../operator/process/fill/NextFillTest.java | 299 +
.../operator/window/SessionWindowTest.java | 70 +
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 74 +
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 69 +-
...TableModelStatementMemorySourceVisitorTest.java | 88 +
.../planner/node/PlanGraphJsonPrinterTest.java | 573 +
.../node/write/DeleteDataNodeSerdeTest.java | 28 +
.../planner/node/write/InsertRowNodeSerdeTest.java | 155 +-
.../node/write/InsertRowsNodeSerdeTest.java | 35 +
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 34 +
.../node/write/InsertTabletNodeSerdeTest.java | 158 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 41 +
.../write/InsertNodeIsMeasurementFailedTest.java | 255 +
.../node/write/RelationalDeleteDataNodeTest.java | 9 +-
.../relational/analyzer/SelectAliasReuseTest.java | 347 +
.../relational/analyzer/TableFunctionTest.java | 187 +
.../plan/relational/analyzer/TestMetadata.java | 13 +
.../relational/planner/CteMaterializerTest.java | 1 +
.../plan/relational/planner/CteSubqueryTest.java | 1 +
.../relational/planner/NextFillNodeSerdeTest.java | 112 +
.../plan/relational/sql/ExplainFormatTest.java | 186 +
.../relational/sql/parser/FillStatementTest.java | 68 +
.../load/LoadTsFileDispatcherImplTest.java | 98 +
.../crud/InsertStatementPartialInsertTest.java | 320 +
.../FragmentInstanceStatisticsJsonDrawerTest.java | 594 +
.../buffer/TimeSeriesMetadataCacheTest.java | 280 +
.../storageengine/dataregion/DataRegionTest.java | 30 +-
.../AbstractMemTablePartialInsertTest.java | 113 +
.../memtable/MemChunkDeserializeTest.java | 23 +
.../dataregion/memtable/TsFileProcessorTest.java | 172 +
.../modification/TableDeletionEntryTest.java | 8 +-
.../modification/TreeDeletionEntryTest.java | 5 +-
.../dataregion/modification/v1/DeletionTest.java | 52 +
.../dataregion/snapshot/IoTDBSnapshotTest.java | 26 +
.../wal/compression/WALCompressionTest.java | 37 +-
.../dataregion/wal/io/ProgressWALReaderTest.java | 93 +
.../dataregion/wal/io/WALFileTest.java | 1 +
.../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 +
.../ConsensusLogToTabletConverterTest.java | 266 +
.../ConsensusSubscriptionCommitStateTest.java | 314 +
.../broker/consensus/ProgressWALIteratorTest.java | 323 +
.../SubscriptionPipeEventBatchSegmentLockTest.java | 50 +
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 127 +
.../resources/conf/iotdb-system.properties | 1 -
.../conf/iotdb-system.properties.template | 25 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 1 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 1 +
.../async/AsyncAINodeInternalServiceClient.java | 2 +-
.../AsyncConfigNodeInternalServiceClient.java | 2 +-
.../async/AsyncDataNodeExternalServiceClient.java | 2 +-
.../async/AsyncDataNodeInternalServiceClient.java | 2 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 2 +-
.../async/AsyncIoTConsensusV2ServiceClient.java | 2 +-
.../async/AsyncPipeDataTransferServiceClient.java | 2 +-
.../iotdb/commons/concurrent/ThreadName.java | 9 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 174 +-
.../iotdb/commons/conf/CommonDescriptor.java | 122 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 8 +-
.../commons/pipe/resource/log/PipeLogger.java | 18 +-
.../resource/log/PipePeriodicalLogReducer.java | 76 +
.../thrift/request/PipeTransferFileSealReqV2.java | 8 +
.../plan/node/CommonPlanNodeDeserializer.java | 3 +
.../planner/plan/node/ICoreQueryPlanVisitor.java | 5 +
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../function/TableBuiltinTableFunction.java | 4 +
.../{PreviousFillNode.java => NextFillNode.java} | 27 +-
.../relational/planner/node/PreviousFillNode.java | 5 +-
.../queryengine/plan/relational/sql/ast/Fill.java | 22 +-
.../sql/util/CommonQuerySqlFormatter.java | 3 +-
.../plan/statement/component/FillPolicy.java | 1 +
.../schema/table/InsertNodeMeasurementInfo.java | 9 +-
.../iotdb/commons/service/metric/enums/Metric.java | 4 +
.../subscription/config/SubscriptionConfig.java | 73 +-
.../meta/consumer/CommitProgressKeeper.java | 190 +
.../meta/consumer/ConsumerGroupMeta.java | 25 +
.../relational/tvf/CapacityTableFunction.java | 69 +-
.../builtin/relational/tvf/M4TableFunction.java | 802 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 3 +
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 47 +-
.../commons/pipe/config/PipeDescriptorTest.java | 65 +
.../commons/pipe/resource/PipeLoggerTest.java | 83 +
.../common/PipeTransferSliceReqBuilderTest.java | 32 +
.../thrift/request/PipeRequestTypeTest.java | 61 +
.../request/PipeTransferCompressedReqTest.java | 112 +
.../request/PipeTransferFileSealReqV2Test.java | 65 +
.../table/InsertNodeMeasurementInfoTest.java | 83 +
.../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 | 5 +-
.../src/main/thrift/confignode.thrift | 22 +-
.../src/main/thrift/iotconsensus.thrift | 16 +-
.../src/main/thrift/datanode.thrift | 43 +-
scripts/sbin/windows/start-cli.bat | 23 +-
575 files changed, 48254 insertions(+), 22663 deletions(-)
copy .claude/settings.json => .codex/hooks.json (100%)
create mode 100755 .github/scripts/package-client-cpp-manylinux228.sh
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/cli/it/ExplainJsonCliOutputIT.java
copy
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/fill/filter/FixedIntervalFillFilter.java
=>
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionMigrateITFrameworkForRatis.java
(54%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/ratis/IoTDBRegionMigrateAddingPeerCrashForRatisIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/ratis/IoTDBRegionMigrateClusterCrashForRatisIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/ratis/IoTDBRegionMigrateConfigNodeCrashForRatisIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/IoTDBRemoveLastDataNodeIT.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/query/recent/IoTExplainJsonFormatIT.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/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/statement/component/FillPolicy.java
=> iotdb-client/client-cpp/src/include/Endpoint.h (58%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/statement/component/FillPolicy.java
=> iotdb-client/client-cpp/src/include/Export.h (69%)
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/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/statement/component/FillPolicy.java
=> iotdb-client/client-cpp/src/include/SessionConfig.h (60%)
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/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/statement/component/FillPolicy.java
=> iotdb-client/client-cpp/src/include/Status.h (70%)
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/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionManager.java
=> iotdb-client/client-cpp/src/rpc/ThriftConvert.h (57%)
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/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
copy
iotdb-core/calc-commons/src/{main/java/org/apache/iotdb/calc/execution/operator/process/fill/filter/FixedIntervalFillFilter.java
=>
test/java/org/apache/iotdb/calc/execution/operator/process/fill/filter/FixedIntervalFillFilterTest.java}
(59%)
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/ExtremeAccumulatorTest.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/manager/load/balancer/router/leader/HashLeaderBalancerTest.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
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/log/PipePeriodicalLogReducer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphJsonPrinter.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/statement/component/FillPolicy.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ExplainOutputFormat.java}
(58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/statistics/FragmentInstanceStatisticsJsonDrawer.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/pipe/processor/downsampling/changing/ChangingValueFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/downsampling/sdt/SwingingDoorTrendingFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/downsampling/tumbling/TumblingTimeSamplingProcessorTest.java
copy
iotdb-core/{node-commons/src/test/java/org/apache/iotdb/commons/utils/WindowsOSUtilsTest.java
=>
datanode/src/test/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java}
(52%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertRowStatementTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/tsfile/PipeTsFileResourceSegmentLockTest.java
copy
iotdb-core/{node-commons/src/test/java/org/apache/iotdb/commons/utils/WindowsOSUtilsTest.java
=>
datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/aggregation/slidingwindow/SlidingWindowAggregatorFactoryTest.java}
(52%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/ExplainAnalyzeOperatorTest.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/window/SessionWindowTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/memory/TableModelStatementMemorySourceVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/PlanGraphJsonPrinterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SelectAliasReuseTest.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/ExplainFormatTest.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/queryengine/plan/statement/crud/InsertStatementPartialInsertTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/statistics/FragmentInstanceStatisticsJsonDrawerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/buffer/TimeSeriesMetadataCacheTest.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
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatchSegmentLockTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/log/PipePeriodicalLogReducer.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/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/M4TableFunction.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/config/PipeDescriptorTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/resource/PipeLoggerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeRequestTypeTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferCompressedReqTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferFileSealReqV2Test.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/schema/table/InsertNodeMeasurementInfoTest.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
