This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch codex/jdbc-driver-info
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 164931f42f5 Fix JDBC resource lifecycle cleanup
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 1a3548e6fa6 Add cache for single measurement validation (#17899)
add 3853d380fc1 Fix driver scheduler ready queue reservation leak (#17919)
add e9e3dd63199 Refactor some method and PlanNodeType (#17918)
add 72e72dd2c4e Upgrade minimum JDK to 17 and migrate JavaX to Jakarta
(#17859)
add aec7dfb3d61 Add PERCENTILE aggregation function and related validation
(#16545)
add abb9ef93ca1 Subscription: add topic owner epoch fencing (#17780)
add 71e9c59634e Uncomment commented set-configuration-able items in the
config template (fix enable_topology_probing & topology_probing_* hot/restart
reload) (#17933)
add f5175b97aad Fix flaky region-migration/cluster ITs and enable IoTV2
daily migration tests (#17924)
add 8fd6b0490da Pipe: avoid blocking startup on hardlink dir cleanup
(#17932)
add 98c823461be Fix pipe schema snapshot database creation (#17910)
add 08c55b96840 Exclude DataNodes being removed from new Region allocation
(#17934)
add 3ebc26444ca Fix MIGRATE REGION falsely reported complete when
ConfigNode leader switches during AddRegionPeer (#17908)
add d58313225e6 Fix compaction writer size checkpointing (#17941)
add 3b9f59fc9e8 [Pipe] Fix omitted legacy tablet compatibility follow-ups
(#17929)
add 1df19137839 Fix pipe runtime meta push blocking user operations
(#17909)
add c39061ae458 Subscription: Drain TsFile batches before termination
(#17926)
add 8c9dbb57c7c Add region group stats to table model database details
(#17738)
add a4ed6dd6ab8 Propagate snapshot load failure during IoTConsensus
AddPeer (#17935)
add 8fad78466f6 Implement GROUP BY ALL functionality (#17937)
add 3f207172056 Fix aggregate write-back output database metadata (#17938)
add c4574b6567a Fix active load cleanup lifecycle (#17947)
add b9d3dbe9123 Remove IoTConsensus auto leader balance toggle (#17950)
add 5e6f1c20cc5 Pipe: serialize sink transfers by region (#17946)
add 3767282ad12 feat(client-cpp): add SessionC DATE/BLOB support and
RowRecord getters (#17956)
add b33278688c2 Pipe: improve progress coverage checks (#17940)
add 9ca448ef4f4 Fix tree model load type mismatch conversion (#17949)
add 0a45a3b7b70 Fix duplicate scheduling in procedure execution (#17902)
add 757f9007fdc Throttle async pipe sink on receiver reject (#17928)
add c94c9a393c7 Fix idempotent table cache update handling (#17959)
add db27f78a1b8 Fix pipe lifecycle restart order in IT (#17962)
add dd3153e4038 Fix tree schema snapshot database creation on master
(#17964)
add b443006e34f Add envelope function to UDF registration script (#17971)
add 8d56ae71e5f Fix PBTree flush for negative child address (#17955)
add 08c046e151e Fix IoTConsensus multi-folder snapshot load for DataRegion
(#17974)
add d11770d7443 feat: add integration test support for StreamNode (#17952)
add d6d57559075 Prevent pipe sink task id from logging secrets (#17981)
add ddc65546ad6 Fix test clean directory deletion (#17860)
add ef0d9f8534f Improve IT cluster readiness diagnostics (#17903)
add 09fba6889f3 Fix missing Objects import in ConfigurationFileUtilsTest
(#17992)
add 5994e1ee93f Support hot reload for cluster runtime configs (#17975)
add 67c69b46589 Fix double living table schema race in IT (#17980)
add 4c2fd638a15 Add generic SSL/TLS configuration support (#17854)
add f971de235ec Fix old pipe root user compatibility (#17985)
new 5db0a02a148 Merge branch 'master' of https://github.com/apache/iotdb
into codex/jdbc-driver-info
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 | 59 -
.github/workflows/daily-it.yml | 4 +-
.github/workflows/daily-ut.yml | 15 +-
.github/workflows/dependency-check.yml | 8 +
.github/workflows/multi-language-client.yml | 81 +-
.github/workflows/pipe-it.yml | 19 +
.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 +-
CLAUDE.md | 2 +-
CONTRIBUTING.md | 5 +-
Jenkinsfile | 2 +-
LICENSE-binary | 43 +-
README.md | 4 +-
README_ZH.md | 4 +-
dependencies.json | 318 +-
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/jdbc/pom.xml | 4 +-
example/pipe-count-point-processor/pom.xml | 4 +-
example/pom.xml | 13 +-
.../ConsensusSubscriptionWalFileAnalyzer.java | 528 +
.../iotdb/ConsensusSubscriptionSessionExample.java | 198 +
...sensusTableModelSubscriptionSessionExample.java | 201 +
external-service-impl/mqtt/pom.xml | 4 +-
external-service-impl/pom.xml | 4 +-
external-service-impl/rest-openapi/pom.xml | 28 +-
external-service-impl/rest/pom.xml | 32 +-
.../java/org/apache/iotdb/rest/RestService.java | 17 +-
.../rest/protocol/filter/ApiOriginFilter.java | 15 +-
.../rest/protocol/filter/AuthorizationFilter.java | 36 +-
.../rest/protocol/filter/BasicSecurityContext.java | 2 +-
.../protocol/handler/AuthorizationHandler.java | 4 +-
.../rest/protocol/impl/PingApiServiceImpl.java | 4 +-
.../table/v1/handler/ExceptionHandler.java | 2 +-
.../table/v1/handler/QueryDataSetHandler.java | 2 +-
.../protocol/table/v1/impl/RestApiServiceImpl.java | 4 +-
.../rest/protocol/v1/handler/ExceptionHandler.java | 2 +-
.../protocol/v1/handler/QueryDataSetHandler.java | 2 +-
.../protocol/v1/impl/GrafanaApiServiceImpl.java | 4 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 4 +-
.../rest/protocol/v2/handler/ExceptionHandler.java | 2 +-
.../rest/protocol/v2/handler/FastLastHandler.java | 2 +-
.../protocol/v2/handler/QueryDataSetHandler.java | 3 +-
.../protocol/v2/impl/GrafanaApiServiceImpl.java | 4 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 4 +-
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 1 +
.../iotdb/it/env/cluster/config/MppBaseConfig.java | 7 +-
.../it/env/cluster/config/MppCommonConfig.java | 70 +-
.../env/cluster/config/MppSharedCommonConfig.java | 69 +-
.../org/apache/iotdb/it/env/cluster/env/AIEnv.java | 28 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 421 +-
.../iotdb/it/env/cluster/node/AINodeStarter.java | 84 +
.../it/env/remote/config/RemoteCommonConfig.java | 52 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 23 +-
.../itbase/runtime/ParallelRequestDelegate.java | 13 +-
.../iotdb/cli/it/ExplainJsonCliOutputIT.java | 345 +
...oTDBMultiDBRegionGroupLeaderDistributionIT.java | 1 -
.../IoTDBPerDatabaseRegionGroupAllocationIT.java | 8 +-
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 1 -
.../partition/IoTDBPartitionInheritStrategyIT.java | 2 +-
.../partition/IoTDBPartitionShuffleStrategyIT.java | 2 +-
.../IoTDBRegionMigrateITFrameworkForRatis.java} | 26 +-
...IoTDBRegionOperationReliabilityITFramework.java | 202 +-
...BRegionMigrateDataNodeCrashForIoTV2BatchIT.java | 19 +-
...RegionMigrateDataNodeCrashForIoTV2StreamIT.java | 19 +-
...oTDBRegionMigrateAddingPeerCrashForRatisIT.java | 48 +
.../IoTDBRegionMigrateConfigNodeCrashIoTV1IT.java | 26 +
...IoTDBRegionMigrateClusterCrashIoTV2BatchIT.java | 6 +-
...DBRegionMigrateConfigNodeCrashIoTV2BatchIT.java | 35 +-
...oTDBRegionMigrateClusterCrashIoTV2StreamIT.java | 9 +-
...BRegionMigrateConfigNodeCrashIoTV2StreamIT.java | 35 +-
.../IoTDBRegionMigrateClusterCrashForRatisIT.java} | 35 +-
...TDBRegionMigrateConfigNodeCrashForRatisIT.java} | 72 +-
.../IoTDBRemoveDataNodeRegionAllocationIT.java | 348 +
.../removedatanode/IoTDBRemoveLastDataNodeIT.java | 111 +
.../iotdb/db/it/IoTDBCustomizedClusterIT.java | 54 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 18 +-
.../db/it/IoTDBSetConfigurationClusterIT.java | 122 +
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 311 +
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 2 +-
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 48 +-
...DBSingleMeasurementCheckCachePerformanceIT.java | 207 +
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 11 +-
.../pipe/it/dual/TypeConversionSemanticCase.java | 315 +
.../manual/basic/IoTDBPipeLifeCycleIT.java | 2 +-
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 24 +-
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 8 +
.../manual/enhanced/IoTDBPipeSinkParallelIT.java | 1 +
.../IoTDBPipeTypeConversionSemanticIT.java | 255 +
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 2 +-
.../auto/basic/IoTDBPipeSinkParallelIT.java | 1 +
.../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/IoTDBGroupByAllTableIT.java | 238 +
.../it/query/recent/IoTDBTableAggregationIT.java | 121 +
.../it/query/recent/IoTExplainJsonFormatIT.java | 855 +
.../it/schema/IoTDBAlterColumnTypeIT.java | 11 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 55 +-
.../apache/iotdb/session/it/IoTDBClientSSLIT.java | 233 +
.../IoTDBSubscriptionTopicOwnerPartitionIT.java | 267 +
.../AbstractSubscriptionConsensusLocalIT.java} | 9 +-
.../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 +
.../dual/tablemodel/IoTDBSubscriptionTopicIT.java | 86 +
.../it/local/AbstractSubscriptionLocalIT.java | 1 +
.../it/local/IoTDBSubscriptionTopicOwnerIT.java | 225 +
.../IoTDBEncryptedPasswordPullConsumerIT.java | 5 +-
integration-test/src/test/resources/test-keystore | Bin 2710 -> 2742 bytes
.../src/test/resources/test-truststore | Bin 1238 -> 1270 bytes
.../api/customizer/parameter/PipeParameters.java | 10 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 60 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 4 +
.../org/apache/iotdb/tool/common/Constants.java | 4 +
.../org/apache/iotdb/tool/common/OptionsUtil.java | 10 +
.../apache/iotdb/tool/data/AbstractDataTool.java | 37 +
.../apache/iotdb/tool/data/ExportDataTable.java | 3 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 3 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 3 +-
.../org/apache/iotdb/tool/data/ImportDataTree.java | 3 +-
.../iotdb/tool/schema/AbstractSchemaTool.java | 28 +
.../iotdb/tool/schema/ExportSchemaTable.java | 3 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 3 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 3 +-
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 3 +-
.../java/org/apache/iotdb/cli/AbstractCliTest.java | 83 +-
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 | 368 +-
.../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 | 35 +-
.../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 | 12 +
.../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 | 36 +-
.../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 | 33 +
.../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 | 42 +-
.../{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 +
.../org/apache/iotdb/isession/SessionConfig.java | 2 +
iotdb-client/jdbc/README.md | 4 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 4 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 5 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 9 +
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 1 +
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 5 +
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 7 +
.../iotdb/jdbc/IoTDBDataSourceFactoryTest.java | 2 +
.../org/apache/iotdb/jdbc/IoTDBDriverTest.java | 2 +
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 11 +
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 29 +-
.../java/org/apache/iotdb/rpc/RpcSslUtils.java | 245 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 9 +-
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 32 +
.../iotdb/session/AbstractSessionBuilder.java | 2 +
.../org/apache/iotdb/session/NodesSupplier.java | 6 +
.../java/org/apache/iotdb/session/Session.java | 10 +
.../apache/iotdb/session/SessionConnection.java | 33 +-
.../apache/iotdb/session/TableSessionBuilder.java | 12 +
.../org/apache/iotdb/session/ThriftConnection.java | 6 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 13 +
.../session/pool/TableSessionPoolBuilder.java | 12 +
.../src/test/resources/iotdb-common.properties | 2 +-
iotdb-client/subscription/pom.xml | 5 +
.../subscription/i18n/SubscriptionMessages.java | 25 +
.../subscription/i18n/SubscriptionMessages.java | 20 +
.../rpc/subscription/config/ConsumerConfig.java | 10 +
.../rpc/subscription/config/ConsumerConstant.java | 2 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 89 +-
.../rpc/subscription/config/TopicConstant.java | 19 +
.../SubscriptionOwnerFencedException.java | 27 +-
.../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 +-
.../subscription/AbstractSubscriptionSession.java | 99 +-
.../subscription/ISubscriptionTableSession.java | 43 +
.../subscription/ISubscriptionTreeSession.java | 43 +
.../subscription/SubscriptionTableSession.java | 22 +
.../SubscriptionTableSessionBuilder.java | 5 +
.../subscription/SubscriptionTreeSession.java | 22 +
.../SubscriptionTreeSessionBuilder.java | 5 +
.../consumer/ISubscriptionTablePullConsumer.java | 25 +
.../consumer/ISubscriptionTreePullConsumer.java | 25 +
.../base/AbstractSubscriptionConsumer.java | 655 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 23 +
.../base/AbstractSubscriptionProvider.java | 186 +-
.../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 | 11 +-
.../table/SubscriptionTablePullConsumer.java | 31 +
.../SubscriptionTablePullConsumerBuilder.java | 18 +
.../table/SubscriptionTablePushConsumer.java | 4 +
.../SubscriptionTablePushConsumerBuilder.java | 18 +
.../consumer/tree/SubscriptionTreeProvider.java | 11 +-
.../tree/SubscriptionTreePullConsumer.java | 48 +
.../tree/SubscriptionTreePullConsumerBuilder.java | 18 +
.../tree/SubscriptionTreePushConsumer.java | 21 +
.../tree/SubscriptionTreePushConsumerBuilder.java | 18 +
.../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 | 15 +-
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 +
.../operator/source/relational/Percentile.java | 173 +
.../relational/aggregation/AccumulatorFactory.java | 28 +-
.../relational/aggregation/ExtremeAccumulator.java | 32 +-
.../aggregation/PercentileAccumulator.java | 266 +
.../grouped/GroupedExtremeAccumulator.java | 70 +-
.../grouped/GroupedPercentileAccumulator.java | 291 +
.../grouped/array/PercentileBigArray.java | 73 +
.../queue/IndexedBlockingReserveQueue.java | 36 +-
.../calc/plan/planner/CommonOperatorUtils.java | 105 +-
.../calc/plan/planner/TableOperatorGenerator.java | 212 +-
.../iotdb/calc/utils/constant/SqlConstant.java | 1 +
.../fill/filter/FixedIntervalFillFilterTest.java} | 24 +-
.../aggregation/ExtremeAccumulatorTest.java | 150 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 3 +
.../iotdb/confignode/i18n/ManagerMessages.java | 14 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 7 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 3 +
.../iotdb/confignode/i18n/ManagerMessages.java | 20 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 7 +-
.../async/AsyncAINodeHeartbeatClientPool.java | 12 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 12 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 22 +-
.../client/async/CnToDnAsyncRequestType.java | 3 +
.../CnToDnInternalServiceAsyncRequestManager.java | 19 +
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 2 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 125 +-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 2 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 2 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 10 +
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 16 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 2 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 2 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 2 +-
.../ConsumerGroupPushMetaRPCHandler.java | 11 +-
...dler.java => PullCommitProgressRPCHandler.java} | 28 +-
.../rpc/subscription/TopicPushMetaRPCHandler.java | 11 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 81 +-
.../confignode/conf/ConfigNodeDescriptor.java | 207 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../CommitProgressHandleMetaChangePlan.java | 78 +
.../consensus/response/cq/ShowCQResp.java | 2 +-
.../externalservice/ShowExternalServiceResp.java | 2 +-
.../statemachine/ConfigRegionStateMachine.java | 404 +-
.../iotdb/confignode/manager/ConfigManager.java | 160 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 118 +-
.../confignode/manager/RetryFailedTasksThread.java | 23 +-
.../manager/consensus/ConsensusManager.java | 104 +-
.../iotdb/confignode/manager/load/LoadManager.java | 81 +
.../manager/load/balancer/RegionBalancer.java | 24 +-
.../manager/load/balancer/RouteBalancer.java | 9 +-
.../balancer/router/leader/HashLeaderBalancer.java | 2 +-
.../manager/load/cache/AbstractLoadCache.java | 6 +-
.../confignode/manager/load/cache/LoadCache.java | 27 +
.../load/cache/consensus/ConsensusGroupCache.java | 2 +-
.../manager/load/service/EventService.java | 23 +-
.../manager/load/service/HeartbeatService.java | 23 +-
.../manager/load/service/StatisticsService.java | 23 +-
.../manager/load/service/TopologyService.java | 17 +-
.../iotdb/confignode/manager/node/NodeManager.java | 8 +-
.../manager/partition/PartitionManager.java | 26 +-
.../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 | 20 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 8 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 22 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 4 +-
.../manager/schema/ClusterSchemaManager.java | 14 +-
.../schema/ClusterSchemaQuotaStatistics.java | 2 +-
.../subscription/SubscriptionCoordinator.java | 123 +
.../manager/subscription/SubscriptionManager.java | 15 +
.../subscription/SubscriptionMetaSyncer.java | 7 +
.../subscription/SubscriptionOwnerLeaseSyncer.java | 97 +
.../runtime/SubscriptionLeaderChangeHandler.java | 43 +
.../runtime/SubscriptionRuntimeCoordinator.java | 160 +
.../persistence/executor/ConfigPlanExecutor.java | 12 +-
.../confignode/persistence/pipe/PipeInfo.java | 8 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 64 +-
.../mnode/container/ConfigMNodeContainer.java | 2 +-
.../persistence/subscription/SubscriptionInfo.java | 331 +
.../iotdb/confignode/procedure/Procedure.java | 20 +
.../confignode/procedure/ProcedureExecutor.java | 134 +-
.../procedure/TimeoutExecutorThread.java | 32 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 403 +-
.../procedure/env/RegionMaintainHandler.java | 23 +
.../procedure/env/RemoveDataNodeHandler.java | 52 +-
.../procedure/impl/StateMachineProcedure.java | 3 +-
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../procedure/impl/node/AbstractNodeProcedure.java | 12 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 45 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 40 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 37 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 12 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 2 +-
.../impl/region/AddRegionPeerProcedure.java | 30 +-
.../impl/region/CreateRegionGroupsProcedure.java | 10 +-
.../schema/AlterEncodingCompressorProcedure.java | 2 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 2 +-
.../impl/schema/DeleteDatabaseProcedure.java | 2 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../AbstractOperateSubscriptionProcedure.java | 21 +
.../impl/subscription/SubscriptionOperation.java | 2 +
.../runtime/CommitProgressSyncProcedure.java | 320 +
.../runtime/ConsumerGroupMetaSyncProcedure.java | 10 +-
.../SubscriptionHandleLeaderChangeProcedure.java | 445 +
.../subscription/CreateSubscriptionProcedure.java | 85 +-
.../subscription/DropSubscriptionProcedure.java | 14 +
.../topic/runtime/TopicMetaSyncProcedure.java | 9 +-
.../impl/trigger/CreateTriggerProcedure.java | 2 +-
.../impl/trigger/DropTriggerProcedure.java | 2 +-
.../confignode/procedure/scheduler/LockQueue.java | 10 +-
.../scheduler/SimpleProcedureScheduler.java | 37 +-
.../procedure/store/ProcedureFactory.java | 12 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../iotdb/confignode/service/ConfigNode.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 22 +-
.../manager/consensus/ConsensusManagerTest.java | 116 +
.../confignode/manager/load/LoadManagerTest.java | 70 +
.../router/leader/HashLeaderBalancerTest.java | 65 +
.../task/PipeTaskCoordinatorLockTest.java | 60 +
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 212 +
.../pipe/PipeTaskInfoAutoRestartTest.java | 169 +-
.../pipe/PipeTaskInfoConsensusPipeTest.java | 4 +-
.../subscription/SubscriptionInfoTest.java | 194 +
.../SubscriptionInfoTopicValidationTest.java | 248 +
.../iotdb/confignode/procedure/TestLockRegime.java | 23 +
.../procedure/TestProcedureExecutor.java | 92 +
.../procedure/entity/SimpleLockProcedure.java | 11 +-
.../PipeHandleLeaderChangeProcedureTest.java | 47 +
.../DropSubscriptionProcedureTest.java | 3 +
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 47 +
iotdb-core/consensus/pom.xml | 4 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 28 +-
.../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 | 371 +-
.../iot/SubscriptionWalRetentionPolicy.java} | 48 +-
.../org/apache/iotdb/consensus/iot/WriterMeta.java | 112 +
.../consensus/iot/WriterSafeFrontierTracker.java | 145 +
.../iot/client/AsyncIoTConsensusServiceClient.java | 2 +-
.../consensus/iot/client/DispatchLogHandler.java | 45 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 3 +-
.../consensus/iot/log/ConsensusReqReader.java | 90 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 82 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 4 +
.../service/IoTConsensusRPCServiceProcessor.java | 43 +-
.../subscription/SubscriptionQueueRegistry.java | 124 +
.../SubscriptionWalRetentionCalculator.java | 126 +
.../ratis/ApplicationStateMachineProxy.java | 13 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 31 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +-
.../utils/NoHostnameVerificationTrustManager.java | 88 -
.../apache/iotdb/consensus/ratis/utils/Utils.java | 35 +-
.../simple/SimpleConsensusServerImpl.java | 4 +-
.../apache/iotdb/consensus/EmptyStateMachine.java | 4 +-
.../iot/AddPeerSnapshotLoadFailureTest.java | 354 +
.../apache/iotdb/consensus/iot/WriterMetaTest.java | 76 +
.../iot/WriterSafeFrontierTrackerTest.java | 56 +
.../consensus/iot/util/FakeConsensusReqReader.java | 20 +
.../iotdb/consensus/iot/util/TestStateMachine.java | 12 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 4 +-
.../consensus/simple/SimpleConsensusTest.java | 4 +-
iotdb-core/datanode/pom.xml | 8 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 23 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 51 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 11 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 22 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 55 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 11 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 2 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 18 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 46 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 60 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 13 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 4 +
.../db/consensus/DataRegionConsensusImpl.java | 6 +
.../db/consensus/SchemaRegionConsensusImpl.java | 3 +
.../dataregion/DataExecutionVisitor.java | 9 +-
.../dataregion/DataRegionStateMachine.java | 53 +-
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../schemaregion/SchemaRegionStateMachine.java | 25 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 16 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 129 +-
.../task/execution/PipeSubtaskExecutorManager.java | 24 +-
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 36 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 8 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 57 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 2 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 24 +-
.../common/tablet/PipeRawTabletEventConverter.java | 42 +-
.../event/common/tablet/PipeTabletCollector.java | 23 +-
.../tablet/parser/TabletInsertionEventParser.java | 123 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 2 +-
.../parser/scan/SinglePageWholeChunkReader.java | 2 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 12 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 15 +-
.../processor/aggregate/AggregateProcessor.java | 13 +-
.../downsampling/changing/ChangingValueFilter.java | 20 +-
.../sdt/SwingingDoorTrendingFilter.java | 19 +-
.../tumbling/TumblingTimeSamplingProcessor.java | 7 +-
.../exchange/sender/TwoStageAggregateSender.java | 2 +-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 3 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 126 +-
.../statement/PipeConvertedInsertRowStatement.java | 9 +
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 254 +-
.../resource/log/PipePeriodicalLogReducer.java | 93 -
.../resource/memory/InsertNodeMemoryEstimator.java | 15 +-
.../resource/memory/PipeDynamicMemoryBlock.java | 2 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 10 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 22 +-
.../batch/PipeTransferBatchReqBuilder.java | 43 +-
.../request/PipeTransferTabletBatchReq.java | 98 +-
.../request/PipeTransferTabletRawReq.java | 98 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 116 +
.../handler/PipeTransferTrackableHandler.java | 56 +-
.../async/handler/PipeTransferTsFileHandler.java | 2 +-
.../pipe/sink/util/TabletStatementConverter.java | 116 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 136 +-
.../PipeTsFileEpochProgressIndexKeeper.java | 2 +-
.../listener/PipeInsertionDataNodeListener.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 63 +-
.../iotdb/db/protocol/client/an/AINodeClient.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 108 +-
.../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 +-
.../InformationSchemaContentSupplierFactory.java | 4 +-
.../execution/operator/window/SessionWindow.java | 24 +-
.../operator/window/SessionWindowManager.java | 2 +-
.../execution/schedule/DriverScheduler.java | 15 +-
.../multilevelqueue/MultilevelPriorityQueue.java | 10 +
.../execution/schedule/task/DriverTask.java | 13 +
.../execution/schedule/task/DriverTaskId.java | 2 +-
.../metric/DriverSchedulerMetricSet.java | 13 +
.../iotdb/db/queryengine/plan/Coordinator.java | 32 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 34 +-
.../plan/analyze/ClusterPartitionFetcher.java | 38 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 31 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 17 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 4 +-
.../plan/execution/config/ConfigExecution.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 13 +
.../execution/config/TreeConfigTaskVisitor.java | 12 +
.../config/executor/ClusterConfigTaskExecutor.java | 59 +-
.../config/executor/IConfigTaskExecutor.java | 3 +
.../config/metadata/relational/ShowDBTask.java | 4 +-
.../config/sys/subscription/AlterTopicTask.java | 49 +
.../TableModelStatementMemorySourceVisitor.java | 54 +-
.../plan/expression/unary/InExpression.java | 2 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 17 +
.../planner/DataNodeTableOperatorGenerator.java | 12 +-
.../plan/AbstractFragmentParallelPlanner.java | 7 +-
.../planner/plan/node/PlanGraphJsonPrinter.java | 225 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 15 +
.../plan/node/load/LoadSingleTsFileNode.java | 36 +-
.../metadata/read/LevelTimeSeriesCountNode.java | 2 +-
.../node/metadata/read/TimeSeriesCountNode.java | 2 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 2 +-
.../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 +
.../relational/analyzer/AggregationAnalyzer.java | 84 +-
.../plan/relational/analyzer/Analysis.java | 26 +
.../relational/analyzer/StatementAnalyzer.java | 360 +-
.../relational/metadata/TableMetadataImpl.java | 28 +-
.../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 | 31 +-
.../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 +-
.../security/TreeAccessCheckVisitor.java | 7 +
.../sql/ast/{PipeEnriched.java => AlterTopic.java} | 53 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/ast/Explain.java | 28 +-
.../plan/relational/sql/ast/ExplainAnalyze.java | 37 +-
.../relational/sql/ast/ExplainOutputFormat.java | 31 +-
.../plan/relational/sql/ast/InsertRow.java | 5 +-
.../plan/relational/sql/ast/InsertRows.java | 14 +-
.../plan/relational/sql/ast/InsertTablet.java | 13 +-
.../plan/relational/sql/ast/PipeEnriched.java | 2 +-
.../relational/sql/ast/WrappedInsertStatement.java | 22 +-
.../plan/relational/sql/parser/AstBuilder.java | 103 +-
.../plan/relational/sql/parser/ErrorHandler.java | 6 +-
.../relational/sql/util/DataNodeSqlFormatter.java | 26 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 8 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 88 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
.../plan/statement/crud/InsertBaseStatement.java | 210 +-
.../plan/statement/crud/InsertRowStatement.java | 128 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 12 +
.../plan/statement/crud/InsertTabletStatement.java | 161 +-
.../statement/metadata/ShowDatabaseStatement.java | 8 +-
.../metadata/subscription/AlterTopicStatement.java | 73 +
.../FragmentInstanceStatisticsJsonDrawer.java | 372 +
.../schemaengine/schemaregion/ISchemaRegion.java | 10 +-
.../GeneralRegionAttributeSecurityService.java | 67 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 6 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 6 +-
.../logfile/FakeCRC32Deserializer.java | 3 +-
.../schemaregion/logfile/SchemaLogReader.java | 2 +-
.../mem/mnode/container/MemMNodeContainer.java | 2 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 69 +-
.../mnode/container/CachedMNodeContainer.java | 3 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 9 +-
.../db/schemaengine/table/DataNodeTableCache.java | 47 +-
.../schemaengine/table/InformationSchemaUtils.java | 7 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 10 +-
.../iotdb/db/storageengine/StorageEngine.java | 3 +
.../buffer/TimeSeriesMetadataCache.java | 43 +-
.../db/storageengine/dataregion/DataRegion.java | 80 +-
.../utils/writer/AbstractCompactionWriter.java | 165 +-
.../writer/AbstractCrossCompactionWriter.java | 3 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../utils/writer/FastInnerCompactionWriter.java | 10 +-
.../writer/ReadPointCrossCompactionWriter.java | 5 +-
.../writer/ReadPointInnerCompactionWriter.java | 5 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 4 +-
.../compaction/schedule/CompactionWorker.java | 2 +-
.../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 | 108 +-
.../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 +-
.../db/storageengine/load/LoadTsFileManager.java | 13 +
.../storageengine/load/active/ActiveLoadAgent.java | 6 +
.../load/active/ActiveLoadDirScanner.java | 17 +-
.../active/ActiveLoadScheduledExecutorService.java | 21 +-
.../load/active/ActiveLoadTsFileLoader.java | 27 +-
.../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 | 114 +-
.../broker/ConsensusSubscriptionBroker.java | 836 +
.../subscription/broker/ISubscriptionBroker.java | 93 +
.../db/subscription/broker/SubscriptionBroker.java | 64 +-
.../broker/SubscriptionPrefetchingQueue.java | 268 +-
.../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 +-
.../event/batch/SubscriptionPipeEventBatch.java | 23 +-
.../SubscriptionPipeEventBatchSegmentLock.java | 4 +-
.../event/batch/SubscriptionPipeEventBatches.java | 29 +
...nsensusSubscriptionPrefetchingQueueMetrics.java | 246 +
.../subscription/metric/SubscriptionMetrics.java | 2 +
.../receiver/SubscriptionReceiverV1.java | 361 +-
.../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 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 33 +
.../schemaRegion/SchemaRegionManagementTest.java | 28 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 25 +-
.../agent/task/PipeSinkSubtaskExecutorTest.java | 1 +
.../task/subtask/sink/PipeSinkSubtaskTest.java | 44 +
.../pipe/event/PipeTabletInsertionEventTest.java | 113 +
.../changing/ChangingValueFilterTest.java | 55 +
.../sdt/SwingingDoorTrendingFilterTest.java | 56 +
.../TumblingTimeSamplingProcessorTest.java | 192 +
.../plugin/TwoStageCountProcessorTest.java} | 29 +-
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 53 +-
.../PipeConvertedInsertRowStatementTest.java | 55 +
.../memory/InsertNodeMemoryEstimatorTest.java | 12 +
.../tsfile/PipeTsFileResourceSegmentLockTest.java | 71 +
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 627 +
.../handler/PipeTransferTrackableHandlerTest.java | 38 +-
.../sink/util/TabletStatementConverterTest.java | 64 +
...ricalDataRegionTsFileAndDeletionSourceTest.java | 100 +
.../PipeTsFileEpochProgressIndexKeeperTest.java | 46 +-
.../execution/aggregation/AccumulatorTest.java | 46 +
.../SlidingWindowAggregatorFactoryTest.java} | 26 +-
.../operator/ExplainAnalyzeOperatorTest.java | 96 +
.../operator/process/fill/NextFillTest.java | 299 +
.../process/window/function/FunctionTestUtils.java | 5 +-
.../operator/window/SessionWindowTest.java | 70 +
.../schedule/DefaultDriverSchedulerTest.java | 41 +
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 74 +
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 133 +-
...TableModelStatementMemorySourceVisitorTest.java | 88 +
.../plan/parser/StatementGeneratorTest.java | 15 +
.../distribution/AggregationTableScanTest.java | 4 +-
.../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 +-
.../analyzer/AggregationCornerCaseTest.java | 12 +-
.../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 +
.../relational/sql/parser/TopicStatementTest.java | 48 +
.../load/LoadTsFileDispatcherImplTest.java | 98 +
.../crud/InsertStatementPartialInsertTest.java | 320 +
.../FragmentInstanceStatisticsJsonDrawerTest.java | 594 +
.../schemaengine/table/DataNodeTableCacheTest.java | 106 +
.../buffer/TimeSeriesMetadataCacheTest.java | 280 +
.../storageengine/dataregion/DataRegionTest.java | 30 +-
.../utils/writer/AbstractCompactionWriterTest.java | 167 +
.../compaction/repair/AbstractRepairDataTest.java | 11 +-
.../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 | 124 +
.../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 +
.../receiver/SubscriptionReceiverV1Test.java | 95 +
.../iotdb/db/utils/ConfigurationFileUtilsTest.java | 90 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 88 +-
.../iotdb/db/utils/EnvironmentUtilsTest.java | 52 +
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 127 +
.../src/test/resources/iotdb-common.properties | 2 +-
.../src/test/resources/iotdb-system.properties | 3 +-
.../resources/conf/iotdb-system.properties | 1 -
.../conf/iotdb-system.properties.template | 90 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 8 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 1 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 8 +
.../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 +-
.../client/request/AsyncRequestManager.java | 19 +-
.../commons/client/sync/SyncAINodeClient.java | 3 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 3 +-
.../sync/SyncDataNodeInternalServiceClient.java | 3 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 3 +-
.../sync/SyncIoTConsensusV2ServiceClient.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 9 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 209 +-
.../iotdb/commons/conf/CommonDescriptor.java | 146 +
.../iotdb/commons/conf/ConfigurationFileUtils.java | 16 +-
.../commons/consensus/index/ProgressIndex.java | 11 +
.../iotdb/commons/partition/DataPartition.java | 18 +-
.../plugin/constructor/PipeSinkConstructor.java | 8 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 10 +-
.../pipe/agent/task/meta/PipeStaticMeta.java | 60 +
.../task/subtask/PipeAbstractSinkSubtask.java | 4 +-
.../agent/task/subtask/PipeReportableSubtask.java | 16 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 6 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 8 +-
.../pipe/config/constant/PipeSinkConstant.java | 22 +
.../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 | 3 +
.../function/TableBuiltinTableFunction.java | 4 +
.../{PreviousFillNode.java => NextFillNode.java} | 27 +-
.../relational/planner/node/PreviousFillNode.java | 5 +-
.../queryengine/plan/relational/sql/ast/Fill.java | 22 +-
.../plan/relational/sql/ast/GroupBy.java | 26 +-
.../sql/util/CommonQuerySqlFormatter.java | 12 +-
.../plan/statement/component/FillPolicy.java | 1 +
.../schema/column/ColumnHeaderConstant.java | 11 +-
.../commons/schema/table/InformationSchema.java | 6 +
.../schema/table/InsertNodeMeasurementInfo.java | 9 +-
.../service/AbstractThriftServiceThread.java | 52 +-
.../iotdb/commons/service/metric/enums/Metric.java | 4 +
.../subscription/config/SubscriptionConfig.java | 77 +-
.../meta/consumer/CommitProgressKeeper.java | 190 +
.../meta/consumer/ConsumerGroupMeta.java | 25 +
.../commons/subscription/meta/topic/TopicMeta.java | 267 +-
.../TableBuiltinAggregationFunction.java | 4 +-
.../relational/tvf/CapacityTableFunction.java | 69 +-
.../builtin/relational/tvf/M4TableFunction.java | 802 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 3 +
.../utils/KillPoint/RegionMaintainKillPoints.java | 34 +
.../org/apache/iotdb/commons/utils/PathUtils.java | 56 +-
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 47 +-
.../client/request/AsyncRequestManagerTest.java | 226 +
.../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 +
.../commons/subscription/topic/TopicDeSerTest.java | 200 +
.../relational/tvf/CapacityTableFunctionTest.java | 204 +
.../apache/iotdb/commons/utils/FileUtilsTest.java | 16 +-
.../iotdb/commons/utils/WindowsOSUtilsTest.java | 12 +
.../db/relational/grammar/sql/RelationalSql.g4 | 13 +-
.../thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/confignode.thrift | 27 +-
.../src/main/thrift/iotconsensus.thrift | 16 +-
.../src/main/thrift/datanode.thrift | 64 +-
library-udf/pom.xml | 4 +-
library-udf/src/assembly/tools/register-UDF.bat | 1 +
library-udf/src/assembly/tools/register-UDF.sh | 1 +
pom.xml | 129 +-
scripts/conf/confignode-env.sh | 61 +-
scripts/conf/datanode-env.sh | 70 +-
scripts/sbin/start-cli.sh | 13 +-
scripts/sbin/windows/start-cli.bat | 23 +-
scripts/sbin/windows/start-confignode.bat | 20 +-
scripts/sbin/windows/start-datanode.bat | 19 +-
scripts/tools/ops/health_check.sh | 2 +-
scripts/tools/windows/ops/health_check.bat | 4 +-
927 files changed, 61195 insertions(+), 24775 deletions(-)
copy .claude/settings.json => .codex/hooks.json (100%)
create mode 100755 .github/scripts/package-client-cpp-manylinux228.sh
delete mode 100644 .github/workflows/compile-check.yml
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/main/java/org/apache/iotdb/it/env/cluster/node/AINodeStarter.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/cli/it/ExplainJsonCliOutputIT.java
copy
integration-test/src/test/java/org/apache/iotdb/{subscription/it/local/AbstractSubscriptionLocalIT.java
=> confignode/it/regionmigration/IoTDBRegionMigrateITFrameworkForRatis.java}
(66%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/ratis/IoTDBRegionMigrateAddingPeerCrashForRatisIT.java
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/{iotv2/batch/IoTDBRegionMigrateClusterCrashIoTV2BatchIT.java
=> ratis/IoTDBRegionMigrateClusterCrashForRatisIT.java} (67%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/{iotv1/IoTDBRegionMigrateConfigNodeCrashIoTV1IT.java
=> ratis/IoTDBRegionMigrateConfigNodeCrashForRatisIT.java} (68%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/IoTDBRemoveDataNodeRegionAllocationIT.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/db/it/IoTDBSetConfigurationClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/performance/IoTDBSingleMeasurementCheckCachePerformanceIT.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/IoTDBGroupByAllTableIT.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/session/it/IoTDBClientSSLIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/cluster/IoTDBSubscriptionTopicOwnerPartitionIT.java
copy
integration-test/src/test/java/org/apache/iotdb/subscription/it/{local/AbstractSubscriptionLocalIT.java
=> consensus/local/AbstractSubscriptionConsensusLocalIT.java} (79%)
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
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionTopicOwnerIT.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
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java
=> iotdb-client/client-cpp/src/include/Endpoint.h (59%)
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 (97%)
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
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java
=> iotdb-client/client-cpp/src/rpc/ThriftConvert.h (58%)
rename iotdb-client/client-cpp/src/{main => session}/Column.cpp (100%)
rename iotdb-client/client-cpp/src/{main => session}/ColumnDecoder.cpp (100%)
rename iotdb-client/client-cpp/src/{main => session}/Common.cpp (52%)
create mode 100644 iotdb-client/client-cpp/src/session/Date.cpp
rename iotdb-client/client-cpp/src/{main => session}/Session.cpp (81%)
rename iotdb-client/client-cpp/src/{main => session}/SessionC.cpp (98%)
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 (92%)
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/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcSslUtils.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java
=>
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionOwnerFencedException.java
(53%)
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
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/Percentile.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/PercentileAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedPercentileAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/array/PercentileBigArray.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/SubscriptionOwnerLeaseSyncer.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/manager/pipe/coordinator/task/PipeTaskCoordinatorLockTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfoTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfoTopicValidationTest.java
copy
iotdb-core/consensus/src/{test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
=>
main/java/org/apache/iotdb/consensus/iot/SubscriptionWalRetentionPolicy.java}
(51%)
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
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/NoHostnameVerificationTrustManager.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/AddPeerSnapshotLoadFailureTest.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/execution/config/sys/subscription/AlterTopicTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphJsonPrinter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{PipeEnriched.java
=> AlterTopic.java} (57%)
copy
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ExplainOutputFormat.java
(59%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/AlterTopicStatement.java
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/relational/sql/parser/TopicStatementTest.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/schemaengine/table/DataNodeTableCacheTest.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/compaction/execute/utils/writer/AbstractCompactionWriterTest.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/datanode/src/test/java/org/apache/iotdb/db/utils/EnvironmentUtilsTest.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/main/java/org/apache/iotdb/commons/utils/KillPoint/RegionMaintainKillPoints.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/request/AsyncRequestManagerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/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
