This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch show-create-remain
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 438d1652056 Address show create review comments
add 93438bf34ba fix: supply the key word in antlr module (#17789)
add 33c3ef7196b Pipe: Harden legacy pipe file transfer validation and
access checks (#17741)
add b616502aec0 Pipe Log: Added the remaining chinese logs & Further
reduced the repeatable logs (#17700)
add a2368b2955f Fix C++ client reading FLOAT inference columns declared as
DOUBLE (#17759)
add 084837923f7 Update IoTDBLegacyPipeReceiverSecurityIT.java (#17795)
(#17796)
add 958ce45b137 Fix repeated RPC dispatch reusing a released
FragmentInstanceContext (NPE) (#17794)
add a565a068253 Added flags to mark whether a device has device
descendants to optimize query like select xx from xxx.** (#17672)
add 44d4f6d962e Optimized write performace by reducing separators (#17670)
add 89730b14397 Optimized the overall performance of IoTDB & Fixed the NPE
in LimitOperatorTest (#17664)
add b614d6d16b5 Pipe: Fixed the bug that drop pipe may stuck when
disruptor is interrupted or ring buffer full (#17673)
add 29d0d51dc74 Fix CQ recovery gap and stale callback contamination
(#17734)
add 7a8079d1524 Table: Ignore null attribute values in insert (#17790)
add d9fdf0c6655 C++ client: add thread-safe SessionPool, enable RPC
compression, and harden buffers (#17800)
add f4d7ec4a8ae Fix alter pipe password check after restart for write-back
sink. (#17771)
add f5d2cd82177 Pipe IT: Stabilize leader stop test (#17809)
add 99f0af16c89 Fix flaky space quota IT (#17812)
add 011bdecb77c Fix WAL search index freezing (#17811)
add a4206813a06 Revert "Fix CQ recovery gap and stale callback
contamination (#17734)" (#17827)
add a077c04d57e Reapply "Fix CQ recovery gap and stale callback
contamination (#17734)" (#17827) (#17828)
add 2a6f35c6c09 Ratis CI: Fixed the ratis CI port clash & Optimized the
logs to avoid printing JVM crash (#17675)
add 59b79efb17e Pipe: account page decode memory in scan parser (#17807)
add f44d9b7bf3b Fix count and show timeseries follow-up (#17804)
add b46c58b324d Fix pipe tsfile receiver database handling (#17815)
add c818b289e79 Feature/iotconsensus snap multi dir (#16811)
add e2322e9e9e5 [AINode] Remove Chronos2 DataLoader pin_memory option
(#17822)
add 709145cc00b Fixed UDF jar metadata handling in `UDFInfo` when multiple
UDFs share the same jar (#17732)
add 2fd70b9d1b1 Fix flaky stamped lock test (#17832)
add 66d0c07bb09 Remove useless ProjectNode after SortElimination (#17806)
add dacbf9268db Optimize InsertTabletStatement tablet conversion (#17805)
add 99bf6d4c6b1 Add statistical type aggregate functions, including
autocorrelation, skewness, and linear regression (#17292)
add 187e4547c0c Fix table delete with renamed time column (#17841)
add 1d8b23a8e54 Ignore non-exist object folder when removing a region
(#17840)
add 543e03e9fa2 Fix account unlock propagation for pipe password checks
(#17814)
add eaa5bcb012e Fix pipe permission retry and table parser progress
(#17844)
add 373af669686 Set keepSameDiskWhenLoadingSnapshot default to true
(#17845)
add 16d3669edb1 Fix operator tests for transient null TsBlocks (#17838)
add 594fb879c4d Support table-less SELECT queries without FROM clause
(#17437)
add 63dfac842f7 Fix window function state reset across batches (#17813)
add d182c87a401 Fix PBTree schema cache release after pre-delete (#17834)
add d563cd046e2 Improve query modification loading memory control (#17788)
add eb4409d8b02 Add threat model + security-model discoverability
(AGENTS.md -> SECURITY.md -> THREAT_MODEL.md) (#17823)
add 90055d55b6e Fix pipe receiver type conversion load path (#17849)
add 4747d5f243f Optimize local load TsFile piece dispatch (#17851)
add d09785eaaba Support sink config key for pipe request slicing (#17858)
add 4d55d5121df Optimize load partition routing (#17863)
add 6532d297bca Optimize pipe event batching and listener stop (#17864)
add ab887eb98ea Fix relational delete node serialization (#17867)
add 3d98ea5fd78 Fix Windows path segment validation (#17868)
add faba002feb9 Refactor/cpp client sdk (#17801)
add 0987f6a9a48 Subscription: implement IoTConsensus-based subscription
(#17238)
add ffddfde81ec [IOTDB-17798] Implement table model NEXT fill (#17810)
add a437cd469b7 Add SLIDE parameter support to CAPACITY table-valued
function (#17456)
add c032ea00049 Fix Windows C++ client README commands (#17881)
add c3e74a2a68e Fix AddConfigNode retry idempotency (#17874)
add 07b9cb086a9 Fix empty snapshot loading and region cleanup (#17880)
add 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)
add c2fdc634b1f Fix pipe text date conversion (#17984)
add 28c4e68a6c4 Fix pipe tree database creation on receiver (#17991)
add eef45ff778a Update thrift to 0.23.0 (#17945)
add cbe5847e350 Support readTsFile table function for external TsFiles
(#17951)
add ae7a5dec06e Fix/min folder occupied space cache (#17996)
add 5f968335e12 Fix SingleDeviceViewOperatorTest row assertion (#17995)
add 511d08f6994 Allow idle Pipe worker threads to time out (#18000)
add cb97fe44ca6 Load: Optimized the downgraded logic for tsFile to insert
more data when tsFile corrupted (#17674)
add aa2acd6b4f5 Fix short reads in fixed-length deserialization (#17870)
add b6c217abd3d Pipe: Fix delete inclusion aliases and metrics maps
(#18002)
add b727c66eec4 Reclaim the statement variable to avoid executing stale
statements in the subsequent new test case (#18001)
add c1843f2ff7e Fix C++ client tablet bounds and session close semantics
(#18005)
add a98bd569bd0 Supply the max_schema/data_region_group_num param to
modify schema when create or alter database (#17988)
add 7a23a98f636 Exclude unused thrift Jakarta annotations (#18011)
add 5467513eaa2 Fix flaky multilevel priority queue test (#18013)
add 8ca049d8b8c Fix/unconsensus tsfile mods (#18008)
add 15dba18b1c7 Fix aggregation metric recording (#18018)
add a303507e928 merge
No new revisions were added by this update.
Summary of changes:
.claude/settings.json => .codex/hooks.json | 0
.github/scripts/package-client-cpp-manylinux228.sh | 140 +
.github/workflows/client-cpp-package.yml | 489 +-
.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 | 100 +-
.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 | 11 +-
CONTRIBUTING.md | 5 +-
Jenkinsfile | 2 +-
LICENSE-binary | 45 +-
README.md | 4 +-
README_ZH.md | 4 +-
SECURITY.md | 29 +
THREAT_MODEL.md | 208 +
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 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 6 +
.../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 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 2 -
.../it/env/remote/config/RemoteCommonConfig.java | 52 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../constant/BuiltinAggregationFunctionEnum.java | 9 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 28 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 23 +-
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../itbase/runtime/ParallelRequestDelegate.java | 13 +-
.../iotdb/ainode/it/AINodeSharedClusterIT.java | 83 +
.../iotdb/cli/it/ExplainJsonCliOutputIT.java | 345 +
.../it/database/IoTDBDatabaseRegionControlIT.java | 18 +-
...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 +
...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 180 +
...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 +-
.../aggregation/IoTDBStatisticalAggregationIT.java | 590 +
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 48 +-
...DBSingleMeasurementCheckCachePerformanceIT.java | 207 +
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 30 +-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 11 +-
.../regionscan/IoTDBActiveSchemaQueryIT.java | 13 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 12 +-
.../pipe/it/dual/TypeConversionSemanticCase.java | 315 +
.../manual/basic/IoTDBPipeLifeCycleIT.java | 2 +-
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 24 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 28 +-
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 8 +
.../manual/enhanced/IoTDBPipeMetaIT.java | 1 -
.../manual/enhanced/IoTDBPipeSinkParallelIT.java | 1 +
.../IoTDBPipeTypeConversionISessionIT.java | 1 +
.../IoTDBPipeTypeConversionSemanticIT.java | 255 +
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 2 +-
.../auto/basic/IoTDBPipeSinkParallelIT.java | 1 +
.../auto/enhanced/IoTDBPipeClusterIT.java | 28 +-
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 6 +-
.../IoTDBPipeTypeConversionSemanticIT.java | 259 +
.../treemodel/manual/IoTDBPipePermissionIT.java | 1 +
.../manual/IoTDBPipeTypeConversionISessionIT.java | 3 +-
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 113 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 21 +
.../relational/it/db/it/IoTDBInsertTableIT.java | 35 +
.../db/it/IoTDBWindowFunctionBatchedResultIT.java | 94 +
.../relational/it/db/it/IoTDBWindowTVFIT.java | 435 +
.../it/db/it/udf/IoTDBSQLFunctionManagementIT.java | 3 +-
.../it/insertquery/IoTDBInsertQueryIT.java | 4 +-
.../it/query/recent/IoTDBComplexQueryIT.java | 28 +
.../it/query/recent/IoTDBFillTableIT.java | 155 +
.../it/query/recent/IoTDBGroupByAllTableIT.java | 238 +
.../recent/IoTDBReadTsFileTableFunctionIT.java | 622 +
.../it/query/recent/IoTDBTableAggregationIT.java | 346 +
.../it/query/recent/IoTExplainJsonFormatIT.java | 855 +
.../it/schema/IoTDBAlterColumnTypeIT.java | 11 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 94 +-
.../schema/IoTDBDatabaseMaxRegionGroupNumIT.java | 229 +
.../IoTDBDatabaseMixedRegionGroupPolicyIT.java | 83 +
.../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 | 5 +
.../src/{main => include}/ColumnDecoder.h | 0
.../client-cpp/src/{main => include}/Common.h | 146 +-
iotdb-client/client-cpp/src/include/Date.h | 74 +
.../client-cpp/src/{main => include}/DeviceID.h | 0
.../client-cpp/src/include/Endpoint.h | 30 +-
.../client-cpp/src/include/Export.h | 22 +-
iotdb-client/client-cpp/src/include/Optional.h | 77 +
.../client-cpp/src/{main => include}/Session.h | 372 +-
.../src/{main => include}/SessionBuilder.h | 0
.../client-cpp/src/{main => include}/SessionC.h | 12 +
.../client-cpp/src/include/SessionConfig.h | 23 +-
.../client-cpp/src/include/SessionDataSet.h | 124 +
iotdb-client/client-cpp/src/include/SessionPool.h | 392 +
.../client-cpp/src/include/Status.h | 20 +-
.../src/{main => include}/TableSession.h | 0
.../src/{main => include}/TableSessionBuilder.h | 0
.../client-cpp/src/{main => include}/TsBlock.h | 0
iotdb-client/client-cpp/src/main/CMakeLists.txt | 90 -
.../client-cpp/src/main/SessionDataSet.cpp | 25 +-
iotdb-client/client-cpp/src/main/SessionDataSet.h | 124 -
.../src/{main => rpc}/IoTDBRpcDataSet.cpp | 74 +-
.../client-cpp/src/{main => rpc}/IoTDBRpcDataSet.h | 51 +-
.../client-cpp/src/{main => rpc}/NodesSupplier.cpp | 11 +-
.../client-cpp/src/{main => rpc}/NodesSupplier.h | 9 +-
iotdb-client/client-cpp/src/rpc/RpcCommon.cpp | 214 +
iotdb-client/client-cpp/src/rpc/RpcCommon.h | 81 +
.../src/{main => rpc}/SessionConnection.cpp | 34 +-
.../src/{main => rpc}/SessionConnection.h | 20 +-
.../client-cpp/src/rpc/SessionDataSetFactory.h | 42 +
iotdb-client/client-cpp/src/rpc/SessionImpl.h | 238 +
.../src/{main => rpc}/ThriftConnection.cpp | 16 +-
.../src/{main => rpc}/ThriftConnection.h | 4 +-
iotdb-client/client-cpp/src/rpc/ThriftConvert.cpp | 61 +
.../client-cpp/src/rpc/ThriftConvert.h | 28 +-
.../client-cpp/src/{main => session}/Column.cpp | 20 +
.../src/{main => session}/ColumnDecoder.cpp | 0
.../client-cpp/src/{main => session}/Common.cpp | 226 +-
iotdb-client/client-cpp/src/session/Date.cpp | 63 +
.../client-cpp/src/{main => session}/Session.cpp | 534 +-
.../client-cpp/src/{main => session}/SessionC.cpp | 49 +-
.../client-cpp/src/session/SessionDataSet.cpp | 320 +
.../client-cpp/src/session/SessionPool.cpp | 281 +
.../src/{main => session}/TableSession.cpp | 0
.../client-cpp/src/{main => session}/TsBlock.cpp | 0
iotdb-client/client-cpp/src/test/CMakeLists.txt | 152 -
iotdb-client/client-cpp/src/test/catch2/catch.hpp | 17974 -------------------
iotdb-client/client-cpp/test/CMakeLists.txt | 104 +
iotdb-client/client-cpp/test/catch2/.gitignore | 4 +
.../client-cpp/{src => }/test/cpp/sessionCIT.cpp | 63 +-
.../{src => }/test/cpp/sessionCRelationalIT.cpp | 13 +
.../client-cpp/{src => }/test/cpp/sessionIT.cpp | 189 +-
.../{src => }/test/cpp/sessionRelationalIT.cpp | 20 +-
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 +
.../org/apache/iotdb/isession/SessionDataSet.java | 27 +-
iotdb-client/jdbc/README.md | 4 +-
iotdb-client/jdbc/src/main/feature/feature.xml | 2 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 4 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 5 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 9 +
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 6 +
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 11 +
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 29 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 47 +-
.../java/org/apache/iotdb/rpc/RpcSslUtils.java | 245 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +-
.../iotdb/rpc/TNonblockingTransportWrapper.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 10 +-
.../java/org/apache/iotdb/rpc/TSocketWrapper.java | 4 +-
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 13 +-
.../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 | 196 +-
.../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 +
.../request_scheduler/basic_request_scheduler.py | 19 +-
.../core/model/chronos2/pipeline_chronos2.py | 1 -
iotdb-core/ainode/iotdb/ainode/core/rpc/client.py | 11 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 5 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 19 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +-
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 +
.../aggregation/CentralMomentAccumulator.java | 302 +
.../aggregation/CorrelationAccumulator.java | 261 +
.../aggregation/CovarianceAccumulator.java | 250 +
.../aggregation/RegressionAccumulator.java | 265 +
.../execution/operator/CommonOperatorContext.java | 15 +
.../operator/process/TableNextFillOperator.java | 81 +
.../process/TableNextFillWithGroupOperator.java | 165 +
.../fill/filter/FixedIntervalFillFilter.java | 10 +-
.../operator/process/fill/next/NextFill.java | 182 +
.../process/window/TableWindowOperator.java | 2 +-
.../window/partition/PartitionExecutor.java | 11 +-
.../operator/source/relational/Percentile.java | 173 +
.../relational/aggregation/AccumulatorFactory.java | 97 +-
.../aggregation/AggregationOperator.java | 15 +-
.../relational/aggregation/ExtremeAccumulator.java | 32 +-
.../aggregation/PercentileAccumulator.java | 266 +
.../relational/aggregation/TableAggregator.java | 49 +-
.../aggregation/TableCentralMomentAccumulator.java | 298 +
.../aggregation/TableCorrelationAccumulator.java | 277 +
.../aggregation/TableCovarianceAccumulator.java | 272 +
.../aggregation/TableRegressionAccumulator.java | 283 +
.../grouped/GroupedCentralMomentAccumulator.java | 270 +
.../grouped/GroupedCorrelationAccumulator.java | 246 +
.../grouped/GroupedCovarianceAccumulator.java | 242 +
.../grouped/GroupedExtremeAccumulator.java | 70 +-
.../grouped/GroupedPercentileAccumulator.java | 291 +
.../grouped/GroupedRegressionAccumulator.java | 263 +
.../grouped/StreamingAggregationOperator.java | 9 +-
.../grouped/array/PercentileBigArray.java | 73 +
.../builder/InMemoryHashAggregationBuilder.java | 9 +-
.../queue/IndexedBlockingReserveQueue.java | 36 +-
.../iotdb/calc/metric/QueryExecutionMetricSet.java | 15 +-
.../calc/plan/planner/CommonOperatorUtils.java | 105 +-
.../calc/plan/planner/TableOperatorGenerator.java | 233 +-
.../planner/memory/MemoryReservationManager.java | 8 +
.../datastructure/SerializableList.java | 3 +-
.../iotdb/calc/utils/constant/SqlConstant.java | 8 +
.../iotdb/calc/utils/sort/FileSpillerReader.java | 4 +-
.../fill/filter/FixedIntervalFillFilterTest.java} | 24 +-
.../aggregation/ExtremeAccumulatorTest.java | 150 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 7 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 14 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 7 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 7 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 34 +-
.../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 | 6 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
.../request/ConfigPhysicalPlanVisitor.java | 12 +
.../consensus/request/read/cq/ShowCQPlan.java | 13 +
.../consensus/request/write/cq/ActiveCQPlan.java | 20 +-
.../consensus/request/write/cq/AddCQPlan.java | 20 +-
.../consensus/request/write/cq/DropCQPlan.java | 20 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 23 +-
.../CommitProgressHandleMetaChangePlan.java | 78 +
.../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/cq/CQManager.java | 102 +-
.../confignode/manager/cq/CQScheduleTask.java | 58 +-
.../externalservice/ExternalServiceInfo.java | 3 +-
.../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 | 36 +-
.../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 | 275 +-
.../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 +
.../confignode/persistence/ProcedureInfo.java | 13 +-
.../iotdb/confignode/persistence/UDFInfo.java | 54 +-
.../confignode/persistence/auth/AuthorInfo.java | 6 +-
.../persistence/auth/AuthorPlanExecutor.java | 12 +
.../iotdb/confignode/persistence/cq/CQInfo.java | 76 +-
.../persistence/executor/ConfigPlanExecutor.java | 16 +-
.../confignode/persistence/pipe/PipeInfo.java | 8 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 64 +-
.../persistence/schema/ClusterSchemaInfo.java | 24 +-
.../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 | 82 +-
.../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/sync/AuthOperationProcedure.java | 6 +
.../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/ConfigNodeRPCServiceHandler.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 22 +-
.../writelog/io/SingleFileLogReader.java | 5 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../apache/iotdb/confignode/cq/CQManagerTest.java | 107 +
.../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 +
.../iotdb/confignode/persistence/CQInfoTest.java | 64 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 92 +-
.../persistence/auth/AuthorPlanExecutorTest.java | 80 +
.../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 +-
.../procedure/impl/CreateCQProcedureTest.java | 26 +
.../impl/cq/CreateCQProcedureRecoveryTest.java | 117 +
.../PipeHandleLeaderChangeProcedureTest.java | 47 +
.../DropSubscriptionProcedureTest.java | 3 +
.../impl/sync/AuthOperationProcedureTest.java | 56 +
.../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/ConsensusConfig.java | 35 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 33 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 22 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 73 +-
.../consensus/iot/IoTConsensusServerImpl.java | 454 +-
.../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 +
.../iot/service/IoTConsensusRPCServiceHandler.java | 4 +-
.../service/IoTConsensusRPCServiceProcessor.java | 43 +-
.../subscription/SubscriptionQueueRegistry.java | 124 +
.../SubscriptionWalRetentionCalculator.java | 126 +
.../service/IoTConsensusV2RPCServiceHandler.java | 4 +-
.../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/ReplicateTest.java | 27 +
.../apache/iotdb/consensus/iot/StabilityTest.java | 8 +
.../apache/iotdb/consensus/iot/WriterMetaTest.java | 76 +
.../iot/WriterSafeFrontierTrackerTest.java | 56 +
.../consensus/iot/util/FakeConsensusReqReader.java | 20 +
.../iotdb/consensus/iot/util/TestStateMachine.java | 12 +-
.../iotdb/consensus/ratis/RecoverReadTest.java | 9 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 74 +-
.../consensus/simple/SimpleConsensusTest.java | 4 +-
iotdb-core/datanode/pom.xml | 8 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 23 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 72 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 119 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 22 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 129 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 118 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 2 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 35 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 7 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 18 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 59 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 66 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 13 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 4 +
.../db/consensus/DataRegionConsensusImpl.java | 11 +
.../db/consensus/SchemaRegionConsensusImpl.java | 3 +
.../dataregion/DataExecutionVisitor.java | 14 +-
.../dataregion/DataRegionStateMachine.java | 53 +-
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../schemaregion/SchemaRegionStateMachine.java | 25 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 22 +-
.../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 +-
.../consensus/deletion/recover/DeletionReader.java | 5 +-
.../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 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 10 +-
.../query/TsFileInsertionEventQueryParser.java | 108 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 57 +-
.../parser/scan/MemoryControlledChunkReader.java | 76 +
.../parser/scan/SinglePageWholeChunkReader.java | 195 +-
.../scan/TsFileInsertionEventScanParser.java | 110 +-
.../table/TsFileInsertionEventTableParser.java | 197 +-
.../metric/processor/PipeProcessorMetrics.java | 3 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 12 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 18 +-
.../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 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 6 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 43 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 331 +-
.../transform/converter/ValueConverter.java | 30 +-
.../statement/PipeConvertedInsertRowStatement.java | 9 +
.../visitor/PipeStatementExceptionVisitor.java | 7 +
...eeStatementDataTypeConvertExecutionVisitor.java | 13 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 254 +-
.../resource/log/PipePeriodicalLogReducer.java | 93 -
.../resource/memory/InsertNodeMemoryEstimator.java | 15 +-
.../resource/memory/PipeDynamicMemoryBlock.java | 2 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 10 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 28 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 22 +-
.../batch/PipeTransferBatchReqBuilder.java | 43 +-
.../request/PipeTransferTabletBatchReq.java | 98 +-
.../request/PipeTransferTabletRawReq.java | 98 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 103 +-
.../handler/IoTConsensusV2DeleteEventHandler.java | 16 +-
.../IoTConsensusV2TabletBatchEventHandler.java | 20 +-
.../IoTConsensusV2TabletInsertionEventHandler.java | 17 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 18 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 29 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 149 +-
.../handler/PipeTransferTrackableHandler.java | 69 +-
.../async/handler/PipeTransferTsFileHandler.java | 23 +-
.../sink/protocol/writeback/WriteBackSink.java | 21 +-
.../pipe/sink/util/TabletStatementConverter.java | 116 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 6 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 136 +-
.../PipeRealtimeDataRegionHybridSource.java | 4 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 5 +-
.../realtime/PipeRealtimeDataRegionSource.java | 8 +-
.../PipeRealtimeDataRegionTsFileSource.java | 5 +-
.../realtime/assigner/DisruptorQueue.java | 19 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 41 +-
.../PipeTsFileEpochProgressIndexKeeper.java | 2 +-
.../realtime/disruptor/BatchEventProcessor.java | 11 +-
.../realtime/disruptor/MultiProducerSequencer.java | 21 +
.../dataregion/realtime/disruptor/RingBuffer.java | 22 +-
.../listener/PipeInsertionDataNodeListener.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 63 +-
.../iotdb/db/protocol/client/an/AINodeClient.java | 3 +-
.../iotdb/db/protocol/session/SessionManager.java | 6 +-
.../thrift/handler/BaseServerContextHandler.java | 7 +-
.../handler/InternalServiceThriftHandler.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 63 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 128 +-
.../db/queryengine/common/MPPQueryContext.java | 81 +
.../db/queryengine/common/TimeseriesContext.java | 234 +-
.../db/queryengine/execution/StateMachine.java | 8 +-
.../execution/aggregation/AccumulatorFactory.java | 39 +
.../execution/aggregation/ExtremeAccumulator.java | 32 +-
.../execution/aggregation/TreeAggregator.java | 92 +-
.../SlidingWindowAggregatorFactory.java | 43 +-
.../MPPDataExchangeServiceThriftHandler.java | 3 +-
.../execution/executor/RegionReadExecutor.java | 23 +-
.../fragment/FragmentInstanceContext.java | 205 +-
.../fragment/FragmentInstanceManager.java | 79 +-
.../execution/fragment/QueryContext.java | 24 +-
.../fragment/QueryModificationLoader.java | 314 +
.../execution/operator/ExplainAnalyzeOperator.java | 70 +-
.../execution/operator/OperatorContext.java | 27 +
.../operator/process/AggregationOperator.java | 25 +-
.../process/RawDataAggregationOperator.java | 129 +-
.../operator/process/TagAggregationOperator.java | 15 +-
.../schema/source/SchemaSourceFactory.java | 19 +-
.../schema/source/TimeSeriesSchemaSource.java | 29 +-
.../AbstractSeriesAggregationScanOperator.java | 26 +-
.../source/ActiveTimeSeriesRegionScanOperator.java | 77 +-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../execution/operator/source/FileLoaderUtils.java | 19 +-
.../execution/operator/source/SeriesScanUtil.java | 46 +-
.../relational/AbstractAggTableScanOperator.java | 127 +-
.../AbstractDefaultAggTableScanOperator.java | 2 +-
.../relational/AbstractTableScanOperator.java | 31 +-
.../ExternalTsFileAggTableScanOperator.java | 180 +
.../relational/ExternalTsFileSeriesScanUtil.java | 94 +
.../ExternalTsFileTableScanOperator.java | 168 +
.../InformationSchemaContentSupplierFactory.java | 12 +-
.../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 | 48 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 57 +-
.../plan/analyze/ClusterPartitionFetcher.java | 38 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 12 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 31 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 17 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 4 +-
.../queryengine/plan/execution/QueryExecution.java | 8 +-
.../plan/execution/config/ConfigExecution.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 32 +-
.../execution/config/TreeConfigTaskVisitor.java | 12 +
.../config/executor/ClusterConfigTaskExecutor.java | 59 +-
.../config/executor/IConfigTaskExecutor.java | 3 +
.../config/metadata/DatabaseSchemaTask.java | 9 +-
.../config/metadata/ShowFunctionsTask.java | 6 +
.../metadata/relational/AbstractDatabaseTask.java | 4 +-
.../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 | 36 +-
.../planner/DataNodeTableOperatorGenerator.java | 81 +-
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../plan/planner/LogicalPlanVisitor.java | 8 +-
.../plan/planner/OperatorTreeGenerator.java | 8 +-
.../plan/planner/distribution/SourceRewriter.java | 10 +-
.../memory/FakedMemoryReservationManager.java | 3 +
.../NotThreadSafeMemoryReservationManager.java | 9 +
.../memory/ThreadSafeMemoryReservationManager.java | 5 +
.../plan/AbstractFragmentParallelPlanner.java | 7 +-
.../planner/plan/node/PlanGraphJsonPrinter.java | 225 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 24 +
.../plan/planner/plan/node/PlanVisitor.java | 10 +
.../plan/node/load/LoadSingleTsFileNode.java | 36 +-
.../metadata/read/LevelTimeSeriesCountNode.java | 50 +-
.../node/metadata/read/TimeSeriesCountNode.java | 51 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 2 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 55 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 44 +
.../plan/node/source/TimeseriesRegionScanNode.java | 7 +
.../planner/plan/node/write/DeleteDataNode.java | 17 +-
.../plan/node/write/InsertMultiTabletsNode.java | 24 +
.../plan/planner/plan/node/write/InsertNode.java | 79 +-
.../planner/plan/node/write/InsertRowNode.java | 228 +-
.../planner/plan/node/write/InsertRowsNode.java | 34 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 26 +-
.../planner/plan/node/write/InsertTabletNode.java | 400 +-
.../plan/planner/plan/node/write/ObjectNode.java | 14 +-
.../plan/node/write/RelationalDeleteDataNode.java | 36 +-
.../plan/node/write/RelationalInsertRowNode.java | 67 +-
.../plan/node/write/RelationalInsertRowsNode.java | 52 +-
.../node/write/RelationalInsertTabletNode.java | 121 +-
.../plan/planner/plan/node/write/SearchNode.java | 114 +
.../plan/parameter/AggregationDescriptor.java | 21 +
.../relational/analyzer/AggregationAnalyzer.java | 84 +-
.../plan/relational/analyzer/Analysis.java | 26 +
.../relational/analyzer/StatementAnalyzer.java | 364 +-
.../ConvertSchemaPredicateToFilterVisitor.java | 17 +-
.../DataNodeTableBuiltinTableFunction.java | 65 +
.../tvf/read_tsfile/DeviceTaskRunCursor.java | 124 +
.../ExternalTsFileDeviceFilterVisitor.java | 54 +
.../read_tsfile/ExternalTsFileDeviceQueryTask.java | 97 +
.../read_tsfile/ExternalTsFileQueryDataSource.java | 49 +
.../read_tsfile/ExternalTsFileQueryResource.java | 749 +
.../tvf/read_tsfile/ReadTsFileTableFunction.java | 305 +
.../tvf/read_tsfile/TsFileSchemaCollector.java | 348 +
.../relational/metadata/TableMetadataImpl.java | 85 +-
.../fetcher/TableDeviceSchemaValidator.java | 44 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 6 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 4 +-
.../cache/TreeDeviceSchemaCacheManager.java | 9 +-
.../plan/relational/planner/CteMaterializer.java | 1 +
.../plan/relational/planner/PredicateUtils.java | 28 +-
.../plan/relational/planner/QueryPlanner.java | 34 +-
.../plan/relational/planner/RelationPlanner.java | 100 +-
.../relational/planner/TableLogicalPlanner.java | 3 +-
.../distribute/TableDistributedPlanGenerator.java | 216 +-
.../distribute/TableDistributedPlanner.java | 16 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 2 +
.../planner/iterative/rule/PruneFillColumns.java | 5 +
.../iterative/rule/PruneTableScanColumns.java | 75 +-
.../planner/node/AggregationTableScanNode.java | 54 +
.../planner/node/ExplainAnalyzeNode.java | 39 +-
.../node/ExternalTsFileAggregationScanNode.java | 181 +
.../planner/node/ExternalTsFileScanNode.java | 172 +
.../planner/optimizations/ParallelizeGrouping.java | 18 +-
.../PushAggregationIntoTableScan.java | 49 +-
.../PushLimitOffsetIntoTableScan.java | 25 +-
.../optimizations/PushPredicateIntoTableScan.java | 62 +-
.../planner/optimizations/SortElimination.java | 46 +
.../optimizations/TransformSortToStreamSort.java | 27 +-
.../optimizations/UnaliasSymbolReferences.java | 87 +-
.../security/TreeAccessCheckVisitor.java | 106 +-
.../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} | 24 +-
.../plan/relational/sql/ast/InsertRow.java | 5 +-
.../plan/relational/sql/ast/InsertRows.java | 14 +-
.../plan/relational/sql/ast/InsertTablet.java | 30 +-
.../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/FragmentInstanceDispatcherImpl.java | 15 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 8 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 89 +-
.../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 | 275 +-
.../plan/statement/crud/LoadTsFileStatement.java | 25 +
.../plan/statement/metadata/CountStatement.java | 9 +
.../metadata/DatabaseSchemaStatement.java | 32 +-
.../statement/metadata/ShowDatabaseStatement.java | 8 +-
.../metadata/subscription/AlterTopicStatement.java | 73 +
.../FragmentInstanceStatisticsJsonDrawer.java | 372 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 9 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 10 +-
.../GeneralRegionAttributeSecurityService.java | 67 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 6 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 6 +-
.../logfile/FakeCRC32Deserializer.java | 8 +-
.../schemaregion/logfile/SchemaLogReader.java | 2 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 81 +-
.../mtree/impl/mem/mnode/IMemMNode.java | 23 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 21 +-
.../mem/mnode/container/MemMNodeContainer.java | 2 +-
.../impl/mem/mnode/impl/AboveDatabaseMNode.java | 10 -
.../mtree/impl/mem/mnode/impl/DatabaseMNode.java | 10 -
.../impl/mem/mnode/impl/MeasurementMNode.java | 10 -
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 83 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 69 +-
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 17 +
.../mtree/impl/pbtree/mnode/ICachedMNode.java | 19 +
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 40 +-
.../mnode/container/CachedMNodeContainer.java | 3 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 3 +-
.../pbtree/schemafile/log/SchemaFileLogReader.java | 7 +-
.../pbtree/schemafile/pagemgr/PageIOChannel.java | 3 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 9 +-
.../schemaregion/mtree/traverser/Traverser.java | 103 +
.../traverser/basic/MeasurementTraverser.java | 5 +
.../schemaengine/schemaregion/tag/TagLogFile.java | 12 +-
.../db/schemaengine/table/DataNodeTableCache.java | 47 +-
.../schemaengine/table/InformationSchemaUtils.java | 7 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 10 +-
.../iotdb/db/storageengine/StorageEngine.java | 19 +-
.../db/storageengine/buffer/BloomFilterCache.java | 24 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 19 +-
.../buffer/TimeSeriesMetadataCache.java | 130 +-
.../db/storageengine/dataregion/DataRegion.java | 168 +-
.../execute/task/InnerSpaceCompactionTask.java | 2 +-
.../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 +-
.../impl/SizeTieredCompactionSelector.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 | 20 +-
.../dataregion/modification/ModEntry.java | 12 +-
.../dataregion/modification/TreeDeletionEntry.java | 11 +-
.../dataregion/modification/v1/Deletion.java | 10 +-
.../dataregion/read/QueryDataSourceType.java | 3 +-
.../dataregion/read/control/FileReaderManager.java | 88 +
.../filescan/impl/ClosedFileScanHandleImpl.java | 35 +-
.../filescan/impl/UnclosedFileScanHandleImpl.java | 83 +-
.../dataregion/snapshot/SnapshotLoader.java | 225 +-
.../dataregion/tsfile/TsFileManager.java | 21 +-
.../dataregion/tsfile/TsFileResource.java | 18 +-
.../tsfile/generator/TsFileNameGenerator.java | 4 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 2 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 31 +-
.../allocation/AbstractNodeAllocationStrategy.java | 6 +-
.../dataregion/wal/buffer/WALBuffer.java | 36 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 52 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 3 +-
.../dataregion/wal/io/ProgressWALReader.java | 85 +
.../dataregion/wal/io/WALByteBufReader.java | 73 +
.../dataregion/wal/io/WALFileVersion.java | 9 +-
.../dataregion/wal/io/WALInputStream.java | 40 +-
.../dataregion/wal/io/WALMetaData.java | 252 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 22 +-
.../dataregion/wal/node/WALFakeNode.java | 30 +
.../storageengine/dataregion/wal/node/WALNode.java | 130 +-
.../dataregion/wal/recover/WALRepairWriter.java | 3 +-
.../dataregion/wal/utils/WALFileUtils.java | 211 +
.../dataregion/wal/utils/WALWriteUtils.java | 16 +-
.../db/storageengine/load/LoadTsFileManager.java | 19 +-
.../storageengine/load/active/ActiveLoadAgent.java | 6 +
.../load/active/ActiveLoadDirScanner.java | 17 +-
.../active/ActiveLoadScheduledExecutorService.java | 21 +-
.../load/active/ActiveLoadTsFileLoader.java | 27 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 15 +-
.../converter/LoadTreeTsFileTabletIterator.java | 557 +
.../storageengine/load/disk/ILoadDiskSelector.java | 2 +-
.../InheritSystemMultiDisksStrategySelector.java | 2 +-
.../db/storageengine/load/disk/MinIOSelector.java | 2 +-
.../load/splitter/AlignedChunkData.java | 15 +-
.../load/splitter/NonAlignedChunkData.java | 16 +
.../iotdb/db/storageengine/load/util/LoadUtil.java | 6 +-
.../db/storageengine/rescon/disk/TierManager.java | 23 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 66 -
.../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 +
.../response/SubscriptionEventTsFileResponse.java | 11 +-
...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 +-
.../iotdb/db/utils/DataNodeObjectFileService.java | 3 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 71 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 57 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 171 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 49 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 58 +-
.../org/apache/iotdb/db/auth/TreeAccessTest.java | 133 +
.../strategy/DirectoryStrategyTest.java | 45 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 49 +
.../mtree/lock/StampedWriterPreferredLockTest.java | 42 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 33 +
.../schemaRegion/SchemaRegionBasicTest.java | 22 +
.../schemaRegion/SchemaRegionManagementTest.java | 28 +-
.../schemaRegion/SchemaStatisticsTest.java | 61 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 25 +-
.../agent/task/PipeSinkSubtaskExecutorTest.java | 1 +
.../task/subtask/sink/PipeSinkSubtaskTest.java | 44 +
.../pipe/event/PipeTabletInsertionEventTest.java | 113 +
.../pipe/event/TsFileInsertionEventParserTest.java | 303 +
.../changing/ChangingValueFilterTest.java | 55 +
.../sdt/SwingingDoorTrendingFilterTest.java | 56 +
.../TumblingTimeSamplingProcessorTest.java | 192 +
.../plugin/TwoStageCountProcessorTest.java} | 41 +-
.../receiver/PipeStatementTsStatusVisitorTest.java | 14 +
.../legacy/IoTDBLegacyPipeReceiverAgentTest.java | 122 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 208 +
.../transform/converter/ValueConverterTest.java | 70 +
.../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 +-
.../realtime/disruptor/DisruptorShutdownTest.java | 56 +
.../execution/aggregation/AccumulatorTest.java | 46 +
.../SlidingWindowAggregatorFactoryTest.java} | 26 +-
.../execution/executor/RegionReadExecutorTest.java | 46 +
.../fragment/FragmentInstanceContextTest.java | 623 +
.../fragment/QueryModificationLoaderTest.java | 358 +
.../AlignedSeriesAggregationScanOperatorTest.java | 33 +-
.../operator/DeviceViewIntoOperatorTest.java | 16 +-
.../operator/ExplainAnalyzeOperatorTest.java | 96 +
.../execution/operator/FillOperatorTest.java | 7 +-
.../operator/HorizontallyConcatOperatorTest.java | 3 +-
.../execution/operator/LimitOperatorTest.java | 3 +
.../operator/MergeTreeSortOperatorTest.java | 3 +-
.../execution/operator/OffsetOperatorTest.java | 20 +-
.../execution/operator/OperatorTestUtils.java | 55 +
.../SeriesAggregationScanOperatorTest.java | 33 +-
.../execution/operator/SeriesScanOperatorTest.java | 3 +-
.../operator/SingleDeviceViewOperatorTest.java | 9 +-
.../execution/operator/TreeIntoOperatorTest.java | 6 +-
.../operator/TreeLinearFillOperatorTest.java | 5 +-
.../operator/UpdateLastCacheOperatorTest.java | 7 +-
.../operator/process/fill/NextFillTest.java | 299 +
.../process/window/function/FunctionTestUtils.java | 5 +-
.../schema/source/TimeSeriesSchemaSourceTest.java | 41 +-
.../operator/window/SessionWindowTest.java | 70 +
.../schedule/DefaultDriverSchedulerTest.java | 41 +
.../queue/MultilevelPriorityQueueTest.java | 13 +-
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 129 +
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 133 +-
...TableModelStatementMemorySourceVisitorTest.java | 88 +
.../plan/parser/StatementGeneratorTest.java | 15 +
.../distribution/AggregationTableScanTest.java | 4 +-
.../distribution/RegionScanPlanningTest.java | 81 +
.../logical/RegionScanLogicalPlannerTest.java | 47 +
.../planner/node/PlanGraphJsonPrinterTest.java | 573 +
.../metadata/read/SchemaCountNodeSerdeTest.java | 8 +-
.../node/write/DeleteDataNodeSerdeTest.java | 28 +
.../planner/node/write/InsertRowNodeSerdeTest.java | 241 +-
.../node/write/InsertRowsNodeSerdeTest.java | 176 +
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 34 +
.../node/write/InsertTabletNodeSerdeTest.java | 221 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 41 +
.../write/InsertNodeIsMeasurementFailedTest.java | 255 +
.../node/write/RelationalDeleteDataNodeTest.java | 9 +-
.../analyzer/AggregationCornerCaseTest.java | 12 +-
.../relational/analyzer/SelectAliasReuseTest.java | 347 +
.../plan/relational/analyzer/SortTest.java | 44 +
.../relational/analyzer/TableFunctionTest.java | 187 +
.../plan/relational/analyzer/TestMetadata.java | 13 +
.../ExternalTsFileQueryResourceTest.java | 203 +
.../fetcher/TableDeviceSchemaValidatorTest.java | 29 +-
.../relational/planner/CteMaterializerTest.java | 1 +
.../plan/relational/planner/CteSubqueryTest.java | 1 +
.../relational/planner/NextFillNodeSerdeTest.java | 112 +
.../relational/planner/PredicateUtilsTest.java | 13 +
.../plan/relational/sql/ExplainFormatTest.java | 186 +
.../plan/relational/sql/ast/InsertTabletTest.java | 69 +
.../relational/sql/parser/FillStatementTest.java | 68 +
.../relational/sql/parser/TopicStatementTest.java | 48 +
.../load/LoadTsFileDispatcherImplTest.java | 98 +
.../scheduler/load/LoadTsFileSchedulerTest.java | 31 +
.../crud/InsertStatementPartialInsertTest.java | 320 +
.../FragmentInstanceStatisticsJsonDrawerTest.java | 594 +
.../logfile/FakeCRC32DeserializerTest.java | 108 +
.../mtree/impl/mem/MTreeBelowSGMemoryImplTest.java | 281 +
.../impl/pbtree/MTreeBelowSGCachedImplTest.java | 217 +
.../schemaregion/tag/TagLogFileTest.java | 57 +
.../schemaengine/table/DataNodeTableCacheTest.java | 106 +
.../buffer/TimeSeriesMetadataCacheTest.java | 283 +
.../storageengine/dataregion/DataRegionTest.java | 30 +-
.../iotdb/db/storageengine/dataregion/TTLTest.java | 4 +-
.../BatchedCompactionWithTsFileSplitterTest.java | 16 +-
...actionWithReadPointPerformerValidationTest.java | 4 +-
.../utils/writer/AbstractCompactionWriterTest.java | 167 +
.../compaction/repair/AbstractRepairDataTest.java | 11 +-
.../utils/CompactionFileGeneratorUtils.java | 2 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 7 +-
.../AbstractMemTablePartialInsertTest.java | 113 +
.../memtable/MemChunkDeserializeTest.java | 23 +
.../dataregion/memtable/TsFileProcessorTest.java | 172 +
.../modification/TableDeletionEntryTest.java | 17 +-
.../modification/TreeDeletionEntryTest.java | 5 +-
.../dataregion/modification/v1/DeletionTest.java | 52 +
.../dataregion/snapshot/IoTDBSnapshotTest.java | 336 +-
.../wal/compression/WALCompressionTest.java | 37 +-
.../dataregion/wal/io/ProgressWALReaderTest.java | 93 +
.../dataregion/wal/io/WALFileTest.java | 58 +
.../wal/io/WALMetaDataV3CompatibilityTest.java | 185 +
.../wal/node/ConsensusReqReaderTest.java | 17 +
.../dataregion/wal/node/WALNodeTest.java | 66 +
.../wal/node/WALNodeWaitForRollFileTest.java | 29 +-
.../dataregion/wal/utils/WALFileUtilsTest.java | 74 +
...atementDataTypeConvertExecutionVisitorTest.java | 380 +
.../load/splitter/ChunkDataDirectWriteTest.java | 91 +
.../rescon/disk/FolderManagerTest.java | 5 +-
.../ConsensusLogToTabletConverterTest.java | 266 +
.../ConsensusSubscriptionCommitStateTest.java | 314 +
.../broker/consensus/ProgressWALIteratorTest.java | 323 +
...SubscriptionPipeEventBatchSegmentLockTest.java} | 34 +-
.../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 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 4 +-
.../resources/conf/iotdb-system.properties | 1 -
.../conf/iotdb-system.properties.template | 108 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 8 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 14 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 15 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 8 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 14 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 15 +
.../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 +-
.../commons/concurrent/IoTDBThreadPoolFactory.java | 17 +
.../iotdb/commons/concurrent/ThreadName.java | 9 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 235 +-
.../iotdb/commons/conf/CommonDescriptor.java | 171 +
.../iotdb/commons/conf/ConfigurationFileUtils.java | 16 +-
.../commons/consensus/index/ProgressIndex.java | 11 +
.../index/impl/TimeWindowStateProgressIndex.java | 9 +-
.../apache/iotdb/commons}/disk/FolderManager.java | 53 +-
.../commons}/disk/strategy/DirectoryStrategy.java | 12 +-
.../disk/strategy/DirectoryStrategyType.java | 56 +
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 4 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 151 +
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../commons}/disk/strategy/SequenceStrategy.java | 4 +-
.../exception/DiskSpaceInsufficientException.java | 4 +-
.../commons/executable/ExecutableManager.java | 3 +-
.../executable/ReferenceCountedJarMetaKeeper.java | 136 +
.../iotdb/commons/partition/DataPartition.java | 18 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 28 +-
.../plugin/constructor/PipeSinkConstructor.java | 8 +-
.../meta/ConfigNodePipePluginMetaKeeper.java | 50 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 19 +-
.../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 +
.../options/PipeInclusionOptions.java | 4 +-
.../pipe/datastructure/pattern/TreePattern.java | 36 +-
.../queue/serializer/PlainQueueSerializer.java | 3 +-
.../commons/pipe/resource/log/PipeLogger.java | 18 +-
.../resource/log/PipePeriodicalLogReducer.java | 76 +
.../thrift/request/PipeTransferFileSealReqV2.java | 8 +
.../pipe/sink/protocol/IoTDBAirGapSink.java | 5 +-
.../execution/MemoryEstimationHelper.java | 4 +-
.../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 +-
.../plan/relational/planner/node/ValuesNode.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 +
.../plan/udf/BuiltinAggregationFunction.java | 23 +-
.../schema/column/ColumnHeaderConstant.java | 11 +-
.../node/common/AbstractAboveDatabaseMNode.java | 4 +
.../commons/schema/node/utils/IMNodeIterator.java | 2 +-
.../commons/schema/table/InformationSchema.java | 6 +
.../schema/table/InsertNodeMeasurementInfo.java | 9 +-
.../schema/table/column/TsTableColumnCategory.java | 7 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 4 +
.../service/AbstractThriftServiceThread.java | 52 +-
.../iotdb/commons/service/NoopServerContext.java | 48 +
.../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 | 18 +-
.../relational/tvf/CapacityTableFunction.java | 69 +-
.../builtin/relational/tvf/M4TableFunction.java | 802 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 3 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 24 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 11 +-
.../utils/KillPoint/RegionMaintainKillPoints.java | 34 +
.../org/apache/iotdb/commons/utils/PathUtils.java | 56 +-
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 47 +-
.../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 16 +
.../client/mock/MockInternalRPCService.java | 7 +-
.../client/request/AsyncRequestManagerTest.java | 226 +
...FolderOccupiedSpaceFirstStrategyRealFsTest.java | 127 +
.../disk/strategy/DirectoryStrategyTypeTest.java | 63 +
.../ReferenceCountedJarMetaKeeperTest.java | 116 +
.../commons/pipe/config/PipeDescriptorTest.java | 65 +
.../options/PipeInclusionOptionsTest.java | 48 +
.../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 +
.../NoopServerContextTest.java} | 28 +-
.../meta/consumer/CommitProgressKeeperTest.java | 163 +
.../commons/subscription/topic/TopicDeSerTest.java | 200 +
.../relational/tvf/CapacityTableFunctionTest.java | 204 +
.../apache/iotdb/commons/utils/FileUtilsTest.java | 16 +-
.../apache/iotdb/commons/utils/IOUtilsTest.java | 147 +
.../iotdb/commons/utils/JVMCommonUtilsTest.java | 27 +
.../iotdb/commons/utils/WindowsOSUtilsTest.java | 12 +
.../db/relational/grammar/sql/RelationalSql.g4 | 13 +-
.../thrift-commons/src/main/thrift/common.thrift | 8 +
.../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 | 175 +-
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 +-
1260 files changed, 84453 insertions(+), 27167 deletions(-)
copy .claude/settings.json => .codex/hooks.json (100%)
create mode 100644 .github/scripts/package-client-cpp-manylinux228.sh
delete mode 100644 .github/workflows/compile-check.yml
create mode 100644 SECURITY.md
create mode 100644 THREAT_MODEL.md
delete mode 100644 example/client-c-example/README.md
delete mode 100644 example/client-c-example/pom.xml
delete mode 100644 example/client-c-example/src/table_example.c
delete mode 100644 example/client-c-example/src/tree_example.c
delete mode 100644 example/client-cpp-example/pom.xml
delete mode 100644 example/client-cpp-example/src/CMakeLists.txt
create mode 100644
example/session/src/main/java/org/apache/iotdb/ConsensusSubscriptionWalFileAnalyzer.java
create mode 100644
example/subscription/src/main/java/org/apache/iotdb/ConsensusSubscriptionSessionExample.java
create mode 100644
example/subscription/src/main/java/org/apache/iotdb/ConsensusTableModelSubscriptionSessionExample.java
create mode 100644
integration-test/src/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
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithDeletionMultiDataDirIT.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/aggregation/IoTDBStatisticalAggregationIT.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/pipe/it/single/IoTDBLegacyPipeReceiverSecurityIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBWindowFunctionBatchedResultIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBGroupByAllTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBReadTsFileTableFunctionIT.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/relational/it/schema/IoTDBDatabaseMaxRegionGroupNumIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseMixedRegionGroupPolicyIT.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 (97%)
rename iotdb-client/client-cpp/src/{main => include}/ColumnDecoder.h (100%)
rename iotdb-client/client-cpp/src/{main => include}/Common.h (74%)
create mode 100644 iotdb-client/client-cpp/src/include/Date.h
rename iotdb-client/client-cpp/src/{main => include}/DeviceID.h (100%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java
=> iotdb-client/client-cpp/src/include/Endpoint.h (61%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/utils/IMNodeIterator.java
=> iotdb-client/client-cpp/src/include/Export.h (73%)
create mode 100644 iotdb-client/client-cpp/src/include/Optional.h
rename iotdb-client/client-cpp/src/{main => include}/Session.h (72%)
rename iotdb-client/client-cpp/src/{main => include}/SessionBuilder.h (100%)
rename iotdb-client/client-cpp/src/{main => include}/SessionC.h (97%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java
=> iotdb-client/client-cpp/src/include/SessionConfig.h (67%)
create mode 100644 iotdb-client/client-cpp/src/include/SessionDataSet.h
create mode 100644 iotdb-client/client-cpp/src/include/SessionPool.h
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/strategy/DirectoryStrategyType.java
=> iotdb-client/client-cpp/src/include/Status.h (76%)
rename iotdb-client/client-cpp/src/{main => include}/TableSession.h (100%)
rename iotdb-client/client-cpp/src/{main => include}/TableSessionBuilder.h
(100%)
rename iotdb-client/client-cpp/src/{main => include}/TsBlock.h (100%)
delete mode 100644 iotdb-client/client-cpp/src/main/CMakeLists.txt
delete mode 100644 iotdb-client/client-cpp/src/main/SessionDataSet.h
rename iotdb-client/client-cpp/src/{main => rpc}/IoTDBRpcDataSet.cpp (88%)
rename iotdb-client/client-cpp/src/{main => rpc}/IoTDBRpcDataSet.h (72%)
rename iotdb-client/client-cpp/src/{main => rpc}/NodesSupplier.cpp (97%)
rename iotdb-client/client-cpp/src/{main => rpc}/NodesSupplier.h (94%)
create mode 100644 iotdb-client/client-cpp/src/rpc/RpcCommon.cpp
create mode 100644 iotdb-client/client-cpp/src/rpc/RpcCommon.h
rename iotdb-client/client-cpp/src/{main => rpc}/SessionConnection.cpp (93%)
rename iotdb-client/client-cpp/src/{main => rpc}/SessionConnection.h (93%)
create mode 100644 iotdb-client/client-cpp/src/rpc/SessionDataSetFactory.h
create mode 100644 iotdb-client/client-cpp/src/rpc/SessionImpl.h
rename iotdb-client/client-cpp/src/{main => rpc}/ThriftConnection.cpp (93%)
rename iotdb-client/client-cpp/src/{main => rpc}/ThriftConnection.h (95%)
create mode 100644 iotdb-client/client-cpp/src/rpc/ThriftConvert.cpp
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/ICachedMNode.java
=> iotdb-client/client-cpp/src/rpc/ThriftConvert.h (59%)
rename iotdb-client/client-cpp/src/{main => session}/Column.cpp (96%)
rename iotdb-client/client-cpp/src/{main => session}/ColumnDecoder.cpp (100%)
rename iotdb-client/client-cpp/src/{main => session}/Common.cpp (52%)
create mode 100644 iotdb-client/client-cpp/src/session/Date.cpp
rename iotdb-client/client-cpp/src/{main => session}/Session.cpp (79%)
rename iotdb-client/client-cpp/src/{main => session}/SessionC.cpp (97%)
create mode 100644 iotdb-client/client-cpp/src/session/SessionDataSet.cpp
create mode 100644 iotdb-client/client-cpp/src/session/SessionPool.cpp
rename iotdb-client/client-cpp/src/{main => session}/TableSession.cpp (100%)
rename iotdb-client/client-cpp/src/{main => session}/TsBlock.cpp (100%)
delete mode 100644 iotdb-client/client-cpp/src/test/CMakeLists.txt
delete mode 100644 iotdb-client/client-cpp/src/test/catch2/catch.hpp
create mode 100644 iotdb-client/client-cpp/test/CMakeLists.txt
create mode 100644 iotdb-client/client-cpp/test/catch2/.gitignore
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionCIT.cpp (90%)
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionCRelationalIT.cpp
(96%)
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionIT.cpp (84%)
rename iotdb-client/client-cpp/{src => }/test/cpp/sessionRelationalIT.cpp (94%)
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/aggregation/CentralMomentAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/aggregation/CorrelationAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/aggregation/CovarianceAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/aggregation/RegressionAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/TableNextFillOperator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/TableNextFillWithGroupOperator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/fill/next/NextFill.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/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/TableCentralMomentAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/TableCorrelationAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/TableCovarianceAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/TableRegressionAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedCentralMomentAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedCorrelationAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedCovarianceAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedPercentileAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedRegressionAccumulator.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/cq/CQManagerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/consensus/ConsensusManagerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/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/auth/AuthorPlanExecutorTest.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
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedureRecoveryTest.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
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/MemoryControlledChunkReader.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/execution/fragment/QueryModificationLoader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/ExternalTsFileAggTableScanOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/ExternalTsFileSeriesScanUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/ExternalTsFileTableScanOperator.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
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/DataNodeTableBuiltinTableFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/read_tsfile/DeviceTaskRunCursor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/read_tsfile/ExternalTsFileDeviceFilterVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/read_tsfile/ExternalTsFileDeviceQueryTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/read_tsfile/ExternalTsFileQueryDataSource.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/read_tsfile/ExternalTsFileQueryResource.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/read_tsfile/ReadTsFileTableFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/read_tsfile/TsFileSchemaCollector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/ExternalTsFileAggregationScanNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/ExternalTsFileScanNode.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{PipeEnriched.java
=> AlterTopic.java} (57%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ExplainOutputFormat.java}
(62%)
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/storageengine/load/converter/LoadTreeTsFileTabletIterator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/strategy/MinFolderOccupiedSpaceFirstStrategy.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/datanode/src/{main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CountStatement.java
=>
test/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java}
(53%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/legacy/IoTDBLegacyPipeReceiverAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiverTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverterTest.java
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/fragment/FragmentInstanceContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryModificationLoaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/ExplainAnalyzeOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/OperatorTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/NextFillTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/window/SessionWindowTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/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/function/tvf/read_tsfile/ExternalTsFileQueryResourceTest.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/schemaregion/logfile/FakeCRC32DeserializerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/MTreeBelowSGMemoryImplTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/MTreeBelowSGCachedImplTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagLogFileTest.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/converter/LoadTreeStatementDataTypeConvertExecutionVisitorTest.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/test/java/org/apache/iotdb/commons/utils/JVMCommonUtilsTest.java
=>
datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatchSegmentLockTest.java}
(50%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/EnvironmentUtilsTest.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/FolderManager.java
(72%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/DirectoryStrategy.java
(88%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/DirectoryStrategyType.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/MaxDiskUsableSpaceFirstStrategy.java
(92%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/MinFolderOccupiedSpaceFirstStrategy.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/RandomOnDiskUsableSpaceStrategy.java
(94%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/SequenceStrategy.java
(95%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/DiskSpaceInsufficientException.java
(91%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/executable/ReferenceCountedJarMetaKeeper.java
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/service/NoopServerContext.java
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/disk/MinFolderOccupiedSpaceFirstStrategyRealFsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/disk/strategy/DirectoryStrategyTypeTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/executable/ReferenceCountedJarMetaKeeperTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/config/PipeDescriptorTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/options/PipeInclusionOptionsTest.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
copy
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/{utils/WindowsOSUtilsTest.java
=> service/NoopServerContextTest.java} (53%)
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
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/IOUtilsTest.java
