This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch udtf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 788abe098c0 fix UT
add c5a2e4364f4 Pipe: implement AutoCloseable for insert node event and
raw tablet event & Subscription: add parameter control tablet event batch
estimate & close memory block in tablet event for iteration snapshot (#14991)
add f4c85210eca Pipe: Refactor pipe metrics related packages (#14997)
add 90be866a86e Fix StreamingHashAggOperator when process input TsBlock
with more than maxTsBlockLineNumber unPreGroup values in one preGroup
add a40a0153fed Try remove NormalizeToOuterToInnerJoin
add 0db89873e78 Modified pks, sversion, dbname (#14999)
add 1adc74dffd2 fix: memtable enhancement issues (#14994)
add e8d07c156da Load: detect region migration during second phase (#15005)
add 17f099e03db Fix typo in SimpleNestedLoopJoinOperator
add 5911f231b79 Pipe: Using caching to optimize the verifyTableDataType
method in the Load analysis phase (#15007)
add 9154e7c67c8 revert: page access when initialize statistics and build
TsBlock for aligned memchunk (#15013)
add 83d53722cd3 Make the error message clearer for query operator
add d412a202af6 Reject insert without field column (#15017)
add f9f0574b0f7 Fix frozen IoTConsensus sync lag (#15023)
add 8fe854752de Bump jinja2 from 3.1.5 to 3.1.6 in /iotdb-core/ainode
(#15026)
add 1ab9631cb4b Added comment for table & column
add 93f0795233d IoTConsensusV2: persistent isGeneratedByPipeConsensus
(#14938)
add 1669f503907 [Fix](query)(table model) GroupedAccumulator are not
discovered before because of stream optimize
add b8947ff54fd Delete Maintain Auth
add 809ecd4cad1 Fix (#15027)
add 23068b42bbe Add memory metrics and refact memory allocation (#14710)
add f58ba839f2e Fixed the memory leakage of TableDeviceSchemaCache & The
invalidation logic when filter by SK & The bug that last time may not be
invalidated when the measurement with largest last time is invalidated (#15018)
add fddf0a6eaa2 Fixed the metadata query & Fragment Instance & retry's
timeout
add 93abf64655f Fix overflow when using format in ns timestamp precision
add 25af23d1b19 Added comments to tables and columns (#15033)
add 8608710e89a Fix Memory NPE when use IDEA to debug #15034
add 32cc3834e2a Merge branch 'master' into udtf
add bafd3f7b99a try rerun IT
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 73 ---
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 17 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 1 -
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 11 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 2 +-
.../manual/basic/IoTDBPipeLifeCycleIT.java | 54 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 12 +
.../it/db/it/IoTDBAuthenticationTableIT.java | 114 +++-
.../relational/it/db/it/IoTDBInsertTableIT.java | 40 +-
.../scalar/IoTDBFormatFunctionTableIT.java | 16 +-
.../query/old/query/IoTDBGreatestLeastTableIT.java | 2 +-
.../it/query/recent/IoTDBMaintainAuthIT.java | 89 +--
.../it/query/recent/IoTDBTableAggregationIT.java | 4 +-
.../IoTDBTableAggregationNonStreamIT.java} | 27 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 53 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 37 +-
.../it/session/IoTDBSessionRelationalIT.java | 141 +++--
.../it/local/IoTDBSubscriptionBasicIT.java | 38 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 88 +--
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 7 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 64 ++
.../IoTDBRelationalDatabaseMetadata.java | 119 +++-
.../base/AbstractSubscriptionConsumer.java | 7 +-
iotdb-core/ainode/poetry.lock | 149 +++--
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../request/ConfigPhysicalPlanVisitor.java | 15 +
...umnPlan.java => SetTableColumnCommentPlan.java} | 26 +-
...bleColumnPlan.java => SetTableCommentPlan.java} | 27 +-
.../iotdb/confignode/manager/ConfigManager.java | 14 +
.../manager/load/balancer/PartitionBalancer.java | 8 +-
.../iotdb/confignode/manager/node/NodeManager.java | 45 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 2 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 4 +-
.../extractor/ConfigRegionListeningFilter.java | 6 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 4 +-
...ConfigPhysicalPlanTablePatternParseVisitor.java | 22 +
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 9 +
.../PipeConfigNodeRemainingTimeMetrics.java | 2 +-
.../PipeConfigNodeRemainingTimeOperator.java | 2 +-
.../PipeConfigNodeResourceMetrics.java | 2 +-
.../{ => overview}/PipeProcedureMetrics.java | 2 +-
.../metric/{ => overview}/PipeTaskInfoMetrics.java | 2 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 2 +-
.../PipeConfigNodeReceiverMetrics.java | 2 +-
.../PipeConfigRegionConnectorMetrics.java | 2 +-
.../PipeConfigNodeListenerMetrics.java | 2 +-
.../PipeConfigRegionExtractorMetrics.java | 2 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 120 +++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 36 +-
.../resource/PipeConfigNodeResourceManager.java | 1 +
.../PipeConfigNodeSnapshotResourceManager.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 40 +-
.../persistence/executor/ConfigPlanExecutor.java | 6 +
.../confignode/persistence/pipe/PipeInfo.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 39 ++
.../confignode/persistence/schema/ConfigMTree.java | 31 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 33 +-
...igPhysicalPlanTablePatternParseVisitorTest.java | 18 +
.../iotdb/consensus/config/IoTConsensusConfig.java | 30 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +-
.../logdispatcher/IoTConsensusMemoryManager.java | 50 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 80 +--
.../consensus/pipe/PipeConsensusServerImpl.java | 4 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 6 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 684 +++++++++++++++++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 345 +----------
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 307 +--------
.../db/consensus/DataRegionConsensusImpl.java | 11 +-
.../runtime/PipeSchemaRegionListenerManager.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../pipe/agent/task/connection/EnrichedDeque.java | 2 +-
.../agent/task/connection/PipeEventCollector.java | 1 +
.../subtask/connector/PipeConnectorSubtask.java | 4 +-
.../connector/PipeConnectorSubtaskManager.java | 2 +-
.../PipeRealtimePriorityBlockingQueue.java | 2 +-
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 67 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 30 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 8 +-
.../event/realtime/PipeRealtimeEventFactory.java | 5 +-
.../dataregion/IoTDBDataRegionExtractor.java | 4 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 1 -
.../realtime/PipeRealtimeDataRegionExtractor.java | 2 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 4 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 2 +-
.../listener/PipeInsertionDataNodeListener.java | 8 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 4 +-
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 12 +
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 2 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 2 +-
.../{ => overview}/PipeHeartbeatEventMetrics.java | 2 +-
.../metric/{ => overview}/PipeResourceMetrics.java | 2 +-
.../PipeWALInsertNodeCacheMetrics.java | 2 +-
.../{ => processor}/PipeProcessorMetrics.java | 2 +-
.../PipeDataNodeReceiverMetrics.java | 2 +-
.../PipeSchemaRegionConnectorMetrics.java | 2 +-
.../PipeSchemaRegionExtractorMetrics.java | 2 +-
.../PipeSchemaRegionListenerMetrics.java | 2 +-
.../{ => sink}/PipeDataRegionConnectorMetrics.java | 2 +-
.../metric/{ => source}/PipeAssignerMetrics.java | 2 +-
.../{ => source}/PipeDataRegionEventCounter.java | 2 +-
.../PipeDataRegionExtractorMetrics.java | 2 +-
.../pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryBlock.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 100 +--
.../impl/DataNodeInternalRPCServiceImpl.java | 36 +-
.../execution/exchange/SharedTsBlockQueue.java | 2 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 2 +-
.../execution/exchange/sink/SinkChannel.java | 2 +-
.../execution/exchange/source/SourceHandle.java | 2 +-
.../execution/memory/LocalMemoryManager.java | 5 +-
.../queryengine/execution/memory/MemoryPool.java | 42 +-
.../execution/operator/AbstractOperator.java | 5 +-
.../join/SimpleNestedLoopCrossJoinOperator.java | 2 +-
.../InformationSchemaContentSupplierFactory.java | 15 +-
.../aggregation/grouped/GroupedAggregator.java | 4 +-
.../grouped/GroupedFirstAccumulator.java | 11 +-
.../grouped/GroupedFirstByAccumulator.java | 2 +-
.../grouped/GroupedLastAccumulator.java | 1 +
.../grouped/GroupedLastByAccumulator.java | 2 +-
.../grouped/GroupedVarianceAccumulator.java | 2 +-
.../grouped/StreamingHashAggregationOperator.java | 3 +-
.../execution/schedule/DriverScheduler.java | 6 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 8 +-
.../plan/analyze/ClusterPartitionFetcher.java | 5 +
.../plan/analyze/IPartitionFetcher.java | 4 +
.../analyze/cache/partition/PartitionCache.java | 16 +-
.../cache/schema/DataNodeDevicePathCache.java | 23 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 9 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 4 +
.../analyze/load/LoadTsFileTableSchemaCache.java | 24 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 6 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 7 +-
.../queryengine/plan/execution/QueryExecution.java | 4 -
.../execution/config/TableConfigTaskVisitor.java | 140 +++--
.../config/executor/ClusterConfigTaskExecutor.java | 85 +++
.../config/executor/IConfigTaskExecutor.java | 16 +
...nTask.java => AlterTableCommentColumnTask.java} | 13 +-
...esTask.java => AlterTableCommentTableTask.java} | 19 +-
.../relational/DescribeTableDetailsTask.java | 6 +
.../metadata/relational/ShowTablesDetailsTask.java | 7 +
.../execution/config/sys/pipe/ShowPipeTask.java | 2 +-
.../plan/planner/LocalExecutionPlanContext.java | 3 +-
.../plan/planner/LocalExecutionPlanner.java | 124 ++--
.../SimpleFragmentParallelPlanner.java | 2 +-
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../plan/planner/plan/node/write/InsertNode.java | 3 +-
.../plan/node/write/RelationalInsertRowNode.java | 5 -
.../analyzer/StatementAnalyzerFactory.java | 4 +
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 6 +-
.../fetcher/TableDeviceSchemaValidator.java | 6 +-
.../fetcher/TableHeaderSchemaValidator.java | 47 +-
.../fetcher/cache/TableAttributeSchema.java | 6 +-
.../fetcher/cache/TableDeviceLastCache.java | 5 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 19 +-
.../distribute/TableModelQueryFragmentPlanner.java | 2 +-
.../optimizations/PushPredicateIntoTableScan.java | 35 +-
.../plan/relational/security/AccessControl.java | 8 -
.../relational/security/AccessControlImpl.java | 6 +-
.../relational/security/AllowAllAccessControl.java | 5 -
.../relational/security/TableModelPrivilege.java | 5 -
.../plan/relational/sql/ast/AstVisitor.java | 12 +
.../plan/relational/sql/ast/ColumnDefinition.java | 27 +-
.../plan/relational/sql/ast/CreateTable.java | 8 +
.../ast/{DropColumn.java => SetColumnComment.java} | 26 +-
.../plan/relational/sql/ast/SetProperties.java | 12 -
.../{CountStatement.java => SetTableComment.java} | 60 +-
...onfiguration.java => ShowQueriesStatement.java} | 18 +-
.../plan/relational/sql/parser/AstBuilder.java | 29 +-
.../plan/relational/sql/rewrite/ShowRewrite.java | 26 +-
.../sql/rewrite/StatementRewriteFactory.java | 6 +-
.../plan/relational/sql/util/SqlFormatter.java | 42 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 117 ++--
.../unary/scalar/FormatColumnTransformer.java | 4 +-
.../metric/SchemaEngineCachedMetric.java | 5 +-
.../rescon/MemSchemaEngineStatistics.java | 41 +-
.../ReleaseFlushStrategySizeBasedImpl.java | 6 +-
.../db/service/metrics/CompactionMetrics.java | 2 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 2 +-
.../metrics/memory/ConsensusMemoryMetrics.java | 50 +-
.../metrics/memory/GlobalMemoryMetrics.java | 82 +--
.../metrics/memory/OffHeapMemoryMetrics.java | 102 +++
.../metrics/memory/QueryEngineMemoryMetrics.java | 281 ++++++---
.../metrics/memory/SchemaEngineMemoryMetrics.java | 159 +++--
.../metrics/memory/StorageEngineMemoryMetrics.java | 361 +++++++----
.../metrics/memory/StreamEngineMemoryMetrics.java | 50 +-
.../db/storageengine/buffer/BloomFilterCache.java | 27 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 27 +-
.../buffer/TimeSeriesMetadataCache.java | 27 +-
.../storageengine/dataregion/DataRegionInfo.java | 6 +-
.../execute/task/CrossSpaceCompactionTask.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 2 +-
.../task/RepairUnsortedFileCompactionTask.java | 2 +-
.../compaction/execute/utils/CompactionUtils.java | 12 +-
.../dataregion/memtable/AbstractMemTable.java | 9 -
.../memtable/AlignedReadOnlyMemChunk.java | 318 +++-------
.../memtable/AlignedWritableMemChunk.java | 134 ++--
.../memtable/AlignedWritableMemChunkGroup.java | 5 -
.../dataregion/memtable/IMemTable.java | 2 -
.../memtable/IWritableMemChunkGroup.java | 2 -
.../dataregion/memtable/ReadOnlyMemChunk.java | 16 +-
.../dataregion/memtable/TsFileProcessor.java | 12 +-
.../dataregion/memtable/WritableMemChunk.java | 4 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 8 -
.../read/reader/chunk/MemAlignedChunkReader.java | 188 ++----
.../read/reader/chunk/MemChunkReader.java | 4 +-
.../read/reader/chunk/MemPageReader.java | 6 +-
.../dataregion/tsfile/TsFileResource.java | 19 +
.../dataregion/wal/buffer/IWALBuffer.java | 10 +
.../dataregion/wal/buffer/WALBuffer.java | 13 +
.../storageengine/dataregion/wal/node/WALNode.java | 8 +-
.../wal/utils/MemoryControlledWALEntryQueue.java | 9 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 7 +-
.../memory/LoadTsFileAnalyzeSchemaMemoryBlock.java | 2 +-
.../memory/LoadTsFileDataCacheMemoryBlock.java | 4 +-
.../load/memory/LoadTsFileMemoryManager.java | 2 +-
.../rescon/memory/PrimitiveArrayManager.java | 16 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 187 ++----
.../rescon/memory/TimePartitionManager.java | 31 +-
.../rescon/memory/TsFileResourceManager.java | 40 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 44 +-
.../SubscriptionPipeTabletIterationSnapshot.java | 48 +-
.../SubscriptionConnectorSubtaskManager.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 55 +-
.../datastructure/FixedPriorityBlockingQueue.java | 2 +-
.../MergeSortAlignedTVListIterator.java | 147 ++---
...tIterator.java => MergeSortTVListIterator.java} | 63 +-
.../utils/datastructure/PageColumnAccessInfo.java | 52 --
.../iotdb/db/utils/datastructure/TVList.java | 4 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 1 -
.../execution/exchange/LocalSinkChannelTest.java | 7 +-
.../exchange/MPPDataExchangeManagerTest.java | 7 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 4 +-
.../execution/exchange/ShuffleSinkHandleTest.java | 4 +-
.../execution/exchange/SinkChannelTest.java | 7 +-
.../execution/exchange/SourceHandleTest.java | 15 +-
.../execution/memory/MemoryPoolTest.java | 6 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 5 +
.../plan/planner/distribution/Util.java | 5 +
.../plan/planner/distribution/Util2.java | 5 +
...ataTest.java => AggregationCornerCaseTest.java} | 148 ++++-
.../plan/relational/analyzer/AnalyzerTest.java | 4 +-
.../plan/relational/analyzer/TSBSMetadata.java | 7 +
.../plan/relational/analyzer/TestMatadata.java | 7 +
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 21 +-
.../plan/relational/planner/PlanTester.java | 9 +-
.../relational/sql/parser/AuthorStatementTest.java | 5 -
.../compaction/CompactionWorkerTest.java | 16 +-
.../FastCrossCompactionPerformerTest.java | 5 +-
.../cross/CrossSpaceCompactionSelectorTest.java | 5 +-
.../CompactionTableModelTestFileWriter.java | 14 +
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../compaction/utils/CompactionTaskQueueTest.java | 13 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 26 +-
.../rescon/memory/ResourceManagerTest.java | 6 +-
.../rescon/memory/TimePartitionManagerTest.java | 8 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 5 +-
.../datastructure/PrimitiveArrayManagerTest.java | 8 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 2 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 34 +
.../iotdb/commons/conf/CommonDescriptor.java | 20 +
.../commons/memory/AtomicLongMemoryBlock.java | 152 +++++
.../apache/iotdb/commons/memory/IMemoryBlock.java | 138 +++++
.../MemoryBlockType.java} | 11 +-
.../apache/iotdb/commons/memory/MemoryConfig.java} | 26 +-
.../iotdb/commons/memory/MemoryException.java} | 52 +-
.../apache/iotdb/commons/memory/MemoryManager.java | 523 ++++++++++++++++
.../schema/column/ColumnHeaderConstant.java | 7 +-
.../table/AlterOrDropTableOperationType.java | 8 +-
.../commons/schema/table/InformationSchema.java | 6 +
.../apache/iotdb/commons/schema/table/TsTable.java | 1 +
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../subscription/config/SubscriptionConfig.java | 21 +
.../iotdb/commons/memory/MemoryBlockTest.java | 67 ++
.../iotdb/commons/memory/MemoryManagerTest.java | 171 ++++++
.../db/relational/grammar/sql/RelationalSql.g4 | 19 +-
.../src/main/thrift/confignode.thrift | 1 +
283 files changed, 5845 insertions(+), 3269 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBAlignedSeriesQueryTable5IT.java
=> recent/IoTDBTableAggregationNonStreamIT.java} (61%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{AbstractTableColumnPlan.java
=> SetTableColumnCommentPlan.java} (71%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{AbstractTableColumnPlan.java
=> SetTableCommentPlan.java} (70%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> overview}/PipeConfigNodeRemainingTimeMetrics.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> overview}/PipeConfigNodeRemainingTimeOperator.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> overview}/PipeConfigNodeResourceMetrics.java (97%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> overview}/PipeProcedureMetrics.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> overview}/PipeTaskInfoMetrics.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> overview}/PipeTemporaryMetaInCoordinatorMetrics.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> receiver}/PipeConfigNodeReceiverMetrics.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> sink}/PipeConfigRegionConnectorMetrics.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> source}/PipeConfigNodeListenerMetrics.java (97%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{
=> source}/PipeConfigRegionExtractorMetrics.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/{
=> snapshot}/PipeConfigNodeSnapshotResourceManager.java (94%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/DataNodeMemoryConfig.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
overview}/PipeDataNodeRemainingEventAndTimeMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
overview}/PipeDataNodeRemainingEventAndTimeOperator.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
overview}/PipeHeartbeatEventMetrics.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
overview}/PipeResourceMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
overview}/PipeWALInsertNodeCacheMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
processor}/PipeProcessorMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
receiver}/PipeDataNodeReceiverMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
schema}/PipeSchemaRegionConnectorMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
schema}/PipeSchemaRegionExtractorMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
schema}/PipeSchemaRegionListenerMetrics.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
sink}/PipeDataRegionConnectorMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
source}/PipeAssignerMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
source}/PipeDataRegionEventCounter.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{ =>
source}/PipeDataRegionExtractorMetrics.java (99%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableDropColumnTask.java
=> AlterTableCommentColumnTask.java} (83%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableSetPropertiesTask.java
=> AlterTableCommentTableTask.java} (77%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DropColumn.java
=> SetColumnComment.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CountStatement.java
=> SetTableComment.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{LoadConfiguration.java
=> ShowQueriesStatement.java} (69%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/memory/OffHeapMemoryMetrics.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/{MergeSortTvListIterator.java
=> MergeSortTVListIterator.java} (67%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/PageColumnAccessInfo.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/{GroupByLargeDataTest.java
=> AggregationCornerCaseTest.java} (55%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/AtomicLongMemoryBlock.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/IMemoryBlock.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/datastructure/visibility/Visibility.java
=> memory/MemoryBlockType.java} (86%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/UnSetTTLTask.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryConfig.java}
(58%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RemoveConfigNode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryException.java}
(50%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryManager.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/memory/MemoryBlockTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/memory/MemoryManagerTest.java
