This is an automated email from the ASF dual-hosted git repository.
HTHou pushed a change to branch codex/jdk17-jakarta-migration
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4191af07ce8 Refresh PR mergeability
add 07d75c26ad4 Merge origin/master into JDK 17 Jakarta migration
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 ef58305b94f Merge origin/master into JDK 17 Jakarta migration
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/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 +-
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 | 2 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 18 +-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 7 +-
.../pipe/it/dual/TypeConversionSemanticCase.java | 315 +
.../IoTDBPipeTypeConversionSemanticIT.java | 255 +
.../IoTDBPipeTypeConversionSemanticIT.java | 259 +
.../relational/it/db/it/IoTDBWindowTVFIT.java | 101 +
.../it/query/recent/IoTDBFillTableIT.java | 155 +
.../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 | 612 +-
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 | 364 +-
.../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 | 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 +
.../src/main/codegen/templates/nextFill.ftl | 101 +
.../operator/process/TableNextFillOperator.java | 81 +
.../process/TableNextFillWithGroupOperator.java | 165 +
.../operator/process/fill/next/NextFill.java | 182 +
.../calc/plan/planner/CommonOperatorUtils.java | 105 +-
.../calc/plan/planner/TableOperatorGenerator.java | 44 +
.../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 | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../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 +
.../persistence/executor/ConfigPlanExecutor.java | 4 +
.../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 +
.../procedure/store/ProcedureFactory.java | 12 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 16 +-
.../manager/consensus/ConsensusManagerTest.java | 116 +
.../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/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 +
.../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/WriterMetaTest.java | 76 +
.../iot/WriterSafeFrontierTrackerTest.java | 56 +
.../consensus/iot/util/FakeConsensusReqReader.java | 20 +
.../iotdb/consensus/iot/util/TestStateMachine.java | 8 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 16 +
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 16 +
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +
.../db/consensus/DataRegionConsensusImpl.java | 4 +
.../dataregion/DataExecutionVisitor.java | 9 +-
.../dataregion/DataRegionStateMachine.java | 3 +
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../task/execution/PipeSubtaskExecutorManager.java | 24 +-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 44 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 22 +-
.../batch/PipeTransferBatchReqBuilder.java | 43 +-
.../listener/PipeInsertionDataNodeListener.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 8 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 67 +
.../plan/analyze/ClusterPartitionFetcher.java | 38 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 31 +-
.../config/executor/ClusterConfigTaskExecutor.java | 29 +-
.../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 | 13 +
.../planner/plan/node/write/InsertRowNode.java | 2 +-
.../planner/plan/node/write/InsertRowsNode.java | 24 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 21 +
.../planner/plan/node/write/InsertTabletNode.java | 40 +-
.../plan/node/write/RelationalDeleteDataNode.java | 26 +-
.../plan/node/write/RelationalInsertRowNode.java | 2 +-
.../plan/node/write/RelationalInsertRowsNode.java | 3 +
.../node/write/RelationalInsertTabletNode.java | 7 +-
.../plan/planner/plan/node/write/SearchNode.java | 65 +
.../plan/relational/analyzer/Analysis.java | 26 +
.../relational/analyzer/StatementAnalyzer.java | 22 +
.../plan/relational/planner/QueryPlanner.java | 22 +
.../planner/iterative/rule/PruneFillColumns.java | 5 +
.../PushLimitOffsetIntoTableScan.java | 7 +
.../optimizations/UnaliasSymbolReferences.java | 32 +
.../plan/relational/sql/parser/AstBuilder.java | 38 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 8 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 88 +-
.../db/storageengine/dataregion/DataRegion.java | 77 +-
.../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 | 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 +-
.../plugin/TwoStageCountProcessorTest.java} | 29 +-
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 43 +-
.../operator/process/fill/NextFillTest.java | 299 +
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 69 +-
.../node/write/DeleteDataNodeSerdeTest.java | 28 +
.../planner/node/write/InsertRowNodeSerdeTest.java | 28 +-
.../node/write/InsertTabletNodeSerdeTest.java | 28 +-
.../node/write/RelationalDeleteDataNodeTest.java | 9 +-
.../relational/planner/NextFillNodeSerdeTest.java | 112 +
.../relational/sql/parser/FillStatementTest.java | 68 +
.../load/LoadTsFileDispatcherImplTest.java | 98 +
.../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 | 208 +
.../ConsensusSubscriptionCommitStateTest.java | 314 +
.../broker/consensus/ProgressWALIteratorTest.java | 323 +
.../resources/conf/iotdb-system.properties | 1 -
.../conf/iotdb-system.properties.template | 9 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 1 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 1 +
.../iotdb/commons/concurrent/ThreadName.java | 6 +
.../apache/iotdb/commons/conf/CommonConfig.java | 174 +-
.../iotdb/commons/conf/CommonDescriptor.java | 122 +
.../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 +-
.../queryengine/plan/relational/sql/ast/Fill.java | 22 +-
.../sql/util/CommonQuerySqlFormatter.java | 3 +-
.../plan/statement/component/FillPolicy.java | 1 +
.../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 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 3 +
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 47 +-
.../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 +
.../src/main/thrift/confignode.thrift | 16 +-
.../src/main/thrift/iotconsensus.thrift | 16 +-
.../src/main/thrift/datanode.thrift | 43 +-
390 files changed, 34546 insertions(+), 21479 deletions(-)
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/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/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/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/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/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/{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/queryengine/execution/operator/process/fill/NextFillTest.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
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/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
