This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch multi_dir_change_to_seq
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard bd1de75af8 suggest to use 0.05 ratio to judgement
discard d855934599 change multi_dir default strategy to SequenceStrategy
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 29e7e1a851 [IOTDB-5662] Fix BufferedUnderflowException occurs in inner
space compaction (#9322)
add 04a074b4ac [IOTDB-5841] Remove duplicate schema template IT (#9693)
add e1103a96d6 [IOTDB-5183] Use default snapshot installation path for
confignode & schema region
add 7d4fdc781f [IOTDB-5812] Reduce useless create of PartialPath in auth
module (#9691)
add 809431fd7e Bump yaml from 2.2.1 to 2.2.2 in /site/src/main (#9705)
add b6f78dcee2 Support update last cache for data insertion when using
template (#9696)
add 8d7ca050cc [IOTDB-5807]Fix decompression error for aligned series in
fast compaction (#9701)
add 86be5ea16a [IOTDB-5803] Improve query performance by reducing cpu
consuming
add c7a6184c01 [IOTDB-5819] Fix npe when booting net metrics (#9698)
add f77f3fd572 [IOTDB-5704] Change default parameters for wal part (#9394)
new 805979f100 change multi_dir default strategy to SequenceStrategy
new e716c4be1a suggest to use 0.05 ratio to judgement
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (bd1de75af8)
\
N -- N -- N refs/heads/multi_dir_change_to_seq (e716c4be1a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 33 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +-
.../consensus/request/ConfigPhysicalPlan.java | 10 +-
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
.../consensus/request/auth/AuthorPlan.java | 29 +-
...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/ClusterSchemaManager.java | 88 +-
.../iotdb/confignode/manager/ConfigManager.java | 44 +-
.../apache/iotdb/confignode/manager/IManager.java | 40 +-
.../confignode/manager/PermissionManager.java | 3 +-
.../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 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 34 +-
.../persistence/executor/ConfigPlanExecutor.java | 6 +
.../partition/DatabasePartitionTable.java | 23 +-
.../persistence/partition/PartitionInfo.java | 128 +-
.../persistence/pipe/PipePluginInfo.java | 37 +-
.../persistence/schema/ClusterSchemaInfo.java | 12 +
.../persistence/schema/TemplateTable.java | 47 +
.../impl/pipe/plugin/DropPipePluginProcedure.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 64 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 27 +-
.../confignode/persistence/AuthorInfoTest.java | 30 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedureTest.java | 2 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 8 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 176 +-
docs/UserGuide/Operate-Metadata/Template.md | 15 +-
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 +
grafana-plugin/README.md | 63 +-
grafana-plugin/src/plugin.json | 2 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 1 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 88 +-
.../it/partition/IoTDBPartitionGetterIT.java | 96 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 59 +-
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 1 +
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 1 +
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 1 +
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 1 +
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 1 +
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 1 +
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 1 +
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 1 +
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 223 ++
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 1 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 70 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 1 +
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 1 +
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 1 +
.../session/it/IoTDBSessionSchemaTemplateIT.java | 75 +-
.../{db/it/schema => util}/AbstractSchemaIT.java | 4 +-
.../iotdb/metrics/metricsets/net/NetMetrics.java | 10 +-
.../resources/conf/iotdb-common.properties | 19 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 35 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 33 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 3 +-
.../iotdb/commons/auth/entity/PathPrivilege.java | 29 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 13 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 13 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 5 +-
.../iotdb/commons/auth/role/IRoleManager.java | 6 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 5 +-
.../iotdb/commons/auth/user/IUserManager.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 10 +
.../iotdb/commons/conf/CommonDescriptor.java | 8 +
.../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/commons/utils/AuthUtils.java | 96 +-
.../org/apache/iotdb/commons/utils/IOUtils.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 10 +-
.../apache/iotdb/db/auth/AuthorizerManager.java | 15 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 38 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 3 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 44 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 14 +-
.../performer/impl/FastCompactionPerformer.java | 11 +-
.../impl/ReadPointCompactionPerformer.java | 3 +
.../execute/utils/MultiTsFileDeviceIterator.java | 4 +-
.../fast/AlignedSeriesCompactionExecutor.java | 3 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 38 +-
.../utils/writer/AbstractCompactionWriter.java | 7 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 65 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 225 +-
.../cache/DataNodeTemplateSchemaCache.java | 95 -
.../cache/DeviceUsingTemplateSchemaCache.java | 177 ++
...SchemaCache.java => TimeSeriesSchemaCache.java} | 101 +-
.../metadata/cache/dualkeycache/IDualKeyCache.java | 4 +
.../dualkeycache/impl/CacheEntryGroupImpl.java | 2 +-
.../cache/dualkeycache/impl/DualKeyCacheImpl.java | 102 +-
.../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 ++
.../org/apache/iotdb/db/mpp/common/QueryId.java | 2 +-
.../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 +-
.../execution/exchange/source/SourceHandle.java | 25 +-
.../execution/operator/source/SeriesScanUtil.java | 24 +-
.../mpp/execution/schedule/DriverTaskThread.java | 7 +-
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 140 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 72 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 11 +-
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 3 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 10 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 254 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 299 +-
.../db/mpp/plan/analyze/schema/ISchemaFetcher.java | 2 -
.../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 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 113 +-
.../db/mpp/plan/parser/StatementGenerator.java | 20 +-
.../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/PipeConnectorSubtask.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/query/context/QueryContext.java | 2 +
.../query/control/clientsession/ClientSession.java | 3 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 12 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +
.../impl/DataNodeInternalRPCServiceImpl.java | 25 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 26 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 9 +-
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 8 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 8 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 8 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 6 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 8 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 6 +-
.../db/auth/user/LocalFileUserManagerTest.java | 8 +-
.../engine/compaction/AbstractCompactionTest.java | 3 +
.../compaction/FastAlignedCrossCompactionTest.java | 751 +++--
.../FastNonAlignedCrossCompactionTest.java | 767 ++++--
.../compaction/ReadChunkInnerCompactionTest.java | 377 +++
...va => ReadPointAlignedCrossCompactionTest.java} | 804 ++++--
...=> ReadPointNonAlignedCrossCompactionTest.java} | 820 ++++--
.../ReadChunkCompactionPerformerNoAlignedTest.java | 274 ++
.../utils/CompactionFileGeneratorUtils.java | 60 +
.../compaction/utils/TsFileGeneratorUtils.java | 116 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 50 +
.../db/mpp/execution/QueryStateMachineTest.java | 2 +
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 3 -
.../mpp/plan/analyze/QueryTimePartitionTest.java | 14 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 3 -
.../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 +-
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 36 +-
.../series/SeriesScanLimitOffsetPushDownTest.java | 23 +-
.../security/encrypt/MessageDigestEncryptTest.java | 6 +-
site/src/main/.vuepress/styles/index.scss | 6 +-
site/src/main/package-lock.json | 2881 +++++++-------------
.../src/main/thrift/confignode.thrift | 47 +-
thrift/src/main/thrift/client.thrift | 3 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../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 +-
.../read/reader/chunk/AlignedChunkReader.java | 40 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 4 +
.../iotdb/tsfile/read/reader/page/PageReader.java | 12 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 42 +-
.../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 +-
269 files changed, 10834 insertions(+), 5454 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/schema/IoTDBExtendTemplateIT.java
rename integration-test/src/test/java/org/apache/iotdb/{db/it/schema =>
util}/AbstractSchemaIT.java (98%)
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
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeTemplateSchemaCache.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} (79%)
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/PipeProcessorSubtask.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/PipeConnectorSubtask.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/engine/compaction/ReadChunkInnerCompactionTest.java
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/{FastAlignedCrossCompactionTest.java
=> ReadPointAlignedCrossCompactionTest.java} (86%)
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/{FastNonAlignedCrossCompactionTest.java
=> ReadPointNonAlignedCrossCompactionTest.java} (85%)
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
