This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch win_metircs
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f66b1dfb3b3 Merge branch 'master' into win_metircs
add 332ba5b56ed Pipe: support multiple path patterns under tree model
(#16575)
add 01ae4dcc481 Load: Deleted the unnecessary auto-creation (#16624)
add 09da138a93f Resolve the problem that it will execute endFile() twice
and generate an invalid wal file that… (#16627)
add 1ba2bb79c92 Resolve the situation where the field value contains
commas in line formatter. (#16609)
add aa560e7ddc5 No need to include http client in distribution (#16634)
add 07d457e36df Fix union when cross region or need mapping from child
input
add 9daaaa8687d fix/loginlockmgr-constructor (#16636)
add fd98737405c Delete concurrent-206 and checker-qual directly dependency
add 2c9064ff67c [AINode] Adjust the maximum inference input length (#16640)
add dbf55834d67 Refactored some dependencies
add c196e0c9f8a Merge branch 'master' into win_metircs
No new revisions were added by this update.
Summary of changes:
LICENSE | 14 +-
LICENSE-binary | 4 -
dependencies.json | 7 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 13 +-
integration-test/import-control.xml | 2 +-
integration-test/pom.xml | 22 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 6 +-
.../itbase/runtime/ClusterTestConnection.java | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 +-
.../iotdb/it/framework/IoTDBTestListener.java | 2 +-
.../auto/basic/IoTDBTreePatternFormatIT.java | 326 ++++++++-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 71 ++
.../manual/IoTDBPipeTypeConversionISessionIT.java | 11 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 2 +-
...DBFillTable2IT.java => IoTDBUnionTable2IT.java} | 16 +-
.../it/query/recent/IoTDBUnionTableIT.java | 18 +
.../view/old/orderby/IoTDBOrderByTableViewIT.java | 2 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 +-
.../it/SkipOnSetUpAndTearDownFailure.java | 3 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 2 +-
iotdb-client/cli/pom.xml | 8 -
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../org/apache/iotdb/cli/utils/IoTPrinter.java | 2 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 4 +-
.../org/apache/iotdb/tool/data/ExportData.java | 4 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 6 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 2 +-
.../org/apache/iotdb/tool/data/ImportData.java | 4 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 8 +-
.../iotdb/tool/schema/AbstractSchemaTool.java | 2 +-
.../org/apache/iotdb/tool/schema/ExportSchema.java | 2 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 6 +-
.../org/apache/iotdb/tool/schema/ImportSchema.java | 2 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 4 +-
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 6 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 2 +-
.../subscription/SubscriptionTableTsFile.java | 2 +-
.../subscription/SubscriptionTreeTsFile.java | 2 +-
iotdb-client/jdbc/pom.xml | 4 -
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 24 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +-
iotdb-core/confignode/pom.xml | 16 -
.../confignode/conf/ConfigNodeRemoveCheck.java | 155 ----
.../consensus/request/write/cq/ActiveCQPlan.java | 2 +-
.../consensus/request/write/cq/AddCQPlan.java | 2 +-
.../consensus/request/write/cq/DropCQPlan.java | 2 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 2 +-
.../load/cache/detector/PhiAccrualDetector.java | 14 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 22 +-
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 60 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/TemplateTable.java | 2 +-
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
...figPhysicalPlanTreePatternParseVisitorTest.java | 79 +-
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../iotdb/confignode/persistence/CQInfoTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../confignode/persistence/QuotaInfoTest.java | 2 +-
.../iotdb/confignode/persistence/TTLInfoTest.java | 2 +-
.../confignode/persistence/TriggerInfoTest.java | 2 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 2 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 2 +-
.../schema/TemplatePreSetTableTest.java | 2 +-
.../persistence/schema/TemplateTableTest.java | 2 +-
iotdb-core/consensus/pom.xml | 9 -
.../consensus/iot/IoTConsensusServerImpl.java | 2 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 2 +-
.../consensus/iot/client/DispatchLogHandler.java | 2 +-
.../iot/logdispatcher/IndexController.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 4 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
iotdb-core/datanode/pom.xml | 24 -
.../src/main/codegen/templates/ModeAccumulator.ftl | 2 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 10 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 2 +-
.../agent/task/connection/PipeEventCollector.java | 4 +-
.../tablet/parser/TabletInsertionEventParser.java | 11 +-
.../parser/TsFileInsertionEventParserProvider.java | 6 +-
.../metric/processor/PipeProcessorMetrics.java | 3 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 4 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 3 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 3 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 3 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 3 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 3 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 2 +-
.../pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 19 +-
.../transform/converter/ValueConverter.java | 2 +-
.../PipeStatementTreePatternParseVisitor.java | 30 +-
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 2 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 2 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 2 +-
.../async/handler/PipeTransferTsFileHandler.java | 2 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 2 +-
.../websocket/WebSocketConnectorServer.java | 4 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 2 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 2 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 2 +-
.../source/dataregion/IoTDBDataRegionSource.java | 7 +-
.../realtime/PipeRealtimeDataRegionSource.java | 4 +-
.../listener/PipeTimePartitionListener.java | 3 +-
.../PipePlanTreePatternParseVisitor.java | 53 +-
.../db/protocol/mqtt/BrokerAuthenticator.java | 2 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 2 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 15 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 6 +-
.../table/v1/handler/RequestValidationHandler.java | 2 +-
.../rest/v1/handler/RequestValidationHandler.java | 2 +-
.../rest/v1/impl/GrafanaApiServiceImpl.java | 2 +-
.../rest/v2/handler/RequestValidationHandler.java | 2 +-
.../rest/v2/impl/GrafanaApiServiceImpl.java | 2 +-
.../iotdb/db/protocol/session/SessionManager.java | 2 +-
.../execution/exchange/MPPDataExchangeManager.java | 2 +-
.../execution/exchange/SharedTsBlockQueue.java | 2 +-
.../execution/exchange/sink/LocalSinkChannel.java | 2 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 2 +-
.../execution/exchange/sink/SinkChannel.java | 2 +-
.../exchange/source/LocalSourceHandle.java | 2 +-
.../execution/exchange/source/SourceHandle.java | 2 +-
.../queryengine/execution/memory/MemoryPool.java | 2 +-
.../operator/process/CollectOperator.java | 6 +-
.../operator/process/MappingCollectOperator.java | 76 ++
.../operator/process/TagAggregationOperator.java | 2 +-
.../process/join/merge/MergeSortComparator.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 4 +
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../plan/execution/memory/MemorySourceHandle.java | 2 +-
.../expression/other/CaseWhenThenExpression.java | 2 +-
.../plan/expression/unary/RegularExpression.java | 2 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 2 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 2 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 2 +-
...ncatDeviceAndBindSchemaForPredicateVisitor.java | 2 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 2 +-
.../plan/optimization/AggregationPushDown.java | 4 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 2 +-
.../plan/planner/LogicalPlanBuilder.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 20 +-
.../plan/planner/TemplatedLogicalPlan.java | 2 +-
.../distribution/DistributionPlanContext.java | 2 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../plan/AbstractFragmentParallelPlanner.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 4 +-
.../planner/plan/node/process/GroupByTagNode.java | 2 +-
.../plan/node/source/LastQueryScanNode.java | 2 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 2 +-
.../function/tvf/ForecastTableFunction.java | 2 +-
.../planner/distribute/SubPlanGenerator.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 34 +-
.../relational/planner/node/SetOperationNode.java | 4 +-
.../plan/relational/planner/node/UnionNode.java | 31 +-
.../relational/sql/ast/SearchedCaseExpression.java | 2 +-
.../plan/relational/sql/ast/ShowSubscriptions.java | 4 +-
.../plan/relational/sql/ast/ShowTopics.java | 4 +-
.../relational/sql/ast/SimpleCaseExpression.java | 2 +-
.../plan/relational/type/CompatibleResolver.java | 4 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../statement/component/GroupByTagComponent.java | 2 +-
.../plan/statement/component/IntoItem.java | 2 +-
.../AbstractCaseWhenThenColumnTransformer.java | 2 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 2 +-
.../schemaengine/schemaregion/tag/TagManager.java | 2 +-
.../iotdb/db/schemaengine/template/Template.java | 2 +-
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../execute/recover/CompactionRecoverTask.java | 2 +-
.../estimator/AbstractCompactionEstimator.java | 2 +-
.../dataregion/flush/CompressionRatio.java | 2 +-
.../dataregion/snapshot/SnapshotLoader.java | 2 +-
.../dataregion/wal/io/CheckpointReader.java | 6 +
.../dataregion/wal/io/WALInputStream.java | 14 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 4 +
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../load/active/ActiveLoadDirScanner.java | 2 +-
.../load/active/ActiveLoadTsFileLoader.java | 2 +-
.../load/config/LoadTsFileConfigurator.java | 2 +-
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../rescon/disk/DirectoryChecker.java | 2 +-
.../broker/SubscriptionPrefetchingQueue.java | 7 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 3 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 3 +-
.../event/batch/SubscriptionPipeEventBatch.java | 4 +-
.../event/batch/SubscriptionPipeEventBatches.java | 4 +-
.../response/SubscriptionEventTsFileResponse.java | 3 +-
.../SubscriptionPrefetchingQueueMetrics.java | 3 +-
.../trigger/service/TriggerManagementService.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +-
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 4 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 2 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 2 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 2 +-
.../db/auth/user/LocalFileUserManagerTest.java | 2 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 2 +-
.../schemaRegion/SchemaRegionBasicTest.java | 2 +-
.../PipeStatementTreePatternParseVisitorTest.java | 46 +-
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 2 +
.../PipePlanTreePatternParseVisitorTest.java | 256 ++++++-
.../source/SchemaRegionListeningQueueTest.java | 2 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 2 +-
.../relational/analyzer/TableFunctionTest.java | 4 +-
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../storageengine/buffer/BloomFilterCacheTest.java | 2 +-
.../dataregion/TsFileManagerTest.java | 2 +-
.../TsFileResourceProgressIndexTest.java | 2 +-
.../compaction/AbstractCompactionTest.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 2 +-
.../compaction/CompactionValidationTest.java | 2 +-
.../TsFileValidationCorrectnessTests.java | 2 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 2 +-
.../inner/FastCompactionPerformerAlignedTest.java | 2 +-
.../FastCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 2 +-
.../compaction/inner/InnerCompactionLogTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 2 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../recover/SizeTieredCompactionRecoverTest.java | 2 +-
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../dataregion/flush/CompressionRatioTest.java | 2 +-
.../dataregion/memtable/TsFileProcessorTest.java | 2 +-
.../dataregion/tsfile/TsFileResourceTest.java | 2 +-
.../wal/compression/WALCompressionTest.java | 2 +-
.../dataregion/wal/io/WALFileTest.java | 22 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 2 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../apache/iotdb/db/utils/OpenFileNumUtilTest.java | 2 +-
.../db/utils/SchemaRegionSnapshotParserTest.java | 2 +-
.../db/utils/datastructure/AlignedTVListTest.java | 2 +-
.../db/utils/datastructure/BinaryTVListTest.java | 2 +-
.../db/utils/datastructure/BooleanTVListTest.java | 2 +-
.../db/utils/datastructure/DoubleTVListTest.java | 2 +-
.../db/utils/datastructure/FloatTVListTest.java | 2 +-
.../db/utils/datastructure/IntTVListTest.java | 2 +-
.../db/utils/datastructure/LongTVListTest.java | 2 +-
iotdb-core/node-commons/pom.xml | 16 -
.../commons/auth/role/LocalFileRoleAccessor.java | 4 +-
.../commons/auth/user/LocalFileUserAccessor.java | 4 +-
.../apache/iotdb/commons/client/ThriftClient.java | 2 +-
.../AsyncConfigNodeInternalServiceClient.java | 2 +-
.../async/AsyncDataNodeExternalServiceClient.java | 2 +-
.../async/AsyncDataNodeInternalServiceClient.java | 2 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 2 +-
.../async/AsyncPipeConsensusServiceClient.java | 2 +-
.../async/AsyncPipeDataTransferServiceClient.java | 2 +-
.../commons/executable/ExecutableManager.java | 17 +-
.../commons/external/collections4/BidiMap.java | 138 ++++
.../external/collections4/IterableSortedMap.java} | 40 +-
.../external/collections4/OrderedBidiMap.java | 51 ++
.../collections4/ResettableListIterator.java} | 43 +-
.../external/collections4/SortedBidiMap.java | 59 ++
.../collections4/bidimap/AbstractDualBidiMap.java | 798 +++++++++++++++++++++
.../collections4/bidimap/DualTreeBidiMap.java | 414 +++++++++++
.../collection/AbstractCollectionDecorator.java | 182 +++++
.../iterators/AbstractIteratorDecorator.java} | 57 +-
.../AbstractUntypedIteratorDecorator.java | 66 ++
.../iterators/ListIteratorWrapper.java | 274 +++++++
.../keyvalue/AbstractMapEntryDecorator.java | 92 +++
.../collections4/map/AbstractIterableMap.java} | 42 +-
.../collections4/map/AbstractMapDecorator.java | 153 ++++
.../map/AbstractSortedMapDecorator.java | 166 +++++
.../map/EntrySetToMapIteratorAdapter.java | 110 +++
.../iotdb/commons/file/SystemFileFactory.java | 2 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +-
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 2 +-
.../fa/dfa/transition/DFAWildcardTransition.java | 2 +-
.../service/PipePluginExecutableManager.java | 2 +-
.../datastructure/pattern/IoTDBTreePattern.java | 10 +-
.../datastructure/pattern/PrefixTreePattern.java | 4 +-
.../datastructure/pattern/SingleTreePattern.java} | 43 +-
.../pipe/datastructure/pattern/TreePattern.java | 185 +++--
.../pattern/UnionIoTDBTreePattern.java | 161 +++++
.../datastructure/pattern/UnionTreePattern.java | 95 +++
.../commons/pipe/receiver/IoTDBFileReceiver.java | 2 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 2 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 11 +-
.../viewExpression/leaf/ConstantViewOperand.java | 2 +-
.../unary/RegularViewExpression.java | 2 +-
.../meta/consumer/ConsumerGroupMeta.java | 3 +-
.../commons/udf/service/UDFExecutableManager.java | 2 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 23 +-
library-udf/pom.xml | 4 +
pom.xml | 52 +-
308 files changed, 4470 insertions(+), 997 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBFillTable2IT.java
=> IoTDBUnionTable2IT.java} (82%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/MappingCollectOperator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/BidiMap.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/IterableSortedMap.java}
(59%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/OrderedBidiMap.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/ResettableListIterator.java}
(58%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/SortedBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/AbstractDualBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/DualTreeBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/collection/AbstractCollectionDecorator.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/BasicSecurityContext.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractIteratorDecorator.java}
(50%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractUntypedIteratorDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/ListIteratorWrapper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/keyvalue/AbstractMapEntryDecorator.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractIterableMap.java}
(58%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractSortedMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/EntrySetToMapIteratorAdapter.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RemoveAINode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/SingleTreePattern.java}
(54%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/UnionIoTDBTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/UnionTreePattern.java
