You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2023/04/25 02:53:42 UTC
[iotdb] branch beyyes/imporve_query updated (5d82fc4167 -> 65df0efa3d)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/imporve_query
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5d82fc4167 add QUERY_METRICS_ENABLE configuration
add f13699611f [IOTDB-5798] Fix concurrent problem when sinkChannel acknowledgeTsBlock() and close()
add 98adb10391 [IOTDB-5773] fix set space quota problem (#9596)
add 348763f208 Add a cache to avoid initialize duplicated device id object in write process (#9644)
add 9870f332d6 Resolve quadratic complexity issue when flushing numerous Internal/Entity nodes in SchemaFile (#9659)
add 3405c49177 Accelerate count all schema via schema statistic (#9660)
add bc9ee590ed [IOTDB-5720] Fix release processor fail to release memory due to writer-preferred starvation (#9661)
add c19bcdc5f1 Double-check protect memory-control boundary to avoid concurrent bug (#9662)
add 4a822f2da1 TemplateSchemaCache in schema fetcher (#9664)
add e15a3c770b [IOTDB-5774] Fix the syntax that path nodes start or end with a wildcard to fuzzy match is not supported (#9600)
add 2893e362cf [To master] Change the documentation about OpenID login (#9668)
add 06ee7cca94 [IOTDB-3565] Support Dynamic Schema Template (#9663)
add 9b194dcac6 [IOTDB-5784] Incorrect result when querying with offset push-down and time filter
add 50e419f132 feat(site): fix display error for docs has table (#9669)
add 3bf31903e4 [IOTDB-3565] Update User-Guide for Dynamic Template (#9672)
add 73fbcd1b2e [grafana plugin] update grafanaDependency (>= 9.3.0) in plugin.json (#9678)
add 3412975a4a Fix NPE when using template and executing select into (#9679)
add e3e83fe8aa [IOTDB-5788] Built-in pipe plug-in management mechanism (#9680)
add 8b52e79bb3 [IOTDB-5791] Construct Cluster-LoadPublisher-Thread and IClusterStatusSubscriber (#9645)
add 22b04f1bc8 Remove check of closed state in ISink
add 6767a142ca Update Programming-Go-Native-API.md (#9688)
add 6a8d009a72 Remove unecessary synchronized on decrementCnt of SinkListener
add d92ea6e77c [IOTDB-5567] improve show cluster slots information (#9665)
add e8bf6ef1a8 [IOTDB-5810] Result handle in memory pool is not be cleaned properly (#9685)
add 104a8bf26f Fix concurrent state change bug in QueryStateMachine
add 969995276b Combine DataNodeSchemaCache of Template and Non-Template Scenarios (#9687)
add ce843c2c06 [IOTDB-5779] PipeConnector reuse strategy based on reference count mechanism (#9629)
add 4020214423 [IoTDB-5721] Streaming query DataPartition and Schema while loading TsFile (#9684)
add 6554807936 Merge branch 'master' of github.com:apache/iotdb
add de4dcfe2d2 Merge branch 'master' into beyyes/imporve_query
add 65df0efa3d comment querymetric and using DO_NOTHING level
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 43 +-
.../org/apache/iotdb/db/qp/sql/PathParser.g4 | 14 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +-
.../consensus/request/ConfigPhysicalPlan.java | 10 +-
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
...lotListPlan.java => CountTimeSlotListPlan.java} | 52 +-
.../read/partition/GetSeriesSlotListPlan.java | 18 +-
.../read/partition/GetTimeSlotListPlan.java | 44 +-
.../request/read/region/GetRegionIdPlan.java | 46 +-
.../write/template/ExtendSchemaTemplatePlan.java | 58 +++
...egionIdResp.java => CountTimeSlotListResp.java} | 19 +-
.../response/partition/GetRegionIdResp.java | 2 +-
.../response/partition/GetSeriesSlotListResp.java | 2 +-
.../response/partition/GetTimeSlotListResp.java | 2 +-
.../confignode/manager/ClusterQuotaManager.java | 18 +-
.../confignode/manager/ClusterSchemaManager.java | 88 +++-
.../iotdb/confignode/manager/ConfigManager.java | 42 +-
.../apache/iotdb/confignode/manager/IManager.java | 38 +-
.../manager/consensus/ConsensusManager.java | 12 +-
.../iotdb/confignode/manager/load/LoadManager.java | 8 +-
.../manager/load/balancer/RouteBalancer.java | 21 +-
.../load/balancer/router/RegionRouteMap.java | 5 +
.../confignode/manager/load/cache/LoadCache.java | 15 +-
.../load/cache/region/RegionGroupCache.java | 4 +
.../manager/load/service/StatisticsService.java | 115 +++--
.../load/subscriber/IClusterStatusSubscriber.java | 19 +-
.../manager/load/subscriber/RouteChangeEvent.java | 74 +++
.../subscriber/StatisticsChangeEvent.java} | 26 +-
.../iotdb/confignode/manager/observer/IEvent.java | 21 -
.../manager/partition/PartitionManager.java | 60 ++-
.../manager/pipe/PipePluginCoordinator.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 6 +
.../partition/DatabasePartitionTable.java | 23 +-
.../persistence/partition/PartitionInfo.java | 128 ++++-
.../persistence/pipe/PipePluginInfo.java | 37 +-
.../confignode/persistence/quota/QuotaInfo.java | 36 +-
.../persistence/schema/ClusterSchemaInfo.java | 12 +
.../persistence/schema/TemplateTable.java | 47 ++
.../impl/pipe/plugin/DropPipePluginProcedure.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 54 ++-
.../request/ConfigPhysicalPlanSerDeTest.java | 19 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedureTest.java | 2 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 176 +++++--
docs/UserGuide/Operate-Metadata/Template.md | 15 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 49 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 11 +-
docs/zh/UserGuide/API/Programming-Go-Native-API.md | 1 +
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 177 +++++--
docs/zh/UserGuide/Operate-Metadata/Template.md | 14 +
.../UserGuide/QuickStart/Command-Line-Interface.md | 48 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 9 +
grafana-plugin/README.md | 63 +--
grafana-plugin/src/plugin.json | 2 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 1 +
.../iotdb/it/env/cluster/MppCommonConfig.java | 6 +
.../it/env/cluster/MppSharedCommonConfig.java | 7 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 5 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../it/partition/IoTDBPartitionGetterIT.java | 96 ++--
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 40 ++
.../iotdb/db/it/query/IoTDBPaginationIT.java | 59 ++-
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 535 +++++++++++++++++++++
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 222 +++++++++
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 69 ++-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 103 ++++
.../resources/conf/iotdb-common.properties | 13 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 10 +
.../iotdb/commons/conf/CommonDescriptor.java | 8 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 32 +-
.../commons/partition/DataPartitionTable.java | 45 +-
.../commons/partition/SchemaPartitionTable.java | 10 +
.../commons/partition/SeriesPartitionTable.java | 32 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 55 +++
.../builtin/connector/DoNothingConnector.java | 72 +++
.../builtin/processor/DoNothingProcessor.java | 68 +++
.../meta/ConfigNodePipePluginMetaKeeper.java | 25 +-
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 28 +-
.../commons/pipe/plugin/meta/PipePluginMeta.java | 65 ++-
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 62 ++-
.../commons/pipe/task/meta/PipeStaticMeta.java | 24 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 44 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 29 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +-
.../template/TemplateImcompatibeException.java | 5 +
.../db/metadata/cache/DataNodeDevicePathCache.java | 69 +++
.../db/metadata/cache/DataNodeSchemaCache.java | 205 +++-----
.../cache/DeviceUsingTemplateSchemaCache.java | 177 +++++++
...SchemaCache.java => TimeSeriesSchemaCache.java} | 46 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 4 +-
.../store/disk/schemafile/SchemaFileConfig.java | 2 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 1 +
.../store/disk/schemafile/pagemgr/PageManager.java | 90 +++-
.../metadata/rescon/MemSchemaEngineStatistics.java | 26 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 15 +-
.../metadata/template/ClusterTemplateManager.java | 11 +
.../iotdb/db/metadata/template/Template.java | 16 +-
...teType.java => TemplateAlterOperationType.java} | 21 +-
.../template/TemplateInternalRPCUpdateType.java | 5 +-
.../metadata/template/TemplateInternalRPCUtil.java | 10 +
.../template/alter/TemplateAlterInfo.java} | 26 +-
.../template/alter/TemplateAlterOperationUtil.java | 51 ++
.../template/alter/TemplateExtendInfo.java | 161 +++++++
.../db/mpp/common/header/ColumnHeaderConstant.java | 13 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 78 ++-
.../execution/exchange/MPPDataExchangeManager.java | 8 +-
.../execution/exchange/sink/LocalSinkChannel.java | 7 +
.../execution/exchange/sink/ShuffleSinkHandle.java | 7 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 23 +-
.../execution/exchange/source/SourceHandle.java | 25 +-
.../operator/schema/SchemaCountOperator.java | 23 +-
.../operator/schema/source/DeviceSchemaSource.java | 12 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../operator/schema/source/NodeSchemaSource.java | 10 +
.../schema/source/PathsUsingTemplateSource.java | 10 +
.../schema/source/TimeSeriesSchemaSource.java | 12 +
.../execution/operator/source/SeriesScanUtil.java | 24 +-
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 132 ++---
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 72 ++-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 11 +-
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 3 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 254 ++++++++--
.../plan/analyze/schema/ClusterSchemaFetcher.java | 177 ++-----
.../plan/analyze/schema/NormalSchemaFetcher.java | 203 ++++++++
.../plan/analyze/schema/TemplateSchemaFetcher.java | 246 ++++++++++
.../db/mpp/plan/execution/QueryExecution.java | 27 +-
.../plan/execution/config/ConfigTaskVisitor.java | 15 +
.../config/executor/ClusterConfigTaskExecutor.java | 120 ++++-
.../config/executor/IConfigTaskExecutor.java | 8 +
...lotListTask.java => CountTimeSlotListTask.java} | 38 +-
.../config/metadata/GetTimeSlotListTask.java | 9 +-
.../config/metadata/ShowPipePluginsTask.java | 18 +-
.../metadata/template/AlterSchemaTemplateTask.java | 45 ++
.../config/sys/quota/ShowSpaceQuotaTask.java | 7 +-
.../config/sys/quota/ShowThrottleQuotaTask.java | 34 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 201 +++++---
.../db/mpp/plan/parser/StatementGenerator.java | 25 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 8 +
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 12 +-
.../plan/node/load/LoadSingleTsFileNode.java | 59 +--
.../planner/plan/node/load/LoadTsFileNode.java | 16 +-
.../source/AlignedSeriesAggregationScanNode.java | 50 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +
.../node/source/SeriesAggregationScanNode.java | 50 +-
.../node/source/SeriesAggregationSourceNode.java | 49 +-
.../planner/plan/node/source/SeriesScanNode.java | 4 +
.../planner/plan/parameter/SeriesScanOptions.java | 5 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 20 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 201 ++++++--
.../iotdb/db/mpp/plan/statement/StatementType.java | 1 +
.../db/mpp/plan/statement/StatementVisitor.java | 12 +
...tement.java => CountTimeSlotListStatement.java} | 59 ++-
.../statement/metadata/GetRegionIdStatement.java | 54 +--
.../metadata/GetSeriesSlotListStatement.java | 20 +-
.../metadata/GetTimeSlotListStatement.java | 46 +-
.../template/AlterSchemaTemplateStatement.java | 85 ++++
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 9 +-
.../db/pipe/agent/plugin/PipePluginAgent.java | 67 ++-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 17 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 19 +-
.../db/pipe/agent/task/PipeTaskRegionAgent.java | 22 -
.../core/connector/PipeConnectorContainer.java | 22 -
.../pipe/core/connector/PipeConnectorManager.java | 22 -
.../connector/PipeConnectorSubtaskLifeCycle.java | 98 ++++
.../connector/PipeConnectorSubtaskManager.java | 107 +++++
.../execution/executor/PipeSubtaskExecutor.java | 12 +-
.../pipe/task/callable/PipeProcessorSubtask.java | 37 --
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 41 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 109 ++++-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 38 +-
.../iotdb/db/pipe/task/stage/PipeTaskStage.java | 34 +-
.../task/{callable => subtask}/DecoratingLock.java | 2 +-
.../{callable => subtask}/PipeAssignerSubtask.java | 7 +-
.../subtask/PipeConnectorSubtask.java} | 44 +-
.../subtask/PipeProcessorSubtask.java} | 38 +-
.../task/{callable => subtask}/PipeSubtask.java | 8 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +-
.../v1/handler/StatementConstructionHandler.java | 5 +-
.../v2/handler/StatementConstructionHandler.java | 5 +-
.../iotdb/db/query/context/QueryContext.java | 2 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 12 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +
.../impl/DataNodeInternalRPCServiceImpl.java | 14 +-
.../cache/DataNodeDevicePathCacheTest.java | 62 +++
.../metadata/mtree/schemafile/SchemaFileTest.java | 137 ++++--
.../db/mpp/execution/QueryStateMachineTest.java | 2 +
.../mpp/plan/analyze/QueryTimePartitionTest.java | 14 +-
.../node/process/AggregationNodeSerdeTest.java | 7 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 8 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 5 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 7 +-
.../executor/PipeAssignerSubtaskExecutorTest.java | 2 +-
.../executor/PipeConnectorSubtaskExecutorTest.java | 6 +-
.../executor/PipeProcessorSubtaskExecutorTest.java | 12 +-
.../executor/PipeSubtaskExecutorTest.java | 2 +-
site/src/main/.vuepress/styles/index.scss | 6 +-
.../src/main/thrift/confignode.thrift | 43 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 13 +-
.../read/filter/PredicateRemoveNotRewriter.java | 50 ++
.../iotdb/tsfile/read/filter/TimeFilter.java | 158 +++---
.../iotdb/tsfile/read/filter/ValueFilter.java | 179 ++++---
.../tsfile/read/filter/basic/BinaryFilter.java | 5 -
.../iotdb/tsfile/read/filter/basic/Filter.java | 11 +-
.../tsfile/read/filter/factory/FilterFactory.java | 10 +-
.../tsfile/read/filter/operator/AndFilter.java | 11 +
.../iotdb/tsfile/read/filter/operator/Between.java | 127 +++--
.../iotdb/tsfile/read/filter/operator/Eq.java | 25 +-
.../iotdb/tsfile/read/filter/operator/Gt.java | 23 +-
.../iotdb/tsfile/read/filter/operator/GtEq.java | 23 +-
.../iotdb/tsfile/read/filter/operator/In.java | 34 +-
.../iotdb/tsfile/read/filter/operator/Like.java | 55 ++-
.../iotdb/tsfile/read/filter/operator/Lt.java | 23 +-
.../iotdb/tsfile/read/filter/operator/LtEq.java | 23 +-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 25 +-
.../tsfile/read/filter/operator/NotFilter.java | 26 +-
.../tsfile/read/filter/operator/OrFilter.java | 11 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 57 ++-
.../iotdb/tsfile/read/reader/page/PageReader.java | 12 +-
.../tsfile/read/filter/FilterSerializeTest.java | 21 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 42 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 4 +-
.../filter/PredicateRemoveNotRewriterTest.java | 121 +++++
.../tsfile/read/filter/StatisticsFilterTest.java | 113 ++++-
225 files changed, 7159 insertions(+), 2372 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/{GetTimeSlotListPlan.java => CountTimeSlotListPlan.java} (66%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/ExtendSchemaTemplatePlan.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/{GetRegionIdResp.java => CountTimeSlotListResp.java} (71%)
copy server/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskCollectorStage.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/IClusterStatusSubscriber.java (66%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/RouteChangeEvent.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{observer/NodeStatisticsEvent.java => load/subscriber/StatisticsChangeEvent.java} (51%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/IEvent.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBExtendTemplateIT.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/BuiltinPipePlugin.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/DoNothingConnector.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/DoNothingProcessor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DeviceUsingTemplateSchemaCache.java
copy server/src/main/java/org/apache/iotdb/db/metadata/cache/{DataNodeSchemaCache.java => TimeSeriesSchemaCache.java} (86%)
copy server/src/main/java/org/apache/iotdb/db/metadata/template/{TemplateInternalRPCUpdateType.java => TemplateAlterOperationType.java} (71%)
rename server/src/main/java/org/apache/iotdb/db/{pipe/task/callable/PipeConnectorSubtask.java => metadata/template/alter/TemplateAlterInfo.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/alter/TemplateAlterOperationUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/alter/TemplateExtendInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/NormalSchemaFetcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/TemplateSchemaFetcher.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{GetTimeSlotListTask.java => CountTimeSlotListTask.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/AlterSchemaTemplateTask.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{GetTimeSlotListStatement.java => CountTimeSlotListStatement.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/AlterSchemaTemplateStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskRegionAgent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorContainer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorSubtaskLifeCycle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorSubtaskManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/callable/PipeProcessorSubtask.java
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{callable => subtask}/DecoratingLock.java (96%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{callable => subtask}/PipeAssignerSubtask.java (91%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/PipeConnectorPluginRuntimeWrapper.java => task/subtask/PipeConnectorSubtask.java} (64%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/processor/PipeProcessorPluginRuntimeWrapper.java => task/subtask/PipeProcessorSubtask.java} (71%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{callable => subtask}/PipeSubtask.java (95%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCacheTest.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriter.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriterTest.java