This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/memory_collect
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b7c033927df Fix Format
add e1840d0ea7a [IoTConsensus] More accurate statistics on IoTConsensus
memory management (#14965)
add 56080ee2f58 Revert "Allow to write time column only (#14703)" (#14967)
add b638a70a4cc Pipe: Reduce the frequency of printing logs when
AirGapConnector connection fails (#14949)
add a94ae439dde Fix the support of MQTT with java8 (#14968)
add f1a224e56c1 Subscription: unify tablet push consumer builder return
type (#14971)
add ede623a27d8 Pipe: Implemented OPC DA Sink for local COM & Fixed the
newest value of OPC UA Sink (#14964)
add 2a77b7ab162 Pipe: Optimize the TsFile memory control mechanism of the
disassembly table model (#14890)
add aad2caa9f22 Fix flush old leader NPE when rebanlce #14981
add 3384bd69a92 Subscription: add parameter to the clean up method to
distinguish the force close situation & fix reference count management for
iteration snapshot (#14966)
add a1b9f7938af [Table Model Subquery] Support Exists subquery
add 9ffef99a2ea Pipe: Make client-server the default setting of
opc-ua-sink (#14979)
add c1723158ebc [To Master] Adds extensibility to MQTT's table (#14976)
add 662de3115c5 Pipe: Fixed the NPE caused by creating a new Region during
the execution of Alter Pipe Procedure. (#14982)
add b3e57d29409 Shuffle nodeurls to make sure all connections aren't to
the first node by default #14983
add ee7e8f9d349 [RTO/RPO] Add Phi Accrual for Node failure detection
(#14866)
add 21ad376a2a3 Add -lpf param in ExportData (#14957)
add 5e1bd035dc6 Improved the calculation accuracy of table schema fetch +
partial query & Fixed the bug that the attributes' memory is not calculated
when schema region recovers (#14975)
add 9c66a3cdc83 Fix group by hash when process TsBlock more than 1024
lines (#14989)
add 82e9361c6a6 Implemented max ttl under specific database getter for
table model (#14977)
add 174b2cb968f IoTConsensusV2: Transfer table deletion without any parse
or filter (#14988)
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 5205e3c9130 Merge branch 'master' into feature/memory_collect
No new revisions were added by this update.
Summary of changes:
dependencies.json | 1 +
.../server/CustomizedJsonPayloadFormatter.java | 8 +-
.../org/apache/iotdb/mqtt/server/MyMessage.java | 80 ---
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 2 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 11 +-
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 12 +-
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 2 +-
.../IoTDBCorrelatedExistsSubqueryIT.java | 428 +++++++++++++
.../IoTDBUncorrelatedExistsSubqueryIT.java | 391 ++++++++++++
.../it/session/IoTDBSessionRelationalIT.java | 34 -
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 48 --
.../org/apache/iotdb/tool/common/OptionsUtil.java | 54 +-
.../org/apache/iotdb/tool/data/ExportData.java | 4 +-
.../java/org/apache/iotdb/session/Session.java | 17 +-
.../SubscriptionTablePushConsumerBuilder.java | 3 +-
iotdb-core/confignode/pom.xml | 4 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 45 ++
.../confignode/conf/ConfigNodeDescriptor.java | 30 +
.../manager/load/balancer/RouteBalancer.java | 24 +-
.../manager/load/cache/AbstractLoadCache.java | 26 +-
.../manager/load/cache/IFailureDetector.java} | 24 +-
.../manager/load/cache/detector/FixedDetector.java | 58 ++
.../load/cache/detector/PhiAccrualDetector.java | 181 ++++++
.../load/cache/node/AINodeHeartbeatCache.java | 15 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 12 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 11 +-
.../manager/load/cache/region/RegionCache.java | 12 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 2 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 4 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 4 +-
.../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 | 2 +-
.../resource/PipeConfigNodeResourceManager.java | 1 +
.../PipeConfigNodeSnapshotResourceManager.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 12 +-
.../iotdb/confignode/persistence/TTLInfo.java | 2 +-
.../confignode/persistence/pipe/PipeInfo.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 20 +
.../procedure/PartitionTableAutoCleaner.java | 14 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 1 +
.../manager/load/cache/detector/DetectorTest.java | 179 ++++++
.../common/request/IConsensusRequest.java | 5 +
.../common/request/IndexedConsensusRequest.java | 8 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 12 +-
iotdb-core/datanode/pom.xml | 8 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../PipeDataRegionConnectorConstructor.java | 4 +
.../runtime/PipeSchemaRegionListenerManager.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../pipe/agent/task/connection/EnrichedDeque.java | 2 +-
.../agent/task/connection/PipeEventCollector.java | 14 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 5 +-
.../subtask/connector/PipeConnectorSubtask.java | 4 +-
.../connector/PipeConnectorSubtaskManager.java | 2 +-
.../PipeRealtimePriorityBlockingQueue.java | 2 +-
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../connector/protocol/opcda/OpcDaConnector.java | 138 ++++
.../pipe/connector/protocol/opcda/OpcDaHeader.java | 200 ++++++
.../protocol/opcda/OpcDaServerHandle.java | 390 ++++++++++++
.../connector/protocol/opcua/OpcUaConnector.java | 50 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 2 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 67 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 30 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../scan/TsFileInsertionEventScanParser.java | 3 -
.../table/TsFileInsertionEventTableParser.java | 95 ++-
...ileInsertionEventTableParserTabletIterator.java | 421 ++++++++++---
.../dataregion/IoTDBDataRegionExtractor.java | 4 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 2 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 4 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 2 +-
.../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 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 2 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 65 ++
.../db/protocol/mqtt/JSONPayloadFormatter.java | 7 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 7 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 11 +-
.../iotdb/db/protocol/mqtt/PayloadFormatter.java | 6 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
...owOperator.java => AssignUniqueIdOperator.java} | 75 ++-
.../operator/schema/SchemaQueryScanOperator.java | 12 +-
.../operator/schema/source/ISchemaSource.java | 5 +
.../schema/source/TableDeviceFetchSource.java | 21 +
.../schema/source/TableDeviceQuerySource.java | 36 +-
.../InformationSchemaContentSupplierFactory.java | 2 +-
...perator.java => MergeSortLeftJoinOperator.java} | 57 +-
.../aggregation/grouped/hash/HashStrategy.java | 2 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 2 +-
.../plan/planner/TableOperatorGenerator.java | 53 ++
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/planner/plan/node/write/InsertNode.java | 3 +-
.../planner/plan/node/write/InsertRowNode.java | 3 -
.../node/write/RelationalInsertTabletNode.java | 8 -
.../PredicatePushIntoMetadataChecker.java | 7 +-
.../fetcher/TableHeaderSchemaValidator.java | 4 +
.../distribute/TableDistributedPlanGenerator.java | 58 +-
.../iterative/rule/AggregationDecorrelation.java | 83 +++
...olumns.java => PruneAssignUniqueIdColumns.java} | 20 +-
.../iterative/rule/RemoveRedundantExists.java | 104 +++
...orrelatedDistinctAggregationWithProjection.java | 186 ++++++
...elatedDistinctAggregationWithoutProjection.java | 167 +++++
...mCorrelatedGlobalAggregationWithProjection.java | 318 ++++++++++
...rrelatedGlobalAggregationWithoutProjection.java | 302 +++++++++
...CorrelatedGroupedAggregationWithProjection.java | 252 ++++++++
...relatedGroupedAggregationWithoutProjection.java | 233 +++++++
.../rule/TransformCorrelatedJoinToJoin.java | 99 +++
.../rule/TransformExistsApplyToCorrelatedJoin.java | 214 +++++++
...forceSingleRowNode.java => AssignUniqueId.java} | 55 +-
.../plan/relational/planner/node/Patterns.java | 27 +-
.../planner/optimizations/JoinUtils.java | 249 +++++---
.../optimizations/LogicalOptimizeFactory.java | 40 +-
.../optimizations/PlanNodeDecorrelator.java | 699 +++++++++++++++++++++
.../optimizations/PushPredicateIntoTableScan.java | 143 ++++-
.../optimizations/UnaliasSymbolReferences.java | 13 +
.../relational/planner/optimizations/Util.java | 19 +
.../plan/relational/sql/ast/InsertRows.java | 3 -
.../plan/statement/crud/InsertBaseStatement.java | 28 +-
.../plan/statement/crud/InsertRowStatement.java | 3 -
.../rescon/ISchemaRegionStatistics.java | 2 +
.../rescon/MemSchemaRegionStatistics.java | 16 +
.../attribute/DeviceAttributeStore.java | 48 +-
.../attribute/IDeviceAttributeStore.java | 16 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 36 +-
.../dataregion/memtable/AbstractMemTable.java | 24 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 2 +-
.../broker/SubscriptionPrefetchingQueue.java | 10 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 2 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 2 +-
.../db/subscription/event/SubscriptionEvent.java | 4 +-
.../event/batch/SubscriptionPipeEventBatch.java | 2 +-
.../event/batch/SubscriptionPipeEventBatches.java | 2 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 50 +-
.../SubscriptionPipeTabletIterationSnapshot.java | 44 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 2 +-
.../event/pipe/SubscriptionPipeEmptyEvent.java | 2 +-
.../event/pipe/SubscriptionPipeEvents.java | 2 +-
.../pipe/SubscriptionPipeTabletBatchEvents.java | 11 +-
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 4 +-
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 2 +-
.../SubscriptionConnectorSubtaskManager.java | 2 +-
.../db/tools/schema/SRStatementGenerator.java | 2 +
.../db/protocol/mqtt/PayloadFormatManagerTest.java | 2 +-
.../execution/operator/OperatorMemoryTest.java | 2 -
.../relational/analyzer/GroupByLargeDataTest.java | 179 ++++++
.../relational/planner/CorrelatedSubqueryTest.java | 153 +++++
...ueryTest.java => UncorrelatedSubqueryTest.java} | 104 ++-
...liasPresent.java => AssignUniqueIdMatcher.java} | 24 +-
.../planner/assertions/PlanMatchPattern.java | 6 +
.../conf/iotdb-system.properties.template | 25 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 34 +
.../iotdb/commons/conf/CommonDescriptor.java | 16 +
.../iotdb/commons/path/ExtendedPartialPath.java | 4 +
.../agent/plugin/builtin/BuiltinPipePlugin.java | 5 +
.../OpcDaConnector.java} | 10 +-
.../config/constant/PipeConnectorConstant.java | 8 +-
.../connector/protocol/IoTDBAirGapConnector.java | 21 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 2 +-
.../subscription/config/SubscriptionConfig.java | 21 +
pom.xml | 8 +-
190 files changed, 7114 insertions(+), 874 deletions(-)
delete mode 100644
example/mqtt-customize/src/main/java/org/apache/iotdb/mqtt/server/MyMessage.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/subquery/correlated/IoTDBCorrelatedExistsSubqueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/subquery/uncorrelated/IoTDBUncorrelatedExistsSubqueryIT.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/IFragInstanceDispatcher.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/IFailureDetector.java}
(60%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/detector/FixedDetector.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/detector/PhiAccrualDetector.java
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/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/detector/DetectorTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaConnector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaHeader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.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/execution/operator/process/{EnforceSingleRowOperator.java
=> AssignUniqueIdOperator.java} (55%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{MergeSortInnerJoinOperator.java
=> MergeSortLeftJoinOperator.java} (80%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/AggregationDecorrelation.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneFillColumns.java
=> PruneAssignUniqueIdColumns.java} (71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/RemoveRedundantExists.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformCorrelatedDistinctAggregationWithProjection.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformCorrelatedDistinctAggregationWithoutProjection.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformCorrelatedGlobalAggregationWithProjection.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformCorrelatedGlobalAggregationWithoutProjection.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformCorrelatedGroupedAggregationWithProjection.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformCorrelatedGroupedAggregationWithoutProjection.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformCorrelatedJoinToJoin.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/TransformExistsApplyToCorrelatedJoin.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{EnforceSingleRowNode.java
=> AssignUniqueId.java} (62%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PlanNodeDecorrelator.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/GroupByLargeDataTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CorrelatedSubqueryTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/{SubqueryTest.java
=> UncorrelatedSubqueryTest.java} (85%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/{AliasPresent.java
=> AssignUniqueIdMatcher.java} (72%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/{opcua/OpcUaConnector.java
=> opcda/OpcDaConnector.java} (86%)
