This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch fix-equals-hashcode-contract-master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f0cf3911439 Fix flaky WAL roll file test
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 2fc89d07d08 C++ client: build with OpenSSL 3.x by default and bundle
the runtime … (#17987)
add 797dfa5d5cf Pipe: isolate async sink client resources by endpoint
(#18015)
add 4d05a851ef5 Limit concurrent load tsfile type conversions (#18014)
add 1d893f1d197 Support unified pipe pattern inclusion keys (#18016)
add c98bc5a0327 Use MinFolderOccupiedSpaceFirstStrategy for IoTConsensus
recv and all… (#18020)
add ced3908f07e Reduce IoTConsensus snapshot transmission memory and log
overhead (#18019)
add 1073715a081 Add RPC auto resizing buffer memory control (#17911)
add e948e49afbe Added show create pipe/database/topic (#17702)
add f1b45088029 Pipe: Fix tablet event alignment and row count handling
(#17999)
add e0e79aaaaaf Fix raw password user sync under strong policy (#18021)
add cd5c3a31195 Fix empty deleteTimeseries requests (#18012)
add 1811e13f640 Pipe: Retry history LoadTsFile while waiting for schema
(#18031)
add f96fc5824f6 Pipe: merge batched aligned chunks in scan parser (#18010)
add 580fd6afc86 Fix tag index memory accounting (#18029)
add 7f41f064858 Fix internal procedure deduplication (#18036)
add fcd52d7ff06 Support IoTDBLocal in UDF for table model (#18035)
add 27af5a6810d Support strict tree table pipe isolation (#17948)
add 837711dcae7 Pipe: Implemented schema batch for meta transfer (#17665)
add bd952e15645 Fix encrypted password pull consumer commit mode (#18044)
add d737f4b301b Stabilize ZSTD compressor level pipe IT (#17917)
add 3bc7b9032f1 Pipe: Fix async sink handshake backoff (#18054)
add b4c4e5483f4 Fix stale deletion resource manager reuse (#18057)
add a76341d9408 Enable show queries can be executed when the available
memory for Operators is insufficient (#18052)
add 6fcbaddc0d6 Add copy fallback for compaction hard links (#18045)
add aabf552629b Avoid copying measurements when updating last cache
(#18059)
add 186ce3672a7 Throttle empty subscription poll logs (#18063)
add b35a575199a Fix deletion visibility in region migration IT (#18065)
add 2fedd8a395d Add degraded status to show pipes (#18047)
add d00ec094a0e Support multiple regions in MIGRATE REGION and multiple
DataNodes in REMOVE DATANODE (#18046)
add 3b7df259b8d Use procedures for region create/delete to fix the
delete-region ghost task (#18033)
add 522c31c7750 Display data partition repair progress by providing a new
SQL statement (#17637)
add 127eff05577 Reduce log level of TsFileGenerator (#18068)
add e9fe467592f Support Thrift client mutual TLS (#18026)
add 4b1d5e50e0b Fix ConfigNode NPE when extend/reconstruct region targets
a non-DataNode id (#18075)
add 383458fb72c Fix JDBC reusing stale statement id after reconnect
(#18078)
add 1c8ed311c95 Support target database in write-back sink (#18058)
add 9554e5d8ef0 Pipe: add ConfigNode memory control for log reducer
(#18069)
add fa194d32bb4 [Pipe] Improve pipe control-flow lock responsiveness
(#18076)
add 220e7a319c2 Fix two flaky multi-DataNode/multi-region ITs from #18046
(remove-DataNode selection + migrate precondition) (#18082)
add 660b0ad1c94 Update version to 2.0.11-SNAPSHOT (#18093)
add 0a3e21231ed Fix region-group cleanup: recover-safe submission + retry
that actually re-runs the delete (#18097)
add 8439807f722 Fix C++ client DATE 1000-01-01 query crash (#18096)
add 5ce95b1e05c Pipe: Remove Ratis data region source restriction (#18089)
add 19a9b15c410 Avoid login lock for pipe auth retry (#18048)
add ef5f4ca6441 Fix stale pipe runtime error messages (#18061)
add 2e099a68eb5 Hot-reload procedure completed-cleaner & disk space
warning threshold (+ fix evict-TTL unit) (#18091)
add 4722bdbccbd Merge remote-tracking branch 'origin/master' into
fix-equals-hashcode-contract-master
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 | 13 +
.github/workflows/client-cpp-package.yml | 52 +-
.github/workflows/compile-check.yml | 67 --
.github/workflows/daily-it.yml | 4 +-
.github/workflows/daily-ut.yml | 15 +-
.github/workflows/multi-language-client.yml | 109 ++-
.github/workflows/pipe-it.yml | 11 +
.gitignore | 2 +-
CLAUDE.md | 4 +-
CONTRIBUTING.md | 2 +-
Jenkinsfile | 2 +-
LICENSE-binary | 45 +-
README.md | 4 +-
README_ZH.md | 4 +-
code-coverage/pom.xml | 2 +-
dependencies.json | 318 ++++----
distribution/pom.xml | 16 +-
docker/ReadMe.md | 2 +-
example/jdbc/pom.xml | 6 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 6 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 6 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/subscription/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-service-impl/mqtt/pom.xml | 16 +-
external-service-impl/pom.xml | 8 +-
external-service-impl/rest-openapi/pom.xml | 30 +-
external-service-impl/rest/pom.xml | 50 +-
.../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 +-
integration-test/pom.xml | 42 +-
.../iotdblocal/CreateTableProbeFunction.java | 13 +-
.../DeviceIdListInProcessTableFunction.java | 131 ++++
.../iotdblocal/DeviceIdListTableFunction.java | 142 ++++
.../DeviceNameEnrichBeforeStartTableFunction.java | 144 ++++
.../DeviceNameEnrichInProcessTableFunction.java | 139 ++++
.../relational/iotdblocal/DeviceNameFunction.java | 77 ++
.../iotdblocal/DeviceSummaryFunction.java | 98 +++
.../iotdblocal/DeviceSummaryNoCloseFunction.java | 93 +++
.../iotdblocal/DropTableProbeFunction.java | 13 +-
.../relational/iotdblocal/InsertProbeFunction.java | 13 +-
.../iotdblocal/IoTDBLocalLogAggregateFunction.java | 133 ++++
.../iotdblocal/IoTDBLocalLogFunction.java | 71 ++
.../relational/iotdblocal/IoTDBLocalLogHelper.java | 93 +++
.../iotdblocal/IoTDBLocalLogTableFunction.java | 134 ++++
...lQueryUdafAtBeforeDestroyAggregateFunction.java | 101 +++
...calQueryUdafAtBeforeStartAggregateFunction.java | 111 +++
.../LocalQueryUdafInAddInputAggregateFunction.java | 123 +++
...alQueryUdafInCombineStateAggregateFunction.java | 123 +++
...calQueryUdafInOutputFinalAggregateFunction.java | 104 +++
.../iotdblocal/MutatingQueryProbeFunction.java | 54 ++
.../iotdblocal/SecretTableQueryFunction.java | 57 ++
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 1 +
.../iotdb/it/env/cluster/config/MppBaseConfig.java | 7 +-
.../it/env/cluster/config/MppCommonConfig.java | 74 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 37 +
.../env/cluster/config/MppSharedCommonConfig.java | 76 +-
.../org/apache/iotdb/it/env/cluster/env/AIEnv.java | 28 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 450 ++++++++---
.../iotdb/it/env/cluster/node/AINodeStarter.java | 84 ++
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 2 -
.../it/env/remote/config/RemoteCommonConfig.java | 57 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 27 +
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 6 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 25 +-
.../apache/iotdb/itbase/env/DataNodeConfig.java | 12 +
.../itbase/runtime/ParallelRequestDelegate.java | 13 +-
.../iotdb/cli/it/ExplainJsonCliOutputIT.java | 345 +++++++++
.../it/database/IoTDBDatabaseRegionControlIT.java | 18 +-
...oTDBMultiDBRegionGroupLeaderDistributionIT.java | 1 -
.../IoTDBPerDatabaseRegionGroupAllocationIT.java | 8 +-
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 1 -
...ataPartitionTableIntegrityCheckProcedureIT.java | 36 +
.../partition/IoTDBPartitionInheritStrategyIT.java | 2 +-
.../partition/IoTDBPartitionShuffleStrategyIT.java | 2 +-
.../IoTDBRegionMigrateITFrameworkForRatis.java} | 26 +-
...IoTDBRegionOperationReliabilityITFramework.java | 202 ++++-
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 213 +++++
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 59 ++
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 55 ++
...BRegionMigrateDataNodeCrashForIoTV2BatchIT.java | 19 +-
...RegionMigrateDataNodeCrashForIoTV2StreamIT.java | 19 +-
...oTDBRegionMigrateAddingPeerCrashForRatisIT.java | 48 ++
.../IoTDBRegionMigrateConfigNodeCrashIoTV1IT.java | 26 +
...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 160 ++++
...gionMigrateWithDeletionMultiDataDirTableIT.java | 163 ++++
.../daily/iotv1/RegionMigrateFileAssertions.java | 167 ++++
...IoTDBRegionMigrateClusterCrashIoTV2BatchIT.java | 6 +-
...DBRegionMigrateConfigNodeCrashIoTV2BatchIT.java | 35 +-
...oTDBRegionMigrateClusterCrashIoTV2StreamIT.java | 9 +-
...BRegionMigrateConfigNodeCrashIoTV2StreamIT.java | 35 +-
.../IoTDBRegionMigrateClusterCrashForRatisIT.java} | 35 +-
...TDBRegionMigrateConfigNodeCrashForRatisIT.java} | 72 +-
.../IoTDBRemoveDataNodeNormalIT.java | 24 +-
.../IoTDBRemoveDataNodeRegionAllocationIT.java | 348 +++++++++
.../removedatanode/IoTDBRemoveDataNodeUtils.java | 96 +++
.../removedatanode/IoTDBRemoveLastDataNodeIT.java | 111 +++
.../db/it/IoTDBAutoResizingBufferMemoryIT.java | 274 +++++++
.../iotdb/db/it/IoTDBCustomizedClusterIT.java | 54 +-
.../iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java | 226 ++++++
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 2 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 18 +-
.../db/it/IoTDBSetConfigurationClusterIT.java | 122 +++
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 311 ++++++++
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 2 +-
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 48 +-
...DBSingleMeasurementCheckCachePerformanceIT.java | 207 +++++
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 6 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 12 +-
.../manual/AbstractPipeTableModelDualManualIT.java | 2 +
.../manual/basic/IoTDBPipeDataSinkIT.java | 21 +-
.../manual/basic/IoTDBPipeIsolationIT.java | 215 +++++-
.../manual/basic/IoTDBPipeLifeCycleIT.java | 12 +-
.../tablemodel/manual/basic/IoTDBPipeMemoryIT.java | 1 +
.../manual/basic/IoTDBPipePermissionIT.java | 3 +
.../manual/basic/IoTDBPipeProtocolIT.java | 10 +
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 29 +-
.../manual/basic/IoTDBPipeSwitchStatusIT.java | 4 +
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 31 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 8 +
.../manual/basic/IoTDBTablePatternFormatIT.java | 7 +
.../manual/enhanced/IoTDBPipeAutoConflictIT.java | 6 +
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 3 +
.../manual/enhanced/IoTDBPipeClusterIT.java | 15 +
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 72 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 1 +
.../manual/enhanced/IoTDBPipeMetaIT.java | 4 +-
.../manual/enhanced/IoTDBPipeNullValueIT.java | 1 +
.../enhanced/IoTDBPipeSinkCompressionIT.java | 20 +-
.../manual/enhanced/IoTDBPipeSinkParallelIT.java | 3 +
.../IoTDBPipeTypeConversionISessionIT.java | 1 +
.../auto/AbstractPipeDualTreeModelAutoIT.java | 6 +-
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 2 +
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 2 +-
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 2 +
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 6 +
.../IoTDBPipeReceiverAutoCreateDisabledIT.java | 65 +-
.../auto/basic/IoTDBPipeSinkParallelIT.java | 1 +
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 65 +-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 2 +
.../auto/enhanced/IoTDBPipeClusterIT.java | 2 +
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 8 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 182 ++---
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 2 +
.../manual/AbstractPipeDualTreeModelManualIT.java | 4 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 4 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 7 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 4 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 3 +-
.../IoTDBPipeWriteBackSinkIT.java} | 77 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 1 +
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 1 +
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 2 +
.../pipe/it/single/IoTDBPipePermissionIT.java | 1 +
.../pipe/it/triple/AbstractPipeTripleManualIT.java | 5 +-
.../relational/it/db/it/IoTDBLoadTsFileIT.java | 1 +
.../relational/it/db/it/IoTDBWindowTVFIT.java | 334 ++++++++
.../relational/it/db/it/udf/IoTDBLocalIT.java | 451 +++++++++++
.../relational/it/db/it/udf/IoTDBLocalLogIT.java | 159 ++++
.../it/db/it/udf/IoTDBSQLFunctionManagementIT.java | 3 +-
.../relational/it/db/it/udf/SQLFunctionUtils.java | 1 -
.../it/insertquery/IoTDBInsertQueryIT.java | 4 +-
.../it/query/recent/IoTDBGroupByAllTableIT.java | 238 ++++++
.../recent/IoTDBReadTsFileTableFunctionIT.java | 622 +++++++++++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 121 +++
.../it/query/recent/IoTExplainJsonFormatIT.java | 855 +++++++++++++++++++++
.../it/schema/IoTDBAlterColumnTypeIT.java | 2 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 159 +++-
.../schema/IoTDBDatabaseMaxRegionGroupNumIT.java | 229 ++++++
.../IoTDBDatabaseMixedRegionGroupPolicyIT.java | 83 ++
.../iotdb/session/it/IoTDBClientMutualSSLIT.java | 284 +++++++
.../apache/iotdb/session/it/IoTDBClientSSLIT.java | 233 ++++++
.../IoTDBSubscriptionTopicOwnerPartitionIT.java | 267 +++++++
.../dual/tablemodel/IoTDBSubscriptionTopicIT.java | 113 +++
.../it/local/AbstractSubscriptionLocalIT.java | 1 +
.../it/local/IoTDBSubscriptionTopicOwnerIT.java | 225 ++++++
.../IoTDBEncryptedPasswordPullConsumerIT.java | 1 +
integration-test/src/test/resources/test-keystore | Bin 2710 -> 2742 bytes
.../src/test/resources/test-truststore | Bin 1238 -> 1270 bytes
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/external-service-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
.../api/customizer/parameter/PipeParameters.java | 10 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
.../java/org/apache/iotdb/udf/api/IoTDBLocal.java | 70 ++
.../org/apache/iotdb/udf/api/UDFResultSet.java | 45 +-
.../udf/api/relational/AggregateFunction.java | 33 +
.../iotdb/udf/api/relational/ScalarFunction.java | 19 +
.../processor/TableFunctionDataProcessor.java | 34 +
.../processor/TableFunctionLeafProcessor.java | 17 +
iotdb-client/cli/pom.xml | 26 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 104 ++-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 27 +-
.../org/apache/iotdb/tool/common/Constants.java | 12 +
.../org/apache/iotdb/tool/common/OptionsUtil.java | 30 +
.../apache/iotdb/tool/data/AbstractDataTool.java | 58 ++
.../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 | 46 ++
.../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 | 27 +-
iotdb-client/client-cpp/README.md | 62 +-
iotdb-client/client-cpp/README_zh.md | 12 +-
.../client-cpp/cmake/FetchBuildTools.cmake | 17 +-
iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake | 58 +-
iotdb-client/client-cpp/cmake/FetchThrift.cmake | 21 +-
.../client-cpp/cmake/InstallOpenSSLRuntime.cmake | 121 +++
iotdb-client/client-cpp/examples/CMakeLists.txt | 35 +
iotdb-client/client-cpp/examples/README.md | 2 +-
iotdb-client/client-cpp/examples/README_zh.md | 2 +-
iotdb-client/client-cpp/pom.xml | 16 +-
.../client-cpp/src/assembly/client-cpp.xml | 2 +
.../package-metadata/third_party/DEPENDENCIES.md | 25 +-
.../assembly/package-metadata/third_party/NOTICE | 34 +
.../third_party/licenses/LICENSE-Boost-1.0 | 23 +
iotdb-client/client-cpp/src/include/Common.h | 2 +-
iotdb-client/client-cpp/src/include/Session.h | 20 +-
iotdb-client/client-cpp/src/include/SessionC.h | 12 +
iotdb-client/client-cpp/src/rpc/SessionImpl.h | 11 +-
iotdb-client/client-cpp/src/session/Date.cpp | 3 -
iotdb-client/client-cpp/src/session/Session.cpp | 124 +--
iotdb-client/client-cpp/src/session/SessionC.cpp | 51 +-
iotdb-client/client-cpp/test/cpp/sessionCIT.cpp | 93 ++-
.../client-cpp/test/cpp/sessionCRelationalIT.cpp | 13 +
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 53 ++
.../client-cpp/test/cpp/sessionRelationalIT.cpp | 13 +
iotdb-client/client-cpp/third-party/README.md | 6 +-
iotdb-client/client-go | 2 +-
iotdb-client/client-py/README.md | 36 +-
iotdb-client/client-py/iotdb/Session.py | 28 +-
iotdb-client/client-py/iotdb/SessionPool.py | 8 +
iotdb-client/client-py/iotdb/dbapi/Connection.py | 35 +-
iotdb-client/client-py/iotdb/table_session.py | 6 +
iotdb-client/client-py/iotdb/table_session_pool.py | 4 +
iotdb-client/client-py/pom.xml | 8 +-
iotdb-client/client-py/session_ssl_example.py | 16 +-
.../client-py/tests/unit/test_session_ssl.py | 152 ++++
iotdb-client/isession/pom.xml | 8 +-
.../org/apache/iotdb/isession/SessionConfig.java | 2 +
iotdb-client/jdbc/README.md | 4 +-
iotdb-client/jdbc/pom.xml | 8 +-
iotdb-client/jdbc/src/main/feature/feature.xml | 2 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 8 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 5 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 27 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 35 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 14 +
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 39 +
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 53 +-
.../iotdb/rpc/AutoResizingBufferMemoryControl.java | 12 +-
.../iotdb/rpc/AutoResizingBufferMemoryManager.java | 110 +++
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 18 +-
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 20 +-
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 47 +-
.../java/org/apache/iotdb/rpc/RpcSslUtils.java | 304 ++++++++
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +-
.../rpc/TCompressedElasticFramedTransport.java | 29 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 38 +-
.../iotdb/rpc/TNonblockingTransportWrapper.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 8 +-
.../java/org/apache/iotdb/rpc/TSocketWrapper.java | 4 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 6 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 6 +-
.../apache/iotdb/rpc/AutoResizingBufferTest.java | 193 +++++
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 46 ++
iotdb-client/session/pom.xml | 10 +-
.../iotdb/session/AbstractSessionBuilder.java | 3 +
.../org/apache/iotdb/session/NodesSupplier.java | 18 +
.../java/org/apache/iotdb/session/Session.java | 24 +
.../apache/iotdb/session/SessionConnection.java | 44 +-
.../apache/iotdb/session/TableSessionBuilder.java | 36 +
.../org/apache/iotdb/session/ThriftConnection.java | 8 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 38 +
.../session/pool/TableSessionPoolBuilder.java | 36 +
.../iotdb/session/SessionConnectionTest.java | 8 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 11 +
.../src/test/resources/iotdb-common.properties | 2 +-
iotdb-client/subscription/pom.xml | 14 +-
.../subscription/i18n/SubscriptionMessages.java | 31 +
.../subscription/i18n/SubscriptionMessages.java | 24 +
.../rpc/subscription/config/ConsumerConfig.java | 10 +
.../rpc/subscription/config/ConsumerConstant.java | 2 +
.../rpc/subscription/config/TopicConstant.java | 8 +
.../SubscriptionOwnerFencedException.java | 27 +-
.../subscription/AbstractSubscriptionSession.java | 99 ++-
.../subscription/ISubscriptionTableSession.java | 43 ++
.../subscription/ISubscriptionTreeSession.java | 43 ++
.../subscription/SubscriptionTableSession.java | 22 +
.../subscription/SubscriptionTreeSession.java | 22 +
.../base/AbstractSubscriptionConsumer.java | 26 +
.../base/AbstractSubscriptionConsumerBuilder.java | 23 +
.../base/AbstractSubscriptionProvider.java | 25 +
.../base/AbstractSubscriptionPullConsumer.java | 20 +-
.../base/AbstractSubscriptionPushConsumer.java | 20 +-
.../consumer/base/EmptyPollLogThrottler.java | 62 ++
.../consumer/table/SubscriptionTableProvider.java | 4 +
.../table/SubscriptionTablePullConsumer.java | 4 +
.../SubscriptionTablePullConsumerBuilder.java | 18 +
.../table/SubscriptionTablePushConsumer.java | 4 +
.../SubscriptionTablePushConsumerBuilder.java | 18 +
.../consumer/tree/SubscriptionTreeProvider.java | 4 +
.../tree/SubscriptionTreePullConsumer.java | 21 +
.../tree/SubscriptionTreePullConsumerBuilder.java | 18 +
.../tree/SubscriptionTreePushConsumer.java | 21 +
.../tree/SubscriptionTreePushConsumerBuilder.java | 18 +
.../consumer/base/EmptyPollLogThrottlerTest.java | 63 ++
iotdb-core/ainode/iotdb/ainode/core/constant.py | 1 +
iotdb-core/ainode/iotdb/ainode/core/rpc/client.py | 11 +-
iotdb-core/ainode/pom.xml | 12 +-
iotdb-core/antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 7 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 30 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 14 +-
iotdb-core/calc-commons/pom.xml | 19 +-
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 10 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 9 +
.../execution/operator/CommonOperatorContext.java | 15 +
.../fill/filter/FixedIntervalFillFilter.java | 10 +-
.../function/TableFunctionLeafOperator.java | 16 +-
.../process/function/TableFunctionOperator.java | 28 +-
.../operator/source/relational/Percentile.java | 173 +++++
.../relational/aggregation/AccumulatorFactory.java | 109 ++-
.../aggregation/AggregationOperator.java | 15 +-
.../relational/aggregation/ExtremeAccumulator.java | 32 +-
.../aggregation/PercentileAccumulator.java | 266 +++++++
.../relational/aggregation/TableAggregator.java | 49 +-
.../UserDefinedAggregateFunctionAccumulator.java | 65 +-
.../grouped/GroupedExtremeAccumulator.java | 70 +-
.../grouped/GroupedPercentileAccumulator.java | 291 +++++++
.../GroupedUserDefinedAggregateAccumulator.java | 44 +-
.../grouped/StreamingAggregationOperator.java | 9 +-
.../grouped/array/PercentileBigArray.java | 73 ++
.../builder/InMemoryHashAggregationBuilder.java | 9 +-
.../relational/ColumnTransformerBuilder.java | 71 +-
.../queue/IndexedBlockingReserveQueue.java | 36 +-
.../iotdb/calc/metric/QueryExecutionMetricSet.java | 15 +-
.../calc/plan/planner/TableOperatorGenerator.java | 263 ++++++-
.../planner/memory/MemoryReservationManager.java | 6 +
.../udf/UserDefineScalarFunctionTransformer.java | 46 +-
.../datastructure/SerializableList.java | 3 +-
.../iotdb/calc/utils/constant/SqlConstant.java | 1 +
.../iotdb/calc/utils/sort/FileSpillerReader.java | 4 +-
.../fill/filter/FixedIntervalFillFilterTest.java} | 24 +-
.../aggregation/ExtremeAccumulatorTest.java | 150 ++++
iotdb-core/confignode/pom.xml | 30 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 18 +
.../iotdb/confignode/i18n/ManagerMessages.java | 19 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 17 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 18 +
.../iotdb/confignode/i18n/ManagerMessages.java | 25 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 17 +-
.../async/AsyncAINodeHeartbeatClientPool.java | 12 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 12 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 22 +-
.../client/async/CnToDnAsyncRequestType.java | 2 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 11 +-
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 2 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 128 ++-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 2 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 2 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 2 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 2 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 2 +-
.../client/sync/CnToDnSyncRequestType.java | 1 +
.../client/sync/SyncDataNodeClientPool.java | 3 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 81 +-
.../confignode/conf/ConfigNodeDescriptor.java | 248 ++++--
.../confignode/conf/ConfigNodeMemoryConfig.java | 89 +++
.../request/write/pipe/task/AlterPipePlanV2.java | 74 ++
.../request/write/pipe/task/DropPipePlanV2.java | 42 +-
.../pipe/task/OperateMultiplePipesPlanV2.java | 21 +-
.../write/pipe/task/SetPipeStatusPlanV2.java | 52 +-
...eStatusWithStoppedByRuntimeExceptionPlanV2.java | 36 +-
.../consensus/response/cq/ShowCQResp.java | 2 +-
.../externalservice/ShowExternalServiceResp.java | 2 +-
.../response/pipe/task/PipeTableResp.java | 35 +-
.../statemachine/ConfigRegionStateMachine.java | 404 +++++++---
.../iotdb/confignode/manager/ConfigManager.java | 112 ++-
.../apache/iotdb/confignode/manager/IManager.java | 7 +
.../iotdb/confignode/manager/ProcedureManager.java | 368 +++++++--
.../confignode/manager/RetryFailedTasksThread.java | 23 +-
.../manager/consensus/ConsensusManager.java | 81 +-
.../externalservice/ExternalServiceInfo.java | 3 +-
.../iotdb/confignode/manager/load/LoadManager.java | 79 ++
.../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 | 382 ++++-----
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 35 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 21 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 17 +-
.../pipe/coordinator/runtime/PipeMetaSyncer.java | 26 +-
.../runtime/PipeRuntimeCoordinator.java | 6 +-
.../runtime/heartbeat/PipeHeartbeat.java | 22 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 120 +--
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 26 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 157 +++-
.../coordinator/task/PipeTaskCoordinatorLock.java | 22 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 4 +-
.../resource/PipeConfigNodeResourceManager.java | 14 +
.../manager/schema/ClusterSchemaManager.java | 275 +++++--
.../schema/ClusterSchemaQuotaStatistics.java | 2 +-
.../subscription/SubscriptionCoordinator.java | 123 +++
.../subscription/SubscriptionOwnerLeaseSyncer.java | 97 +++
.../confignode/persistence/ProcedureInfo.java | 13 +-
.../persistence/executor/ConfigPlanExecutor.java | 8 +-
.../persistence/partition/PartitionInfo.java | 27 +-
.../confignode/persistence/pipe/PipeInfo.java | 37 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 451 +++++++++--
.../persistence/schema/ClusterSchemaInfo.java | 24 +-
.../mnode/container/ConfigMNodeContainer.java | 2 +-
.../persistence/subscription/SubscriptionInfo.java | 68 ++
.../procedure/CompletedProcedureRecycler.java | 14 +-
.../iotdb/confignode/procedure/Procedure.java | 20 +
.../confignode/procedure/ProcedureExecutor.java | 169 +++-
.../procedure/TimeoutExecutorThread.java | 45 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 339 ++++++--
.../procedure/env/RegionMaintainHandler.java | 35 +-
.../procedure/env/RemoveDataNodeHandler.java | 52 +-
.../procedure/impl/StateMachineProcedure.java | 3 +-
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../procedure/impl/node/AbstractNodeProcedure.java | 12 +
.../DataPartitionTableIntegrityCheckProcedure.java | 141 +++-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 122 ++-
.../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/AlterPipeProcedureV2.java | 64 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 60 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 112 ++-
.../impl/pipe/task/StartPipeProcedureV2.java | 95 ++-
.../impl/pipe/task/StopPipeProcedureV2.java | 58 +-
.../impl/region/AddRegionPeerProcedure.java | 30 +-
.../impl/region/CreateRegionGroupsProcedure.java | 54 +-
.../impl/region/RemoveRegionGroupProcedure.java | 386 ++++++++++
.../schema/AlterEncodingCompressorProcedure.java | 2 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 2 +-
.../impl/schema/DeleteDatabaseProcedure.java | 113 +--
.../impl/schema/DeleteLogicalViewProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../AbstractOperateSubscriptionProcedure.java | 20 +
.../runtime/CommitProgressSyncProcedure.java | 10 +-
.../runtime/ConsumerGroupMetaSyncProcedure.java | 10 +-
.../SubscriptionHandleLeaderChangeProcedure.java | 9 +-
...bstractOperateSubscriptionAndPipeProcedure.java | 39 +-
.../subscription/CreateSubscriptionProcedure.java | 18 +-
.../subscription/DropSubscriptionProcedure.java | 17 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 9 +-
.../impl/trigger/CreateTriggerProcedure.java | 2 +-
.../impl/trigger/DropTriggerProcedure.java | 2 +-
.../confignode/procedure/scheduler/LockQueue.java | 10 +-
.../scheduler/SimpleProcedureScheduler.java | 37 +-
.../procedure/state/RemoveRegionGroupState.java} | 6 +-
.../state/schema/DeleteDatabaseState.java | 5 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 1 +
.../iotdb/confignode/service/ConfigNode.java | 10 +-
.../thrift/ConfigNodeRPCServiceHandler.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 12 +
.../writelog/io/SingleFileLogReader.java | 5 +-
.../conf/ConfigNodeMemoryConfigTest.java | 61 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 131 ++++
.../consensus/response/pipe/PipeTableRespTest.java | 125 +++
.../confignode/manager/load/LoadManagerTest.java | 70 ++
.../router/leader/HashLeaderBalancerTest.java | 65 ++
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 229 +++++-
.../task/PipeTaskCoordinatorLockTest.java | 60 ++
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 212 +++++
.../confignode/persistence/AuthorInfoTest.java | 44 +-
.../confignode/persistence/PartitionInfoTest.java | 27 +
.../pipe/PipeTaskInfoAutoRestartTest.java | 324 +++++++-
.../pipe/PipeTaskInfoConsensusPipeTest.java | 4 +-
.../subscription/SubscriptionInfoTest.java | 194 +++++
.../SubscriptionInfoTopicValidationTest.java | 28 +
.../procedure/CompletedProcedureRecyclerTest.java | 76 ++
.../iotdb/confignode/procedure/TestLockRegime.java | 23 +
.../procedure/TestProcedureExecutor.java | 116 +++
.../procedure/entity/SimpleLockProcedure.java | 11 +-
...aPartitionTableIntegrityCheckProcedureTest.java | 13 +
.../pipe/AbstractOperatePipeProcedureV2Test.java | 168 ++++
.../PipeHandleLeaderChangeProcedureTest.java | 47 ++
.../impl/pipe/task/AlterPipeProcedureV2Test.java | 1 +
.../impl/pipe/task/AlterPipeProcedureV3Test.java | 1 +
.../impl/pipe/task/CreatePipeProcedureV2Test.java | 20 +
.../impl/pipe/task/DropPipeProcedureV2Test.java | 22 +
.../impl/pipe/task/StartPipeProcedureV2Test.java | 20 +
.../impl/pipe/task/StopPipeProcedureV2Test.java | 22 +-
.../region/RemoveRegionGroupProcedureTest.java | 100 +++
iotdb-core/consensus/pom.xml | 18 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 28 +-
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 23 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 22 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 5 +
.../consensus/iot/IoTConsensusServerImpl.java | 159 +++-
.../iot/client/AsyncIoTConsensusServiceClient.java | 2 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 3 +-
.../iot/service/IoTConsensusRPCServiceHandler.java | 4 +-
.../service/IoTConsensusRPCServiceProcessor.java | 12 +-
.../iot/snapshot/SnapshotFragmentReader.java | 14 +-
.../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 | 58 +-
.../simple/SimpleConsensusServerImpl.java | 4 +-
.../apache/iotdb/consensus/EmptyStateMachine.java | 4 +-
.../iot/AddPeerSnapshotLoadFailureTest.java | 354 +++++++++
.../iot/snapshot/SnapshotFragmentReaderTest.java | 97 +++
.../iotdb/consensus/iot/util/TestStateMachine.java | 4 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 4 +-
.../consensus/simple/SimpleConsensusTest.java | 4 +-
iotdb-core/datanode/pom.xml | 52 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 7 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 79 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 122 ++-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 +
.../iotdb/db/i18n/StorageEngineMessages.java | 20 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 6 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 77 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 121 ++-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 +
.../iotdb/db/i18n/StorageEngineMessages.java | 20 +
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 2 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 27 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 63 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 71 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 13 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 4 +
.../db/consensus/DataRegionConsensusImpl.java | 8 +
.../db/consensus/SchemaRegionConsensusImpl.java | 3 +
.../dataregion/DataRegionStateMachine.java | 50 +-
.../schemaregion/SchemaRegionStateMachine.java | 25 +-
.../load/LoadAnalyzeMissingSchemaException.java} | 11 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 36 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 167 +++-
.../subtask/processor/PipeProcessorSubtask.java | 6 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 81 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 8 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 57 +-
.../deletion/DeletionResourceManager.java | 3 +
.../consensus/deletion/recover/DeletionReader.java | 5 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 2 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 24 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 8 +-
.../common/tablet/PipeRawTabletEventConverter.java | 42 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 5 +-
.../event/common/tablet/PipeTabletCollector.java | 29 +-
.../tablet/parser/TabletInsertionEventParser.java | 135 +++-
.../TabletInsertionEventTreePatternParser.java | 3 +-
.../event/common/terminate/PipeTerminateEvent.java | 2 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 33 +-
.../query/TsFileInsertionEventQueryParser.java | 108 ++-
.../scan/AlignedSinglePageWholeChunkReader.java | 2 +-
.../parser/scan/SinglePageWholeChunkReader.java | 40 +-
.../scan/TsFileInsertionEventScanParser.java | 440 ++++++++---
.../overview/PipeDataNodeSinglePipeMetrics.java | 10 +-
.../metric/processor/PipeProcessorMetrics.java | 3 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 70 +-
.../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 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 3 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 229 +++++-
.../transform/converter/ValueConverter.java | 30 +-
.../statement/PipeConvertedInsertRowStatement.java | 9 +
.../visitor/PipeStatementTSStatusVisitor.java | 4 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 13 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 254 +++++-
.../resource/memory/InsertNodeMemoryEstimator.java | 15 +-
.../resource/memory/PipeDynamicMemoryBlock.java | 2 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 18 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 5 +
.../tsfile/PipeTsFileResourceSegmentLock.java | 10 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 48 +-
.../batch/PipeSchemaRegionWritePlanEventBatch.java | 557 ++++++++++++++
.../evolvable/request/PipeTransferPlanNodeReq.java | 28 +-
.../request/PipeTransferTabletBatchReq.java | 98 ++-
.../request/PipeTransferTabletRawReq.java | 98 ++-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 182 ++++-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 7 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 161 +++-
.../handler/PipeTransferTrackableHandler.java | 56 +-
.../async/handler/PipeTransferTsFileHandler.java | 2 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 187 ++++-
.../sink/protocol/writeback/WriteBackSink.java | 383 ++++++++-
.../pipe/sink/util/TabletStatementConverter.java | 116 ++-
.../source/dataregion/IoTDBDataRegionSource.java | 84 --
...istoricalDataRegionTsFileAndDeletionSource.java | 148 ++--
.../PipeRealtimeDataRegionHybridSource.java | 98 ++-
.../PipeTsFileEpochProgressIndexKeeper.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 61 +-
.../iotdb/db/protocol/client/an/AINodeClient.java | 3 +-
.../iotdb/db/protocol/session/SessionManager.java | 25 +
.../thrift/handler/BaseServerContextHandler.java | 7 +-
.../handler/InternalServiceThriftHandler.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 7 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 197 +++--
.../thrift/impl/PushMultiPipeMetaHelper.java | 86 +++
.../db/queryengine/common/MPPQueryContext.java | 81 ++
.../common/header/DatasetHeaderFactory.java | 17 +
.../db/queryengine/execution/StateMachine.java | 8 +-
.../execution/aggregation/ExtremeAccumulator.java | 32 +-
.../execution/aggregation/TreeAggregator.java | 92 +--
.../SlidingWindowAggregatorFactory.java | 36 +-
.../MPPDataExchangeServiceThriftHandler.java | 3 +-
.../fragment/FragmentInstanceContext.java | 129 ++++
.../fragment/FragmentInstanceManager.java | 2 +
.../execution/fragment/QueryContext.java | 4 +
.../execution/operator/ExplainAnalyzeOperator.java | 70 +-
.../execution/operator/OperatorContext.java | 32 +
.../operator/process/AggregationOperator.java | 25 +-
.../process/RawDataAggregationOperator.java | 129 ++--
.../operator/process/TagAggregationOperator.java | 15 +-
.../AbstractSeriesAggregationScanOperator.java | 26 +-
.../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 +-
.../source/relational/CteScanOperator.java | 2 +-
.../ExternalTsFileAggTableScanOperator.java | 180 +++++
.../relational/ExternalTsFileSeriesScanUtil.java | 94 +++
.../ExternalTsFileTableScanOperator.java | 168 ++++
.../InformationSchemaContentSupplierFactory.java | 17 +-
.../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 | 34 +-
.../execution/schedule/task/DriverTaskId.java | 2 +-
.../metric/DriverSchedulerMetricSet.java | 13 +
.../iotdb/db/queryengine/plan/Coordinator.java | 76 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 34 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 57 ++
.../load/TreeSchemaAutoCreatorAndVerifier.java | 39 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 4 +-
.../queryengine/plan/execution/QueryExecution.java | 8 +-
.../plan/execution/config/ConfigExecution.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 97 ++-
.../execution/config/TreeConfigTaskVisitor.java | 27 +
.../config/executor/ClusterConfigTaskExecutor.java | 623 ++++++++++++---
.../config/executor/IConfigTaskExecutor.java | 11 +
.../config/metadata/DatabaseSchemaTask.java | 9 +-
.../config/metadata/ShowFunctionsTask.java | 6 +
.../config/metadata/region/MigrateRegionTask.java | 2 +-
.../metadata/relational/AbstractDatabaseTask.java | 4 +-
.../relational/ShowCreateDatabaseTask.java | 96 +++
.../metadata/relational/ShowCreatePipeTask.java | 186 +++++
.../config/metadata/relational/ShowDBTask.java | 4 +-
.../ShowRepairDataPartitionTableProgressTask.java | 72 ++
.../execution/config/sys/pipe/ShowPipeTask.java | 5 +
.../config/sys/subscription/AlterTopicTask.java | 49 ++
.../sys/subscription/ShowCreateTopicTask.java | 116 +++
.../TableModelStatementMemorySourceVisitor.java | 54 +-
.../plan/expression/unary/InExpression.java | 2 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 44 +-
.../planner/DataNodeTableOperatorGenerator.java | 104 ++-
.../plan/planner/LocalExecutionPlanContext.java | 4 +
.../plan/planner/LocalExecutionPlanner.java | 96 ++-
.../memory/FakedMemoryReservationManager.java | 3 +
.../NotThreadSafeMemoryReservationManager.java | 111 ++-
.../memory/ThreadSafeMemoryReservationManager.java | 5 +
.../plan/AbstractFragmentParallelPlanner.java | 7 +-
.../planner/plan/node/PlanGraphJsonPrinter.java | 225 ++++++
.../plan/planner/plan/node/PlanGraphPrinter.java | 9 +
.../plan/planner/plan/node/PlanVisitor.java | 10 +
.../metadata/read/LevelTimeSeriesCountNode.java | 2 +-
.../node/metadata/read/TimeSeriesCountNode.java | 2 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 82 +-
.../planner/plan/node/write/InsertRowNode.java | 223 ++++--
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 5 +-
.../planner/plan/node/write/InsertTabletNode.java | 358 ++++++---
.../plan/planner/plan/node/write/ObjectNode.java | 4 +-
.../plan/node/write/RelationalInsertRowNode.java | 71 +-
.../plan/node/write/RelationalInsertRowsNode.java | 45 +-
.../node/write/RelationalInsertTabletNode.java | 120 ++-
.../relational/analyzer/AggregationAnalyzer.java | 84 +-
.../relational/analyzer/StatementAnalyzer.java | 360 ++++++++-
.../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 | 39 +-
.../fetcher/cache/TableDeviceCacheEntry.java | 20 +-
.../fetcher/cache/TableDeviceLastCache.java | 44 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 26 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 11 +-
.../cache/TreeDeviceSchemaCacheManager.java | 9 +-
.../plan/relational/planner/CteMaterializer.java | 1 +
.../plan/relational/planner/RelationPlanner.java | 100 ++-
.../relational/planner/TableLogicalPlanner.java | 3 +-
.../distribute/TableDistributedPlanGenerator.java | 216 +++++-
.../distribute/TableDistributedPlanner.java | 16 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 2 +
.../iterative/rule/PruneTableScanColumns.java | 21 +
.../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 | 18 +-
.../optimizations/PushPredicateIntoTableScan.java | 62 +-
.../optimizations/TransformSortToStreamSort.java | 27 +-
.../optimizations/UnaliasSymbolReferences.java | 41 +-
.../security/TreeAccessCheckVisitor.java | 18 +
.../sql/ast/{PipeEnriched.java => AlterTopic.java} | 53 +-
.../plan/relational/sql/ast/AstVisitor.java | 16 +
.../plan/relational/sql/ast/Explain.java | 28 +-
.../plan/relational/sql/ast/ExplainAnalyze.java | 37 +-
.../relational/sql/ast/ExplainOutputFormat.java} | 19 +-
.../plan/relational/sql/ast/InsertRow.java | 5 +-
.../plan/relational/sql/ast/InsertRows.java | 14 +-
.../plan/relational/sql/ast/InsertTablet.java | 13 +-
.../plan/relational/sql/ast/MigrateRegion.java | 22 +-
.../plan/relational/sql/ast/PipeEnriched.java | 2 +-
.../{PipeEnriched.java => ShowCreateDatabase.java} | 43 +-
.../ast/{PipeEnriched.java => ShowCreatePipe.java} | 45 +-
.../{PipeEnriched.java => ShowCreateTopic.java} | 45 +-
.../relational/sql/ast/WrappedInsertStatement.java | 22 +-
.../plan/relational/sql/parser/AstBuilder.java | 94 ++-
.../plan/relational/sql/parser/ErrorHandler.java | 6 +-
.../relational/sql/util/DataNodeSqlFormatter.java | 55 ++
.../plan/scheduler/load/LoadTsFileScheduler.java | 1 +
.../queryengine/plan/statement/StatementType.java | 2 +
.../plan/statement/StatementVisitor.java | 12 +
.../plan/statement/crud/InsertBaseStatement.java | 210 +++--
.../plan/statement/crud/InsertRowStatement.java | 128 ++-
.../crud/InsertRowsOfOneDeviceStatement.java | 12 +
.../plan/statement/crud/InsertTabletStatement.java | 161 +++-
.../metadata/DatabaseSchemaStatement.java | 32 +-
.../statement/metadata/ShowDatabaseStatement.java | 8 +-
.../metadata/region/MigrateRegionStatement.java | 14 +-
.../AlterTopicStatement.java} | 49 +-
...RepairDataPartitionTableProgressStatement.java} | 49 +-
.../FragmentInstanceStatisticsJsonDrawer.java | 372 +++++++++
.../db/queryengine/udf/InternalQueryExecutor.java | 133 ++++
.../db/queryengine/udf/InternalQueryResult.java | 65 ++
.../iotdb/db/queryengine/udf/IoTDBLocalImpl.java | 147 ++++
.../iotdb/db/queryengine/udf/UDFResultSetImpl.java | 154 ++++
.../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 +-
.../mem/mnode/container/MemMNodeContainer.java | 2 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 69 +-
.../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 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 12 +-
.../schemaengine/schemaregion/tag/TagManager.java | 125 +--
.../db/schemaengine/table/DataNodeTableCache.java | 47 +-
.../schemaengine/table/InformationSchemaUtils.java | 7 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 10 +-
.../iotdb/db/service/ExternalRPCService.java | 84 +-
.../iotdb/db/service/RegionMigrateService.java | 12 +-
.../iotdb/db/storageengine/StorageEngine.java | 3 +
.../db/storageengine/buffer/BloomFilterCache.java | 24 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 19 +-
.../buffer/TimeSeriesMetadataCache.java | 130 +++-
.../db/storageengine/dataregion/DataRegion.java | 7 +-
.../RepairUnsortedFileCompactionPerformer.java | 9 +-
.../task/InsertionCrossSpaceCompactionTask.java | 8 +-
.../utils/writer/AbstractCompactionWriter.java | 165 +++-
.../writer/AbstractCrossCompactionWriter.java | 3 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../utils/writer/FastInnerCompactionWriter.java | 10 +-
.../writer/ReadPointCrossCompactionWriter.java | 5 +-
.../writer/ReadPointInnerCompactionWriter.java | 5 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 4 +-
.../compaction/schedule/CompactionWorker.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 120 +--
.../memtable/AbstractWritableMemChunk.java | 17 +
.../memtable/AlignedWritableMemChunk.java | 7 +-
.../dataregion/memtable/TsFileProcessor.java | 162 ++--
.../dataregion/memtable/WritableMemChunk.java | 7 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 2 +-
.../dataregion/modification/IDPredicate.java | 7 +-
.../modification/v1/ModificationFileV1.java | 3 +-
.../dataregion/read/QueryDataSourceType.java | 3 +-
.../dataregion/read/control/FileReaderManager.java | 88 +++
.../dataregion/snapshot/SnapshotLoader.java | 137 +++-
.../dataregion/tsfile/TsFileResource.java | 13 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 31 +-
.../dataregion/wal/io/WALFileVersion.java | 4 +-
.../dataregion/wal/io/WALInputStream.java | 32 +-
.../dataregion/wal/io/WALMetaData.java | 12 +-
.../dataregion/wal/recover/WALRepairWriter.java | 3 +-
.../db/storageengine/load/LoadTsFileManager.java | 13 +
.../storageengine/load/active/ActiveLoadAgent.java | 6 +
.../load/active/ActiveLoadDirScanner.java | 17 +-
.../active/ActiveLoadFailedMessageHandler.java | 17 +
.../active/ActiveLoadScheduledExecutorService.java | 21 +-
.../load/active/ActiveLoadTsFileLoader.java | 29 +-
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 15 +-
.../converter/LoadTreeTsFileTabletIterator.java | 557 ++++++++++++++
.../converter/LoadTsFileDataTypeConverter.java | 112 +++
.../load/splitter/AlignedChunkData.java | 6 +-
.../db/storageengine/rescon/disk/TierManager.java | 18 +-
.../subscription/agent/SubscriptionTopicAgent.java | 98 +++
.../broker/SubscriptionPrefetchingQueue.java | 199 ++---
.../consensus/ConsensusLogToTabletConverter.java | 70 +-
.../event/batch/SubscriptionPipeEventBatch.java | 23 +-
.../SubscriptionPipeEventBatchSegmentLock.java | 4 +-
.../event/batch/SubscriptionPipeEventBatches.java | 29 +
.../response/SubscriptionEventTsFileResponse.java | 11 +-
.../receiver/SubscriptionReceiverV1.java | 73 +-
.../db/trigger/executor/TriggerFireVisitor.java | 53 +-
.../iotdb/db/utils/DataNodeObjectFileService.java | 3 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 71 +-
.../apache/iotdb/db/utils/cte/MemoryReader.java | 18 +-
.../strategy/DirectoryStrategyTest.java | 35 +
.../cache/TreeDeviceSchemaCacheManagerTest.java | 39 +
.../metadata/mtree/schemafile/SchemaFileTest.java | 33 +
.../schemaRegion/SchemaRegionManagementTest.java | 28 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 25 +-
.../agent/task/PipeSinkSubtaskExecutorTest.java | 1 +
.../task/subtask/sink/PipeSinkSubtaskTest.java | 44 ++
.../db/pipe/consensus/DeletionResourceTest.java | 10 +
.../pipe/event/PipeTabletInsertionEventTest.java | 211 +++++
.../pipe/event/TsFileInsertionEventParserTest.java | 343 ++++++++-
.../schema/PipeSchemaRegionSinkMetricsTest.java | 154 ++++
.../db/pipe/pattern/TreePatternPruningTest.java | 41 +-
.../changing/ChangingValueFilterTest.java | 55 ++
.../sdt/SwingingDoorTrendingFilterTest.java | 56 ++
.../TumblingTimeSamplingProcessorTest.java | 192 +++++
.../receiver/PipeStatementTsStatusVisitorTest.java | 32 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 65 ++
.../transform/converter/ValueConverterTest.java | 70 ++
.../PipeConvertedInsertRowStatementTest.java | 55 ++
.../memory/InsertNodeMemoryEstimatorTest.java | 12 +
.../tsfile/PipeTsFileResourceSegmentLockTest.java | 71 ++
.../sink/IoTDBDataNodeAsyncClientManagerTest.java | 57 ++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 665 ++++++++++++++++
.../db/pipe/sink/PipeSchemaRegionSinkTest.java | 386 ++++++++++
.../PipeSchemaRegionWritePlanEventBatchTest.java | 464 +++++++++++
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 213 +++++
.../handler/PipeTransferTrackableHandlerTest.java | 38 +-
.../sink/util/TabletStatementConverterTest.java | 64 ++
.../db/pipe/source/PipeRealtimeExtractTest.java | 151 +++-
...ricalDataRegionTsFileAndDeletionSourceTest.java | 100 +++
.../PipeTsFileEpochProgressIndexKeeperTest.java | 46 +-
...nternalRPCServiceImplPushMultiPipeMetaTest.java | 246 ++++++
.../execution/aggregation/AccumulatorTest.java | 46 ++
.../SlidingWindowAggregatorFactoryTest.java} | 29 +-
.../fragment/FragmentInstanceContextTest.java | 623 +++++++++++++++
.../fragment/QueryModificationLoaderTest.java | 3 +
.../execution/operator/CteScanOperatorTest.java | 2 +-
.../operator/ExplainAnalyzeOperatorTest.java | 96 +++
.../operator/SingleDeviceViewOperatorTest.java | 9 +-
.../process/window/function/FunctionTestUtils.java | 5 +-
.../operator/window/SessionWindowTest.java | 70 ++
.../schedule/DefaultDriverSchedulerTest.java | 41 +
.../queue/MultilevelPriorityQueueTest.java | 13 +-
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 74 ++
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 97 +++
.../metadata/relational/ShowCreateTaskTest.java | 234 ++++++
.../config/sys/pipe/ShowPipeTaskTest.java | 72 ++
...TableModelStatementMemorySourceVisitorTest.java | 88 +++
.../parser/MigrateRegionMultiRegionParseTest.java | 63 ++
.../parser/RemoveDataNodeMultiNodeParseTest.java | 59 ++
.../plan/parser/StatementGeneratorTest.java | 36 +
.../LocalExecutionPlannerOperatorsMemoryTest.java | 164 ++++
.../distribution/AggregationTableScanTest.java | 4 +-
.../planner/node/PlanGraphJsonPrinterTest.java | 573 ++++++++++++++
.../planner/node/write/InsertRowNodeSerdeTest.java | 127 +++
.../node/write/InsertRowsNodeSerdeTest.java | 35 +
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 34 +
.../node/write/InsertTabletNodeSerdeTest.java | 130 ++++
.../planner/node/write/WritePlanNodeSplitTest.java | 41 +
.../write/InsertNodeIsMeasurementFailedTest.java | 277 +++++++
.../analyzer/AggregationCornerCaseTest.java | 12 +-
.../relational/analyzer/SelectAliasReuseTest.java | 347 +++++++++
.../relational/analyzer/TableFunctionTest.java | 187 +++++
.../plan/relational/analyzer/TestMetadata.java | 13 +
.../ExternalTsFileQueryResourceTest.java | 203 +++++
.../relational/planner/CteMaterializerTest.java | 1 +
.../plan/relational/planner/CteSubqueryTest.java | 1 +
.../plan/relational/sql/ExplainFormatTest.java | 186 +++++
.../plan/relational/sql/ShowCreateTopicTest.java | 73 ++
.../MigrateRegionMultiRegionStatementTest.java | 75 ++
.../RemoveDataNodeMultiNodeStatementTest.java | 69 ++
.../relational/sql/parser/TopicStatementTest.java | 48 ++
.../scheduler/load/LoadTsFileSchedulerTest.java | 31 +
.../crud/InsertStatementPartialInsertTest.java | 320 ++++++++
.../FragmentInstanceStatisticsJsonDrawerTest.java | 594 ++++++++++++++
.../logfile/FakeCRC32DeserializerTest.java | 108 +++
.../schemaregion/tag/TagLogFileTest.java | 57 ++
.../schemaregion/tag/TagManagerTest.java | 216 ++++++
.../schemaengine/table/DataNodeTableCacheTest.java | 106 +++
.../buffer/TimeSeriesMetadataCacheTest.java | 283 +++++++
.../storageengine/dataregion/DataRegionTest.java | 30 +-
.../utils/writer/AbstractCompactionWriterTest.java | 167 ++++
.../compaction/repair/AbstractRepairDataTest.java | 11 +-
.../AbstractMemTablePartialInsertTest.java | 113 +++
.../memtable/MemChunkDeserializeTest.java | 23 +
.../dataregion/memtable/TsFileProcessorTest.java | 172 +++++
.../modification/TableDeletionEntryTest.java | 9 +
.../dataregion/snapshot/IoTDBSnapshotTest.java | 222 +++++-
.../active/ActiveLoadFailedMessageHandlerTest.java | 51 ++
.../load/active/ActiveLoadTsFileLoaderTest.java | 152 ++++
...atementDataTypeConvertExecutionVisitorTest.java | 399 ++++++++++
.../ConsensusLogToTabletConverterTest.java | 58 ++
...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 +-
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 4 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 30 +-
.../conf/iotdb-system.properties.template | 119 ++-
.../apache/iotdb/commons/i18n/CommonMessages.java | 8 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 8 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../iotdb/commons/auth/user/BasicUserManager.java | 6 +-
.../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 | 3 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 72 ++
.../iotdb/commons/conf/CommonDescriptor.java | 77 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 16 +-
.../commons/consensus/index/ProgressIndex.java | 11 +
.../index/impl/TimeWindowStateProgressIndex.java | 9 +-
.../disk/strategy/DirectoryStrategyType.java | 32 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 103 ++-
.../RepairDataPartitionTableProgressState.java} | 15 +-
.../commons/executable/ExecutableManager.java | 3 +-
.../memory/AutoResizingBufferMemoryMetrics.java | 112 +++
.../apache/iotdb/commons/memory/MemoryConfig.java | 87 ++-
.../iotdb/commons/partition/DataPartition.java | 18 +-
.../plugin/constructor/PipeSinkConstructor.java | 8 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 109 ++-
.../agent/task/execution/PipeSubtaskExecutor.java | 31 +-
.../pipe/agent/task/meta/PipeMetaKeeper.java | 177 ++++-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 9 +
.../pipe/agent/task/meta/PipeStaticMeta.java | 64 ++
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 4 +
.../pipe/agent/task/meta/PipeTemporaryMeta.java | 29 +-
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 25 +-
.../task/meta/PipeTemporaryMetaInCoordinator.java | 29 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 57 +-
.../agent/task/subtask/PipeReportableSubtask.java | 56 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 17 +-
.../pipe/config/constant/PipeSinkConstant.java | 22 +
.../pipe/config/constant/PipeSourceConstant.java | 2 +
.../pipe/config/constant/SystemConstant.java | 16 +
.../options/PipeInclusionOptions.java | 4 +-
.../pipe/datastructure/pattern/TablePattern.java | 17 +-
.../pipe/datastructure/pattern/TreePattern.java | 196 ++---
.../queue/serializer/PlainQueueSerializer.java | 3 +-
.../datastructure/visibility/VisibilityUtils.java | 84 +-
.../commons/pipe/resource/log/PipeLogger.java | 18 +-
.../resource/log/PipePeriodicalLogReducer.java | 75 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 6 +-
.../pipe/sink/limiter/PipeEndPointRateLimiter.java | 2 +-
.../thrift/request/PipeTransferFileSealReqV2.java | 8 +
.../pipe/sink/protocol/IoTDBAirGapSink.java | 5 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 8 +
.../protocol/PipeSinkWithSchedulingDelay.java} | 11 +-
.../iotdb/commons/pipe/source/IoTDBSource.java | 20 -
.../execution/MemoryEstimationHelper.java | 4 +-
.../plan/planner/plan/node/PlanNodeType.java | 2 +
.../function/TableBuiltinTableFunction.java | 4 +
.../plan/relational/sql/ast/GroupBy.java | 26 +-
.../sql/util/CommonQuerySqlFormatter.java | 9 +-
.../queryengine/utils/cte/CteDataStore.java | 14 +
.../schema/column/ColumnHeaderConstant.java | 46 +-
.../commons/schema/table/InformationSchema.java | 9 +
.../schema/table/InsertNodeMeasurementInfo.java | 9 +-
.../schema/table/column/TsTableColumnCategory.java | 7 +-
.../service/AbstractThriftServiceThread.java | 52 +-
.../iotdb/commons/service/NoopServerContext.java | 48 ++
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../subscription/config/SubscriptionConfig.java | 4 +
.../commons/subscription/meta/topic/TopicMeta.java | 271 ++++++-
.../TableBuiltinAggregationFunction.java | 4 +-
.../builtin/relational/tvf/M4TableFunction.java | 802 +++++++++++++++++++
.../org/apache/iotdb/commons/utils/FileUtils.java | 17 +
.../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 +-
.../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 16 +
.../client/mock/MockInternalRPCService.java | 7 +-
.../client/request/AsyncRequestManagerTest.java | 226 ++++++
...monDescriptorDiskSpaceWarningThresholdTest.java | 78 ++
...FolderOccupiedSpaceFirstStrategyRealFsTest.java | 127 +++
.../disk/strategy/DirectoryStrategyTypeTest.java | 63 ++
.../agent/task/meta/PipeTemporaryMetaTest.java | 92 +++
.../options/PipeInclusionOptionsTest.java | 48 ++
.../pattern/TreePatternParseTest.java | 83 ++
.../visibility/VisibilityUtilsTest.java | 97 +++
.../commons/pipe/resource/PipeLoggerTest.java | 83 ++
.../resource/log/PipePeriodicalLogReducerTest.java | 65 ++
.../common/PipeTransferSliceReqBuilderTest.java | 32 +
.../thrift/request/PipeRequestTypeTest.java | 61 ++
.../request/PipeTransferCompressedReqTest.java | 112 +++
.../request/PipeTransferFileSealReqV2Test.java | 65 ++
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 26 +
.../commons/pipe/task/PipeMetaKeeperTest.java | 189 +++++
.../commons/pipe/task/PipeSleepIntervalTest.java | 86 ++-
.../table/InsertNodeMeasurementInfoTest.java | 83 ++
.../NoopServerContextTest.java} | 31 +-
.../commons/subscription/topic/TopicDeSerTest.java | 200 +++++
.../apache/iotdb/commons/utils/FileUtilsTest.java | 8 +-
.../apache/iotdb/commons/utils/IOUtilsTest.java | 147 ++++
.../iotdb/commons/utils/JVMCommonUtilsTest.java | 27 +
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 31 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
.../thrift-commons/src/main/thrift/common.thrift | 2 +
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
.../src/main/thrift/confignode.thrift | 23 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
.../src/main/thrift/datanode.thrift | 36 +
library-udf/pom.xml | 8 +-
library-udf/src/assembly/tools/register-UDF.bat | 1 +
library-udf/src/assembly/tools/register-UDF.sh | 1 +
pom.xml | 181 ++---
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 +-
1115 files changed, 58020 insertions(+), 6683 deletions(-)
copy .claude/settings.json => .codex/hooks.json (100%)
mode change 100755 => 100644 .github/scripts/package-client-cpp-manylinux228.sh
delete mode 100644 .github/workflows/compile-check.yml
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteDatabaseState.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/CreateTableProbeFunction.java
(70%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceIdListInProcessTableFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceIdListTableFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameEnrichBeforeStartTableFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameEnrichInProcessTableFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceSummaryFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceSummaryNoCloseFunction.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteDatabaseState.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DropTableProbeFunction.java
(73%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteDatabaseState.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/InsertProbeFunction.java
(70%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/IoTDBLocalLogAggregateFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/IoTDBLocalLogFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/IoTDBLocalLogHelper.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/IoTDBLocalLogTableFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/LocalQueryUdafAtBeforeDestroyAggregateFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/LocalQueryUdafAtBeforeStartAggregateFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/LocalQueryUdafInAddInputAggregateFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/LocalQueryUdafInCombineStateAggregateFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/LocalQueryUdafInOutputFinalAggregateFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/MutatingQueryProbeFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/SecretTableQueryFunction.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/commit/IoTDBMigrateMultiRegionForIoTV1IT.java
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
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithDeletionMultiDataDirTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/RegionMigrateFileAssertions.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/IoTDBAutoResizingBufferMemoryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBSetConfigurationClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/performance/IoTDBSingleMeasurementCheckCachePerformanceIT.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/{auto/basic/IoTDBPipeSinkParallelIT.java
=> manual/IoTDBPipeWriteBackSinkIT.java} (56%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/IoTDBLocalIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/IoTDBLocalLogIT.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/IoTDBClientMutualSSLIT.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
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionTopicOwnerIT.java
create mode 100644
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/IoTDBLocal.java
copy
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/AbstractSubscriptionLocalIT.java
=> iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/UDFResultSet.java
(51%)
create mode 100644 iotdb-client/client-cpp/cmake/InstallOpenSSLRuntime.cmake
create mode 100644
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/NOTICE
create mode 100644
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/licenses/LICENSE-Boost-1.0
create mode 100644 iotdb-client/client-py/tests/unit/test_session_ssl.py
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteDatabaseState.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/AutoResizingBufferMemoryControl.java
(78%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/AutoResizingBufferMemoryManager.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcSslUtils.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/AutoResizingBufferTest.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/session/subscription/consumer/base/EmptyPollLogThrottler.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/EmptyPollLogThrottlerTest.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/Percentile.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/PercentileAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedPercentileAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/array/PercentileBigArray.java
copy
iotdb-core/calc-commons/src/{main/java/org/apache/iotdb/calc/execution/operator/process/fill/filter/FixedIntervalFillFilter.java
=>
test/java/org/apache/iotdb/calc/execution/operator/process/fill/filter/FixedIntervalFillFilterTest.java}
(59%)
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/ExtremeAccumulatorTest.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfig.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/procedure/impl/region/RemoveRegionGroupProcedure.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTemporaryMeta.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/RemoveRegionGroupState.java}
(87%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfigTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/HashLeaderBalancerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLockTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfoTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/CompletedProcedureRecyclerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2Test.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionGroupProcedureTest.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/snapshot/SnapshotFragmentReaderTest.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteDatabaseState.java
=>
datanode/src/main/java/org/apache/iotdb/db/exception/load/LoadAnalyzeMissingSchemaException.java}
(79%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeSchemaRegionWritePlanEventBatch.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/PushMultiPipeMetaHelper.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/metadata/relational/ShowCreateDatabaseTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/ShowCreatePipeTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/ShowRepairDataPartitionTableProgressTask.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/execution/config/sys/subscription/ShowCreateTopicTask.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/procedure/state/schema/DeleteDatabaseState.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ExplainOutputFormat.java}
(62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{PipeEnriched.java
=> ShowCreateDatabase.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{PipeEnriched.java
=> ShowCreatePipe.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{PipeEnriched.java
=> ShowCreateTopic.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{region/MigrateRegionStatement.java
=> subscription/AlterTopicStatement.java} (63%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{metadata/region/MigrateRegionStatement.java
=> sys/ShowRepairDataPartitionTableProgressStatement.java} (61%)
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/queryengine/udf/InternalQueryExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/udf/InternalQueryResult.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/udf/IoTDBLocalImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/udf/UDFResultSetImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeTsFileTabletIterator.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/schema/PipeSchemaRegionSinkMetricsTest.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
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
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSchemaRegionSinkTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSchemaRegionWritePlanEventBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplPushMultiPipeMetaTest.java
copy
iotdb-core/{node-commons/src/test/java/org/apache/iotdb/commons/utils/JVMCommonUtilsTest.java
=>
datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/aggregation/slidingwindow/SlidingWindowAggregatorFactoryTest.java}
(51%)
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/operator/ExplainAnalyzeOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/window/SessionWindowTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/ShowCreateTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/ShowPipeTaskTest.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/parser/MigrateRegionMultiRegionParseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/parser/RemoveDataNodeMultiNodeParseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlannerOperatorsMemoryTest.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/sql/ExplainFormatTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ShowCreateTopicTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/MigrateRegionMultiRegionStatementTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/RemoveDataNodeMultiNodeStatementTest.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/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/tag/TagLogFileTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerTest.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/load/active/ActiveLoadFailedMessageHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitorTest.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
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteDatabaseState.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/enums/RepairDataPartitionTableProgressState.java}
(73%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/AutoResizingBufferMemoryMetrics.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/resource/log/PipePeriodicalLogReducer.java
(50%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteDatabaseState.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/PipeSinkWithSchedulingDelay.java}
(82%)
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/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/conf/CommonDescriptorDiskSpaceWarningThresholdTest.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/pipe/agent/task/meta/PipeTemporaryMetaTest.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/datastructure/pattern/TreePatternParseTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/visibility/VisibilityUtilsTest.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/resource/log/PipePeriodicalLogReducerTest.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/pipe/task/PipeMetaKeeperTest.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/JVMCommonUtilsTest.java
=> service/NoopServerContextTest.java} (53%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/IOUtilsTest.java
