This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/pipe-logical-backup-sink
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7772f632331 Merge origin/master into feat/pipe-logical-backup-sink
add f028736f105 Optimize ConfigNode region lookups and reduce metadata
copying (#18902)
add 9bb1f4d14e2 Fix stale IoTConsensus peers after restart during removal
(#18892)
add 10c5f89ba52 [PIPE][Subscription] Fix pipe races and subscription WAL
replay wakeup (#18904)
add 4943c730d7a [Fix] Guard stopped Pipe polling and retain LOAD payloads
until replicated (#18913)
add 2abe6e925eb [Pipe] Refresh credential user IDs and retain privilege
metadata across retries (#18914)
add f709ef52ff5 Avoid eager aggregation type coverage checks on first
query (#18915)
add 8a8a6da57be [Pipe] Avoid quadratic aligned page memory estimation
(#18917)
add 08380be95ae Fixed multiple configNode bugs (#17609)
add c462a975553 Make IoTConsensus peer-list reset retries best effort
(#18929)
add 35b9b708687 Fix IoTConsensusV2 progress for split LOAD TsFiles (#18927)
add d5a2da0b228 Fix pattern_match partition isolation and singleton
handling (#18924)
add 49ba3be90cb [Subscription] Make column filters follow schema changes
by default (#18925)
add 85277b3b689 Filter offline DataNode URLs and add Java client seed
fallback (#18921)
add c75e9a8f70b Prohibit rollback of a procedure which has passed its
commit point (#18909)
add 9904ca34008 Preserve LOAD failure details in logs and client responses
(#18935)
add 86ae95729ab [Subscription][Pipe] Improve receiver error messages and
diagnostics (#18932)
add 576d6a7b3cf [Fix] Harden split LOAD recovery, deletion dispatch and
memory bounds (#18930)
add e7fd2894912 [Fix] Support unordered query results in COPY TO TsFile
(#18928)
add 9647e38692f [Subscription] Restore consensus subscription brokers
after restart (#18916)
add 6844c476885 [Subscription] Fix stalled WAL replay retries across file
refresh and rotation (#18919)
add 38b8969258a Restore DataNode removal cleanup after child procedure
failures (#18947)
add ddb1741118b Use default credentials in seed fallback IT and centralize
IT guidelines (#18944)
add ccbc71d60cb Fix misleading shutdown interruption warnings (#18939)
add 491e392aca5 [Test] Fix WAL gap recovery assertions for lazy
multi-writer replay (#18942)
add c535723a17a [Test] Fix asynchronous assertions in pipe integration
tests (#18941)
add 9ffa89327f8 [Test] Speed up schema, pipe and subscription integration
tests (#18943)
add 5a437f59a33 Fix concurrent JVM thread state metric refresh (#18950)
add 83d419796fb Fix receiver write admission stalls and RPC buffer
allocation failures (#18918)
add 4fceb75dfd8 Fix nullable AND results in tree-model CASE (#18875)
add 20cab121be9 [Fix] Prevent stale schema queue closes after leader
transfer (#18948)
add 6ca9cd9d1ff [Test] Fix the metadata lease override in DataNode unit
tests (#18953)
add e08a738d78b Fix table-model schema series metrics (#18951)
add 8a20619f0dc Refactor write memory accounting into named memory blocks
(#18848)
add 7f0ef94f0c0 [Feature] Support TAG value filtering for table
subscriptions (#18639)
add 36e1a13e558 [Docs] Consolidate repository agent instructions in
AGENTS.md (#18952)
add 10749a27f35 Release subscription WAL buffers between prefetch rounds
(#18956)
add 858df2843c5 [Test] Preserve quorum during session seed fallback
recovery (#18958)
add 4e05c9f8709 Avoid subscription WAL segment reloads across prefetch
slices (#18960)
add cef612edb89 [Bug] Reject empty repetition groups in pattern_match
(#18961)
add 49336d47731 [Metrics] Fix concurrent Prometheus scrapes and disk
sampling (#18957)
add fb0fb2095de Improve schema metadata error messages and recovery logs
(#18937)
add e876ddd023a Fix concurrent device attribute update serialization
counts (#18959)
add 1b9e0713fb1 Fix subscription WAL replay stalls (#18969)
add 4c4572040dc [Test] Stabilize consensus subscription seek tests on cold
JVMs (#18972)
add 212214e6ae2 Fix ACK retention recycling test initialization (#18974)
add 1e851a0e5ee Fix subscription consumer recovery after RPC timeout
(#18980)
add 0acff497175 Fix import-data and export-data correctness and error
reporting (#18828)
add 4f86b5681ea [Subscription] Diagnose stalled replay and WAL footer
recovery (#18970)
add f60066e9609 Trigger node status recovery snapshots after cluster
registration (#18965)
add 1d1074be72b [Test] Stabilize IoTDBRegionGroupLeaderDistributionIT
(#18981)
add 80d16007436 Reject column changes that conflict with a pending column
deletion or data type change (#18776)
add 3be5e53f214 Support auto-sync of tree-to-table views: detect new
measurements and add the matching columns (#18874)
add 4b0099f05a3 [Bug] Reject misplaced repetition signs in pattern_match
(#18983)
add ca207944c09 [Query] Share table fragment exchange budgets and consume
ready Collect inputs (#18869)
add b626c602ead [Pipe] Unify TsFile parser allocation and resize quotas
(#18984)
add 592d6635027 Fix same-region flush stalls during write admission
(#18985)
add d12bb339e1e LOAD TsFile: use the Pair the resolver takes and cover the
HA cases (#18901)
add 4767846ab90 [Pipe] Fix DAL persistence acknowledgments (#18833)
add 02e675a74d3 Preserve write-path causes and return delete failure
details (#18933)
add 4bbfa51c3c9 Fix RegionGroup limits for same-name tree and table
databases (#18990)
add e615946bab0 Fix startup with invalid storage memory proportions
(#18979)
add 7d90a2e5c51 Use graceful shutdown in subscription recovery IT and
remove parser limits from template (#18994)
add 316c93bd315 Fix row-order assumptions in time duration tag aggregation
IT (#18926)
add e4090f7c740 Verify node status failover through production RPCs
(#18963)
add a4202b47f99 Fix tree-model NOT predicate pushdown (#18982)
add 00df0e3340e Ignore non-field columns when collecting tree-view source
names (#19000)
add 7aa8e63a7c6 [JDBC] Fix table-model driver defects that break generic
JDBC clients (#18962)
add 374cd6d6b47 Add scoped agent guidance and reusable unordered IT
assertions (#19001)
add 20bb3a0b8aa Fix datanode PowerMock tests failing when
user_encrypt_token is set (#19008)
add 321bba77b39 Fix NPE in ALIGN BY DEVICE queries when a device's
predicate is always true (#19009)
add 7ce3d58c3db Distinguish tree and table unordered result test helpers
(#19010)
add b5ca7ebc4b2 Fix leader distribution and RegionGroup directory
assertions (#19006)
add fd6b0897058 Fix AUTO RegionGroup replacement checks across region
types (#19003)
add 6862fc0eea5 [Pipe] Optimized useless logic (#18737)
add 6b3b6a540a4 Keep fieldless TableSchema during compaction (#18997)
add af068e3b691 Merge remote-tracking branch 'origin/master' into
codex/pr18623-master-merge
No new revisions were added by this update.
Summary of changes:
AGENTS.md | 236 ++++-
CLAUDE.md | 218 ----
CONTRIBUTING.md | 21 +
LICENSE-binary | 16 -
THREAT_MODEL.md | 4 +-
architecture-test/pom.xml | 6 -
dependencies.json | 11 -
distribution/AGENTS.md | 78 ++
distribution/pom.xml | 9 -
distribution/src/assembly/library-pipe.xml | 51 -
integration-test/AGENTS.md | 147 +++
integration-test/pom.xml | 7 -
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 12 +
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 836 +++++-----------
.../it/cluster/IoTDBNodeStatusPersistenceIT.java | 164 ++-
.../confignode/it/cluster/NodeStatusTestAgent.java | 203 ----
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 236 ++---
.../IoTDBRegionMigrateITFrameworkForRatis.java | 7 +
...IoTDBRegionOperationReliabilityITFramework.java | 56 +-
.../IoTDBRegionMigrateNormalForIoTV2StreamIT.java | 74 ++
...DBRegionMigrateConfigNodeCrashIoTV2BatchIT.java | 2 +
...BRegionMigrateConfigNodeCrashIoTV2StreamIT.java | 2 +
...oTDBRegionMigrateConfigNodeCrashForRatisIT.java | 2 +
.../iotdb/db/it/IoTDBLoadTsFileClusterIT.java | 168 +++-
.../db/it/IoTDBLoadTsFileRegionMigrationIT.java | 403 ++++++++
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 2 +-
.../iotdb/db/it/IoTDBWriteMemoryLifecycleIT.java | 382 +++++++
.../db/it/aggregation/IoTDBTimeDurationIT.java | 3 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 17 +
.../iotdb/db/it/metric/IoTDBMetricFormatIT.java | 109 ++
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 5 +-
.../iotdb/db/it/query/IoTDBCaseWhenThenIT.java | 26 +
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 31 +
.../it/query/IoTDBPredicateConversionTreeIT.java | 231 ++++-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 91 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 125 ++-
.../manual/basic/IoTDBPipeLifeCycleIT.java | 3 +-
.../manual/basic/IoTDBPipeProtocolIT.java | 8 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 5 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 3 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 39 +
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 13 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 4 +-
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 12 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 5 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 68 --
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 379 -------
.../pipe/it/triple/IoTDBShowReceiversTripleIT.java | 83 +-
.../it/db/it/IoTDBMultiDeviceTableIT.java | 27 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 117 +++
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 45 +-
.../it/insertquery/IoTDBInsertQueryIT.java | 35 +-
.../it/query/recent/IoTDBClusterResultSetIT.java | 163 +++
.../it/query/recent/IoTDBCollectFanInIT.java | 371 +++++++
.../it/query/recent/IoTDBComplexQueryIT.java | 9 +
.../relational/it/query/recent/IoTDBCteIT.java | 82 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 28 +-
.../recent/IoTDBTopKRuntimeFilterScanPathIT.java | 3 +-
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 185 ++++
.../IoTDBUncorrelatedExistsSubqueryIT.java | 35 +-
.../IoTDBUncorrelatedQuantifiedComparisonIT.java | 296 +++---
.../IoTDBUncorrelatedScalarSubqueryIT.java | 33 +-
.../it/schema/IoTDBAlterColumnTypeIT.java | 55 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 25 +-
.../it/schema/IoTDBTreeToTableViewAutoSyncIT.java | 743 ++++++++++++++
.../session/it/IoTDBSessionSchemaTemplateIT.java | 26 +-
.../session/it/SessionSeedNodeFallbackIT.java | 297 ++++++
.../it/IoTDBSubscriptionITConstant.java | 3 +-
.../ConsensusSubscriptionTableITSupport.java | 28 +
...ConsensusSubscriptionColumnFilterClusterIT.java | 58 ++
.../IoTDBConsensusSubscriptionFilterTableIT.java | 74 ++
.../IoTDBConsensusSubscriptionRecoveryTableIT.java | 163 +++
.../IoTDBSubscriptionColumnFilterIT.java | 281 +++++-
.../api/customizer/parameter/PipeParameters.java | 9 -
.../customizer/parameter/PipeParametersTest.java | 9 +-
iotdb-client/cli/LOGICAL_BACKUP.md | 138 ---
iotdb-client/cli/pom.xml | 5 +
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 16 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 16 +
.../org/apache/iotdb/tool/common/Constants.java | 5 +-
.../iotdb/tool/common/ImportTsFileOperation.java | 59 ++
.../apache/iotdb/tool/data/AbstractExportData.java | 29 +-
.../apache/iotdb/tool/data/AbstractImportData.java | 197 ++--
.../org/apache/iotdb/tool/data/ExportData.java | 12 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 164 ++-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 131 +--
.../org/apache/iotdb/tool/data/ImportData.java | 3 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 86 +-
.../org/apache/iotdb/tool/data/ImportDataTree.java | 88 +-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 9 +-
.../apache/iotdb/tool/tsfile/ImportTsFileBase.java | 126 +--
.../iotdb/tool/tsfile/ImportTsFileScanTool.java | 8 +
.../iotdb/tool/data/DataToolRegressionTest.java | 1042 ++++++++++++++++++++
.../apache/iotdb/tool/tsfile/ImportTsFileTest.java | 205 ++++
.../org/apache/iotdb/isession/INodeSupplier.java | 11 +
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 7 +-
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 7 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 12 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 17 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 79 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 11 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 27 +-
.../iotdb/jdbc/IoTDBTablePreparedStatement.java | 128 ++-
.../IoTDBRelationalDatabaseMetadata.java | 555 +++++++----
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 39 +
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 20 +
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 209 ++++
.../jdbc/IoTDBRelationalDatabaseMetadataTest.java | 634 ++++++++++++
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 14 +
.../jdbc/IoTDBTablePreparedStatementTest.java | 313 ++++++
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 47 +-
.../iotdb/rpc/AutoResizingBufferMemoryManager.java | 12 +
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 4 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 5 +-
.../rpc/TCompressedElasticFramedTransport.java | 10 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 10 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../apache/iotdb/rpc/AutoResizingBufferTest.java | 347 +++++++
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 28 +
.../org/apache/iotdb/session/NodesSupplier.java | 276 +++++-
.../java/org/apache/iotdb/session/Session.java | 31 +-
.../apache/iotdb/session/SessionConnection.java | 31 +-
.../apache/iotdb/session/TableSessionBuilder.java | 3 +
.../org/apache/iotdb/session/ThriftConnection.java | 127 ++-
.../org/apache/iotdb/session/pool/SessionPool.java | 13 +-
.../session/pool/TableSessionPoolBuilder.java | 3 +
.../iotdb/session/SessionSeedNodeFallbackTest.java | 751 ++++++++++++++
.../session/ThriftConnectionLifecycleTest.java | 207 ++++
iotdb-client/subscription/README.md | 71 ++
.../iotdb/rpc/subscription/config/TopicConfig.java | 55 ++
.../rpc/subscription/config/TopicConstant.java | 2 +
.../rpc/subscription/config/TopicProperty.java | 90 ++
.../subscription/AbstractSubscriptionSession.java | 2 +-
.../base/AbstractSubscriptionConsumer.java | 33 +-
.../base/AbstractSubscriptionProvider.java | 9 +-
.../base/AbstractSubscriptionProviders.java | 40 +
.../rpc/subscription/config/TopicConfigTest.java | 82 ++
.../SubscriptionConsumerMultiProviderPollTest.java | 131 ++-
.../SubscriptionProviderConnectionTimeoutTest.java | 207 ++++
iotdb-core/ainode/AGENTS.md | 92 ++
iotdb-core/antlr/AGENTS.md | 54 +
iotdb-core/calc-commons/AGENTS.md | 49 +
.../operator/process/AnyChildBlocked.java | 274 +++++
.../operator/process/CollectOperator.java | 145 ++-
.../operator/process/MappingCollectOperator.java | 56 +-
.../column/binary/LogicAndColumnTransformer.java | 2 +-
.../operator/process/CollectOperatorTest.java | 707 +++++++++++++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 46 +
.../iotdb/confignode/i18n/ManagerMessages.java | 3 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 25 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 54 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 3 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 21 +
.../statemachine/ConfigRegionStateMachine.java | 322 ++++--
.../iotdb/confignode/manager/ConfigManager.java | 18 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 277 +++++-
.../iotdb/confignode/manager/load/LoadManager.java | 9 +
.../confignode/manager/load/cache/LoadCache.java | 10 +
.../iotdb/confignode/manager/node/NodeManager.java | 246 ++++-
.../manager/partition/PartitionManager.java | 6 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 12 +-
.../manager/schema/ClusterSchemaManager.java | 237 ++++-
.../partition/DatabasePartitionTable.java | 2 +-
.../persistence/partition/PartitionInfo.java | 21 +-
.../persistence/schema/ClusterSchemaInfo.java | 33 +-
.../confignode/persistence/schema/ConfigMTree.java | 11 +
.../schema/TreeDeviceViewFieldDetector.java | 305 +++---
.../persistence/subscription/SubscriptionInfo.java | 51 +-
.../iotdb/confignode/procedure/Procedure.java | 18 +
.../confignode/procedure/ProcedureExecutor.java | 122 ++-
.../confignode/procedure/RootProcedureStack.java | 4 +-
.../procedure/env/RegionMaintainHandler.java | 91 +-
.../procedure/impl/StateMachineProcedure.java | 44 +-
.../impl/node/AddConfigNodeProcedure.java | 4 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 9 +
.../impl/node/RemoveDataNodesProcedure.java | 46 +-
.../impl/region/RemoveRegionPeerProcedure.java | 78 +-
.../procedure/impl/schema/SchemaUtils.java | 54 +-
.../table/AbstractAlterOrDropTableProcedure.java | 34 +-
.../table/AbstractSetPropertiesProcedure.java | 19 +-
.../impl/schema/table/AddTableColumnProcedure.java | 23 +-
.../table/AlterTableColumnDataTypeProcedure.java | 3 +-
.../impl/schema/table/CreateTableProcedure.java | 54 +-
.../schema/table/DropTableColumnProcedure.java | 1 +
.../impl/schema/table/DropTableProcedure.java | 19 +-
.../schema/table/RenameTableColumnProcedure.java | 19 +-
.../impl/schema/table/RenameTableProcedure.java | 17 +
.../schema/table/view/AddViewColumnProcedure.java | 55 +-
.../table/view/CreateTableViewProcedure.java | 84 +-
.../impl/schema/table/view/DropViewProcedure.java | 33 +
.../schema/table/view/RenameViewProcedure.java | 19 +
.../table/view/SetViewPropertiesProcedure.java | 83 ++
.../subscription/topic/AlterTopicProcedure.java | 1 +
.../procedure/state/RemoveRegionPeerState.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +
.../statemachine/ConfigRegionStateMachineTest.java | 302 ++++++
.../manager/ClusterSchemaManagerTest.java | 234 +++++
.../manager/ConfigManagerDatabaseDeletionTest.java | 65 ++
.../load/cache/ConsensusGroupCacheTest.java | 28 +
.../manager/node/NodeManagerRegistrationTest.java | 260 +++++
.../PartitionManagerAutoExtensionTest.java | 181 ++++
.../pipe/agent/task/PipeConfigNodeSubtaskTest.java | 150 +++
.../iotdb/confignode/persistence/NodeInfoTest.java | 43 +
.../confignode/persistence/PartitionInfoTest.java | 29 +
.../persistence/schema/ConfigMTreeTest.java | 36 +
.../SubscriptionInfoTopicValidationTest.java | 78 ++
.../procedure/env/RegionMaintainHandlerTest.java | 85 +-
.../procedure/env/RegionReplicaSetLookupTest.java | 195 ++++
.../procedure/impl/StateMachineProcedureTest.java | 185 ++++
.../impl/node/RemoveDataNodePersistenceTest.java | 2 +
.../impl/node/RemoveDataNodesProcedureTest.java | 324 ++++++
.../region/RemovePeerRestartConsensusTest.java | 640 ++++++++++++
.../impl/region/RestartDuringRemovePeerTest.java | 490 +++++++++
.../topic/AlterTopicProcedureTest.java | 34 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 17 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 6 +
.../consensus/iot/IoTConsensusRecoveryTest.java | 181 ++++
.../iot/StalePeerListRestartReproductionTest.java | 272 +++++
.../iotdb/consensus/ratis/RatisConsensusTest.java | 40 +
iotdb-core/datanode/pom.xml | 5 +
.../assembly/resources/conf/logback-datanode.xml | 21 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 103 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 171 ++--
.../iotdb/db/i18n/DataNodeQueryMessages.java | 43 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 46 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 18 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 106 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 172 ++--
.../iotdb/db/i18n/DataNodeQueryMessages.java | 43 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 46 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 17 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 102 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 15 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +
.../dataregion/DataExecutionVisitor.java | 9 +-
.../schemaregion/SchemaExecutionVisitor.java | 238 ++++-
.../deletion/persist/PageCacheDeletionBuffer.java | 17 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 3 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 26 +-
.../TsFileInsertionEventParserMemoryManager.java | 23 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 140 ++-
.../parser/scan/SinglePageWholeChunkReader.java | 49 +-
.../scan/TsFileInsertionEventScanParser.java | 68 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 41 +-
.../resource/memory/PipeMemoryBlockCategory.java | 1 +
.../pipe/resource/memory/PipeMemoryBlockType.java | 1 +
.../db/pipe/resource/memory/PipeMemoryManager.java | 82 +-
...Block.java => PipeTsFileParserMemoryBlock.java} | 20 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 13 +-
.../batch/PipeTabletEventTsFileBatch.java | 162 ++-
...istoricalDataRegionTsFileAndDeletionSource.java | 19 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +
.../impl/DataNodeInternalRPCServiceImpl.java | 102 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../queryengine/execution/QueryStateMachine.java | 49 +-
.../execution/exchange/SharedTsBlockQueue.java | 6 +-
.../execution/exchange/sink/SinkChannel.java | 6 +-
.../execution/exchange/source/SourceHandle.java | 6 +-
.../fragment/FragmentInstanceContext.java | 18 +
.../queryengine/execution/memory/MemoryPool.java | 448 ++++++---
.../queryengine/execution/memory/MemorySide.java | 8 +-
.../process/copyto/TableCopyToOperator.java | 7 +-
.../process/copyto/tsfile/CopyToTsFileOptions.java | 7 +
.../execution/schedule/AbstractDriverThread.java | 16 +-
.../schedule/DriverTaskAbortedException.java | 2 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 29 +-
.../queryengine/plan/analyze/PredicateUtils.java | 98 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 9 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 56 +-
.../plan/execution/ExecutionResult.java | 8 +
.../queryengine/plan/execution/QueryExecution.java | 25 +-
.../execution/config/TableConfigTaskVisitor.java | 125 ++-
.../execution/config/TreeConfigTaskVisitor.java | 15 +-
.../config/executor/ClusterConfigTaskExecutor.java | 1 +
.../config/metadata/ShowAvailableUrlsTask.java | 8 +-
.../metadata/relational/ShowCreateViewTask.java | 7 +-
.../config/sys/subscription/ShowTopicsTask.java | 56 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 10 +
.../PredicateCanPushDownToSourceChecker.java | 8 +
.../visitor/predicate/ReversePredicateVisitor.java | 82 +-
.../planner/DataNodeTableOperatorGenerator.java | 4 +-
.../plan/planner/LocalExecutionPlanContext.java | 77 +-
.../plan/planner/LocalExecutionPlanner.java | 29 +-
.../planner/SharedExchangeBudgetEligibility.java | 70 ++
.../planner/plan/node/PlanGraphJsonPrinter.java | 11 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 36 +
.../plan/node/load/LoadTsFilePieceNode.java | 7 +-
.../plan/node/pipe/PipeOperateSchemaQueueNode.java | 7 +
.../relational/analyzer/StatementAnalyzer.java | 8 +-
.../relational/planner/TableLogicalPlanner.java | 59 +-
.../distribute/TableDistributedPlanGenerator.java | 95 +-
.../TableModelTypeProviderExtractor.java | 3 +-
.../plan/relational/planner/node/CopyToNode.java | 13 +-
.../optimizations/LogicalOptimizeFactory.java | 2 +
.../planner/optimizations/ParallelizeGrouping.java | 16 +
.../RemoveRedundantSortForCopyTo.java | 88 ++
.../planner/optimizations/SortElimination.java | 25 +
.../optimizations/TransformSortToStreamSort.java | 4 +
.../optimizations/UnaliasSymbolReferences.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 4 +
.../relational/sql/util/DataNodeSqlFormatter.java | 20 +-
.../plan/scheduler/ClusterScheduler.java | 3 +-
.../plan/scheduler/FragInstanceDispatchResult.java | 12 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 6 +-
.../plan/scheduler/load/DataPartitionResolver.java | 10 +-
.../plan/scheduler/load/DataPartitionRouter.java | 33 +-
.../plan/scheduler/load/LoadFallbackHandler.java | 56 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 25 +-
.../plan/scheduler/load/PieceDispatcher.java | 63 +-
.../plan/scheduler/load/TsFileSplitConsumer.java | 15 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 6 +-
.../schemaengine/lease/MetadataLeaseManager.java | 4 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 17 +-
.../attribute/update/UpdateClearContainer.java | 2 +-
.../attribute/update/UpdateDetailContainer.java | 7 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 9 +-
.../schemaregion/utils/MetaFormatUtils.java | 36 +-
.../view/TreeToTableViewReference.java | 94 ++
.../db/schemaengine/table/DataNodeTableCache.java | 185 +++-
.../iotdb/db/schemaengine/table/ITableCache.java | 14 +-
.../schemaengine/table/ITreeToTableViewCache.java | 70 ++
.../schemaengine/table/TreeToTableViewCache.java | 501 ++++++++++
.../table/ViewColumnAutoSyncTrigger.java | 337 +++++++
.../template/ClusterTemplateManager.java | 36 +-
.../metrics/IoTDBInternalLocalReporter.java | 156 ++-
.../db/storageengine/dataregion/DataRegion.java | 15 +-
.../storageengine/dataregion/DataRegionInfo.java | 27 +-
.../compaction/io/CompactionTsFileWriter.java | 17 +-
.../dataregion/flush/MemTableFlushTask.java | 164 ++-
.../dataregion/memtable/AbstractMemTable.java | 75 +-
.../dataregion/memtable/IMemTable.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 314 +++---
.../dataregion/memtable/TsFileProcessorInfo.java | 31 +-
.../timeindex/FileTimeIndexCacheRecorder.java | 6 +-
.../dataregion/wal/buffer/WALBuffer.java | 14 +-
.../dataregion/wal/io/ProgressWALReader.java | 4 +
.../dataregion/wal/io/WALByteBufReader.java | 4 +
.../dataregion/wal/io/WALInputStream.java | 45 +-
.../dataregion/wal/io/WALMetaData.java | 36 +
.../storageengine/dataregion/wal/node/WALNode.java | 4 +
.../dataregion/wal/recover/WALNodeRecoverTask.java | 3 +-
.../dataregion/wal/recover/WALRepairWriter.java | 15 +
.../wal/utils/MemoryControlledWALEntryQueue.java | 39 +-
.../db/storageengine/load/LoadTaskRetention.java | 26 +-
.../db/storageengine/load/LoadTsFileCleaner.java | 24 +-
.../db/storageengine/load/TsFileWriterManager.java | 109 +-
.../load/splitter/AlignedChunkData.java | 284 +++++-
.../splitter/BatchedAlignedValueChunkData.java | 31 +-
.../db/storageengine/load/splitter/ChunkData.java | 49 +-
.../load/splitter/ChunkPayloadRef.java | 94 +-
.../load/splitter/TsFileSplitter.java | 55 +-
.../rescon/memory/PrimitiveArrayManager.java | 58 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 63 +-
.../rescon/memory/WriteMemoryBlock.java | 218 ++++
.../rescon/memory/WriteMemoryManager.java | 76 ++
.../agent/SubscriptionBrokerAgent.java | 151 ++-
.../subscription/agent/SubscriptionTopicAgent.java | 54 +-
.../broker/SubscriptionPrefetchingQueue.java | 9 +-
.../consensus/ConsensusLogToTabletConverter.java | 61 +-
.../consensus/ConsensusPrefetchingQueue.java | 271 ++++-
.../ConsensusSubscriptionSetupHandler.java | 1 +
.../broker/consensus/ProgressWALIterator.java | 247 ++++-
.../columnfilter/ColumnFilterBinder.java | 7 +
.../columnfilter/ColumnFilterMatcher.java | 146 ++-
.../columnfilter/ColumnFilterParser.java | 5 +-
.../columnfilter/TabletColumnPruner.java | 17 +-
.../event/batch/SubscriptionFilterSnapshot.java | 125 +++
.../event/batch/SubscriptionPipeEventBatch.java | 6 +-
.../event/batch/SubscriptionPipeEventBatches.java | 54 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 155 ++-
.../batch/SubscriptionPipeTsFileEventBatch.java | 122 ++-
.../event/batch/SubscriptionTreeViewProjector.java | 126 +++
.../response/SubscriptionEventTabletResponse.java | 7 +-
.../receiver/SubscriptionReceiverV1.java | 157 ++-
.../db/subscription/tagfilter/TabletTagFilter.java | 251 +++++
.../tagfilter/TagFilterEvaluationException.java} | 30 +-
.../subscription/tagfilter/TagFilterEvaluator.java | 228 +++++
.../subscription/tagfilter/TagFilterMatcher.java | 423 ++++++++
.../db/subscription/tagfilter/TagFilterParser.java | 94 ++
.../TagFilterValidator.java} | 136 ++-
.../org/apache/iotdb/db/utils/TypeServices.java | 9 -
.../db/utils/datastructure/AlignedTVList.java | 12 +-
.../tsfile/write/BufferedFileChannelOutput.java | 192 ++++
.../write/TsFilePrecalculatedChunkWriter.java | 115 +--
.../iotdb/db/conf/DataNodeMemoryConfigTest.java | 98 ++
.../org/apache/iotdb/db/conf/PropertiesTest.java | 34 +
.../dataregion/DataExecutionVisitorTest.java | 185 ++++
.../dataregion/IoTConsensusShutdownTest.java | 2 +-
.../i18n/DataNodeSchemaMessagesZhFormatTest.java | 8 +-
.../iotdb/db/metadata/MetaFormatUtilsTest.java | 111 +++
.../SchemaRegionSimpleRecoverTest.java | 4 +-
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 3 +-
.../persist/PageCacheDeletionBufferTest.java | 198 ++++
.../pipe/event/PipeTsFileInsertionEventTest.java | 125 ++-
.../scan/AlignedPageMemoryUsageEstimatorTest.java | 130 +++
.../legacy/IoTDBLegacyPipeReceiverAgentTest.java | 58 +-
.../resource/PipeTsFileResourceManagerTest.java | 52 +
.../memory/PipeMemoryManagerResizeTest.java | 180 ++++
.../batch/PipeTabletEventTsFileBatchTest.java | 38 +
.../execution/QueryStateMachineTest.java | 35 +
.../exchange/MPPDataExchangeManagerTest.java | 53 +
.../execution/exchange/SharedTsBlockQueueTest.java | 43 +
.../execution/exchange/SourceHandleTest.java | 64 ++
.../execution/memory/MemoryPoolTest.java | 874 +++++++++++++++-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 2 +-
.../schedule/AbstractDriverThreadShutdownTest.java | 271 +++++
.../predicate/PredicateRemoveNotTest.java | 74 ++
.../expression/predicate/PredicateUtilsTest.java | 3 +
.../db/queryengine/plan/analyze/AnalyzeTest.java | 44 +
.../plan/analyze/PredicateUtilsTest.java | 70 ++
.../load/LoadTsFileAnalyzerDiagnosticsTest.java | 206 ++++
.../config/PipeAuthenticationIdentityTest.java | 131 +++
.../config/metadata/ShowAvailableUrlsTaskTest.java | 101 ++
.../sys/subscription/ShowTopicsTaskTest.java | 98 ++
.../LocalExecutionPlanContextBudgetTest.java | 596 +++++++++++
.../planner/LocalExecutionPlannerBudgetTest.java | 245 +++++
.../logical/DataQueryLogicalPlannerTest.java | 27 +
.../node/pipe/PipeOperateSchemaQueueNodeTest.java} | 29 +-
.../plan/relational/analyzer/AnalyzerTest.java | 10 +-
.../plan/relational/analyzer/TreeViewTest.java | 15 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 15 +-
.../planner/CollectInputPropertyTest.java | 163 +++
.../OrderingPropertyPropagationTest.java | 281 ++++++
.../optimizations/ParallelizeGroupingTest.java | 58 ++
.../TopKRuntimeFilterTreeViewPlanTest.java | 3 +-
.../relational/sql/parser/TopicStatementTest.java | 58 ++
.../scheduler/load/LoadFallbackHandlerTest.java | 154 +++
.../load/LoadTsFileDispatcherImplTest.java | 84 +-
.../plan/scheduler/load/PieceDispatcherTest.java | 146 +++
.../scheduler/load/TsFileSplitConsumerTest.java | 233 +++++
...TwoPhaseConsensusLoadStrategyMigrationTest.java | 183 ++++
.../plan/statement/InsertStatementTest.java | 6 +-
.../binary/LogicBinaryColumnTransformerTest.java | 90 ++
.../metric/SchemaMemMetricTableTest.java | 55 ++
.../update/UpdateContainerSerializationTest.java | 117 +++
.../table/DataNodeTableCacheLeaseTest.java | 5 +-
.../schemaengine/table/DataNodeTableCacheTest.java | 36 +-
.../table/TreeToTableViewCacheTest.java | 132 +++
.../template/ClusterTemplateManagerTest.java | 132 +++
.../metrics/IoTDBInternalLocalReporterTest.java | 623 ++++++++++++
.../storageengine/dataregion/DataRegionTest.java | 147 ++-
.../CompactionDataTypeAlterTableTest.java | 5 +-
.../CompactionTableModelTestFileWriter.java | 33 +
.../TableModelCompactionWithTTLTest.java | 2 +-
.../utils/CompactionTestFileWriterTest.java | 23 +
.../dataregion/memtable/MemTableFlushTaskTest.java | 100 ++
.../memtable/MemTableMemoryBlockTest.java | 167 ++++
.../dataregion/memtable/TsFileProcessorTest.java | 169 +++-
.../wal/buffer/WALBufferRollRecoveryTest.java | 23 +
.../wal/compression/WALCompressionTest.java | 73 ++
.../dataregion/wal/io/ProgressWALReaderTest.java | 75 ++
.../wal/recover/WALRepairWriterTest.java | 65 ++
.../file/UnsealedTsFileRecoverPerformerTest.java | 2 +-
.../storageengine/load/LoadTsFileCleanerTest.java | 42 +
.../load/LoadTsFileManagerSplitCoverageTest.java | 93 +-
.../storageengine/load/LoadTsFileManagerTest.java | 154 ++-
.../load/LoadTsFileTableSchemaTest.java | 2 +-
.../db/storageengine/load/TsFileSplitterTest.java | 791 +++++++++++++++
.../load/TsFileWriterManagerRecoveryTest.java | 254 +++++
.../load/splitter/ChunkDataDirectWriteTest.java | 91 ++
.../rescon/memory/SystemInfoTest.java | 232 +++++
.../rescon/memory/WriteMemoryBlockTest.java | 184 ++++
.../rescon/memory/WriteMemoryLifecycleTest.java | 133 +++
.../agent/SubscriptionTopicAgentTest.java | 63 ++
.../ConsensusLogToTabletConverterTest.java | 80 ++
.../ConsensusPrefetchingQueueDeliveryTest.java | 2 +-
...onsensusPrefetchingQueueInitializationTest.java | 5 +-
.../ConsensusPrefetchingQueueSeekTest.java | 69 +-
.../consensus/ConsensusPrefetchingQueueTest.java | 395 +++++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 19 +-
...onsensusPrefetchingQueueWriterOrderingTest.java | 89 +-
.../broker/consensus/ProgressWALIteratorTest.java | 281 +++++-
.../columnfilter/ColumnFilterBinderTest.java | 92 +-
.../batch/SubscriptionFilterSnapshotTest.java | 164 +++
.../SubscriptionPipeTabletEventBatchTest.java | 28 +
...ubscriptionPipeTsFileEventBatchCleanupTest.java | 32 +
.../receiver/SubscriptionReceiverV1Test.java | 151 ++-
.../tagfilter/TabletTagFilterTest.java | 182 ++++
.../tagfilter/TagFilterParserTest.java | 122 +++
.../apache/iotdb/db/utils/TypeServicesTest.java | 10 +
.../datastructure/PrimitiveArrayManagerTest.java | 122 +++
.../write/BufferedFileChannelOutputTest.java | 161 +++
.../src/test/resources/iotdb-system.properties | 2 +-
.../powermock/extensions/configuration.properties | 13 +-
.../metricsets/disk/LinuxDiskMetricsManager.java | 120 ++-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 3 +-
.../reporter/prometheus/PrometheusReporter.java | 59 +-
.../disk/LinuxDiskMetricsManagerTest.java | 149 +++
.../metricsets/jvm/JvmThreadMetricsTest.java | 143 +++
.../prometheus/PrometheusReporterTest.java | 188 ++++
iotdb-core/node-commons/AGENTS.md | 49 +
.../conf/iotdb-system.properties.template | 13 -
.../apache/iotdb/commons/i18n/CommonMessages.java | 20 +-
.../apache/iotdb/commons/i18n/QueryMessages.java | 8 +
.../apache/iotdb/commons/i18n/SchemaMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 9 +
.../apache/iotdb/commons/i18n/QueryMessages.java | 8 +
.../apache/iotdb/commons/i18n/SchemaMessages.java | 2 +
...nException.java => ColumnInAlterException.java} | 10 +-
...ception.java => ColumnInDeletionException.java} | 10 +-
.../apache/iotdb/commons/memory/MemoryManager.java | 37 +-
.../iotdb/commons/memory/ReadOnlyMemoryBlock.java | 110 +++
.../pipe/config/constant/PipeSinkConstant.java | 105 --
.../function/tvf/PatternMatchTableFunction.java | 25 +-
.../function/tvf/match/QetchAlgorithm.java | 69 +-
.../iotdb/commons/request/IConsensusRequest.java | 8 +
.../schema/column/ColumnHeaderConstant.java | 9 +
....java => TreeToTableViewTrieOperationType.java} | 48 +-
.../iotdb/commons/schema/table/TreeViewSchema.java | 19 +
.../apache/iotdb/commons/schema/table/TsTable.java | 1 +
.../commons/subscription/meta/topic/TopicMeta.java | 49 +-
.../commons/memory/ReadOnlyMemoryBlockTest.java | 81 ++
.../tvf/PatternMatchTableFunctionTest.java | 294 ++++++
.../commons/subscription/topic/TopicMetaTest.java | 72 ++
iotdb-core/relational-grammar/AGENTS.md | 55 ++
.../db/relational/grammar/sql/RelationalSql.g4 | 4 +-
.../src/main/thrift/confignode.thrift | 19 +
.../src/main/thrift/datanode.thrift | 9 +
library-pipe/opc-ua-sink-example/pom.xml | 91 --
.../java/org/apache/iotdb/opcua/ClientExample.java | 50 -
.../apache/iotdb/opcua/ClientExampleRunner.java | 166 ----
.../java/org/apache/iotdb/opcua/ClientTest.java | 104 --
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 124 ---
library-pipe/opc-ua-sink/README.md | 82 --
library-pipe/opc-ua-sink/pom.xml | 166 ----
.../iotdb/pipe/plugin/sink/opcua/OpcUaSink.java | 759 --------------
.../plugin/sink/opcua/client/ClientRunner.java | 282 ------
.../opcua/client/IoTDBKeyStoreLoaderClient.java | 129 ---
.../plugin/sink/opcua/client/IoTDBOpcUaClient.java | 572 -----------
.../sink/opcua/server/OpcUaKeyStoreLoader.java | 141 ---
.../plugin/sink/opcua/server/OpcUaNameSpace.java | 714 --------------
.../sink/opcua/server/OpcUaServerBuilder.java | 492 ---------
.../sink/opcua/server/OpcUaTypeServices.java | 145 ---
.../pipe/plugin/sink/opcua/OpcUaSinkTest.java | 242 -----
.../sink/opcua/OpcUaSinkTsFileMetadataTest.java | 167 ----
.../sink/opcua/OpcUaSinkTsFilePerformanceTest.java | 415 --------
.../plugin/sink/opcua/client/ClientRunnerTest.java | 147 ---
.../sink/opcua/client/IoTDBOpcUaClientTest.java | 310 ------
.../opcua/server/OpcUaNameSpaceMetadataTest.java | 168 ----
.../sink/opcua/server/OpcUaServerBuilderTest.java | 238 -----
.../server/OpcUaTcpNoneCompatibilityTest.java | 132 ---
.../sink/opcua/server/OpcUaTypeServicesTest.java | 44 -
library-pipe/pom.xml | 68 --
licenses/Bouncy Castle Licence | 17 -
pom.xml | 2 -
scripts/AGENTS.md | 86 ++
scripts/tools/windows/export-data.bat | 4 +-
scripts/tools/windows/export-tsfile.bat | 4 +-
scripts/tools/windows/import-data.bat | 4 +-
scripts/tools/windows/schema/export-schema.bat | 4 +-
scripts/tools/windows/schema/import-schema.bat | 4 +-
553 files changed, 40877 insertions(+), 11976 deletions(-)
mode change 120000 => 100644 AGENTS.md
delete mode 100644 CLAUDE.md
create mode 100644 distribution/AGENTS.md
delete mode 100644 distribution/src/assembly/library-pipe.xml
create mode 100644 integration-test/AGENTS.md
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/NodeStatusTestAgent.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileRegionMigrationIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBWriteMemoryLifecycleIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/metric/IoTDBMetricFormatIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBClusterResultSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBCollectFanInIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTreeToTableViewAutoSyncIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/SessionSeedNodeFallbackIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionRecoveryTableIT.java
delete mode 100644 iotdb-client/cli/LOGICAL_BACKUP.md
create mode 100644
iotdb-client/cli/src/test/java/org/apache/iotdb/tool/data/DataToolRegressionTest.java
create mode 100644
iotdb-client/cli/src/test/java/org/apache/iotdb/tool/tsfile/ImportTsFileTest.java
create mode 100644
iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBRelationalDatabaseMetadataTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/SessionSeedNodeFallbackTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/ThriftConnectionLifecycleTest.java
create mode 100644 iotdb-client/subscription/README.md
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicProperty.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionProviderConnectionTimeoutTest.java
create mode 100644 iotdb-core/ainode/AGENTS.md
create mode 100644 iotdb-core/antlr/AGENTS.md
create mode 100644 iotdb-core/calc-commons/AGENTS.md
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/AnyChildBlocked.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/process/CollectOperatorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigRegionStateMachineTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerDatabaseDeletionTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeManagerRegistrationTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/partition/PartitionManagerAutoExtensionTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtaskTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/RegionReplicaSetLookupTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/StateMachineProcedureTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RemovePeerRestartConsensusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RestartDuringRemovePeerTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/IoTConsensusRecoveryTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/StalePeerListRestartReproductionTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/{PipeTsFileMemoryBlock.java
=> PipeTsFileParserMemoryBlock.java} (61%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionTreeRegressionMisc.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemorySide.java
(83%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/SharedExchangeBudgetEligibility.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/RemoveRedundantSortForCopyTo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/view/TreeToTableViewReference.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/ITreeToTableViewCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/TreeToTableViewCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/ViewColumnAutoSyncTrigger.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryBlock.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionFilterSnapshot.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionTreeViewProjector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TabletTagFilter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/BatchProcessException.java
=> subscription/tagfilter/TagFilterEvaluationException.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterEvaluator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterMatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterParser.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/{columnfilter/ColumnFilterValidator.java
=> tagfilter/TagFilterValidator.java} (57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/tsfile/write/BufferedFileChannelOutput.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataExecutionVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/MetaFormatUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/AlignedPageMemoryUsageEstimatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/schedule/AbstractDriverThreadShutdownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzerDiagnosticsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/PipeAuthenticationIdentityTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowAvailableUrlsTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/subscription/ShowTopicsTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlanContextBudgetTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlannerBudgetTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/{node/PlanNodeDeserializeHelper.java
=> plan/node/pipe/PipeOperateSchemaQueueNodeTest.java} (54%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CollectInputPropertyTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadFallbackHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/PieceDispatcherTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TsFileSplitConsumerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TwoPhaseConsensusLoadStrategyMigrationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/UpdateContainerSerializationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/table/TreeToTableViewCacheTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/template/ClusterTemplateManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/IoTDBInternalLocalReporterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemTableMemoryBlockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/TsFileWriterManagerRecoveryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/SystemInfoTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryBlockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryLifecycleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionFilterSnapshotTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/tagfilter/TabletTagFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterParserTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/tsfile/write/BufferedFileChannelOutputTest.java
copy docker/src/main/DockerCompose/start-1c1d.sh =>
iotdb-core/datanode/src/test/resources/org/powermock/extensions/configuration.properties
(71%)
mode change 100755 => 100644
create mode 100644
iotdb-core/metrics/interface/src/test/java/org/apache/iotdb/metrics/metricsets/disk/LinuxDiskMetricsManagerTest.java
create mode 100644
iotdb-core/metrics/interface/src/test/java/org/apache/iotdb/metrics/metricsets/jvm/JvmThreadMetricsTest.java
create mode 100644 iotdb-core/node-commons/AGENTS.md
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/{TableInDeletionException.java
=> ColumnInAlterException.java} (74%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/{TableInDeletionException.java
=> ColumnInDeletionException.java} (73%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/ReadOnlyMemoryBlock.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/{TsTableInternalRPCType.java
=> TreeToTableViewTrieOperationType.java} (56%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/memory/ReadOnlyMemoryBlockTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/queryengine/plan/relational/function/tvf/PatternMatchTableFunctionTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/subscription/topic/TopicMetaTest.java
create mode 100644 iotdb-core/relational-grammar/AGENTS.md
delete mode 100644 library-pipe/opc-ua-sink-example/pom.xml
delete mode 100644
library-pipe/opc-ua-sink-example/src/main/java/org/apache/iotdb/opcua/ClientExample.java
delete mode 100644
library-pipe/opc-ua-sink-example/src/main/java/org/apache/iotdb/opcua/ClientExampleRunner.java
delete mode 100644
library-pipe/opc-ua-sink-example/src/main/java/org/apache/iotdb/opcua/ClientTest.java
delete mode 100644
library-pipe/opc-ua-sink-example/src/main/java/org/apache/iotdb/opcua/IoTDBKeyStoreLoaderClient.java
delete mode 100644 library-pipe/opc-ua-sink/README.md
delete mode 100644 library-pipe/opc-ua-sink/pom.xml
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSink.java
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/client/ClientRunner.java
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/client/IoTDBKeyStoreLoaderClient.java
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/client/IoTDBOpcUaClient.java
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaKeyStoreLoader.java
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaNameSpace.java
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaServerBuilder.java
delete mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServices.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTsFileMetadataTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTsFilePerformanceTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/client/ClientRunnerTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/client/IoTDBOpcUaClientTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaNameSpaceMetadataTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaServerBuilderTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTcpNoneCompatibilityTest.java
delete mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServicesTest.java
delete mode 100644 library-pipe/pom.xml
delete mode 100644 licenses/Bouncy Castle Licence
create mode 100644 scripts/AGENTS.md
