You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2023/05/15 01:14:34 UTC
[iotdb] branch forward_schema_validate updated (7831122ed00 -> e6d0b9f8cdd)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch forward_schema_validate
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7831122ed00 merge latest master
add b48bc0a4858 [IOTDB-5858] fix the clear of metric in datanode schema cache
add d77c3994208 [IOTDB-5719] Cluster-Wide Time Series Limit Control (#9820)
add 1c2251394bf Use interface for MeasurementSchema and Move viewExpression to node commons (#9826)
add 467024bca30 [IOTDB-5865] Fix route balancing not trigger bug (#9793)
add 568aabe942e [IOTDB-5854] Pipe: Tsfile Resource Manager (#9805)
add 52324d4ec41 [IOTDB-5845] Pipe: Support handling leader change in PipeRuntimeCoordinator (#9777)
add 34fb7f532f6 [IOTDB-5799] Pipe: Support `SHOW PIPES` clause (#9838)
add 888fe13f13d build device timeIndex when validating files after compaction (#9831)
add af2d050b54b [IOTDB-5870] Pipe: Event reference management (#9836)
add 10d4eba1943 [IOTDB-5846] Optimize the memory estimate for HorizontallyConcatOperator (#9781)
add 0940f2a765f bump ratis version to 2.5.2-snapshot (#9839)
add e8f4897d741 [IOTDB-5872] Reduce some IoTConsensus index logs (#9844)
add 803c87fcdb0 [IOTDB-5873] Pipe: Support `CREATE`, `DROP`, `START`, `STOP` & `SHOW` Clauses (#9849)
add 1b1b95172f0 [IOTDB-5852] Add some IoTConsensus and RatisConsensus properties (#9797)
add e6d0b9f8cdd merge master branch and fix conflicts
No new revisions were added by this update.
Summary of changes:
.../heartbeat/DataNodeHeartbeatHandler.java | 25 ++-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 22 +++
.../confignode/conf/ConfigNodeDescriptor.java | 16 ++
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 4 +
.../request/read/pipe/task/ShowPipePlanV2.java | 25 +--
.../coordinator/PipeHandleLeaderChangePlan.java | 74 +++++++
.../response/pipe/task/PipeTableResp.java | 123 ++++++++++++
.../statemachine/ConfigRegionStateMachine.java | 1 +
.../iotdb/confignode/manager/ConfigManager.java | 16 +-
.../apache/iotdb/confignode/manager/IManager.java | 1 +
.../iotdb/confignode/manager/ProcedureManager.java | 22 +++
.../iotdb/confignode/manager/load/LoadManager.java | 2 +
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../confignode/manager/load/cache/LoadCache.java | 11 +-
.../manager/load/cache/route/RegionRouteCache.java | 4 +
.../manager/load/service/HeartbeatService.java | 4 +-
.../manager/load/service/StatisticsService.java | 9 +-
.../iotdb/confignode/manager/node/NodeManager.java | 5 +-
.../manager/partition/PartitionManager.java | 17 +-
.../manager/partition/PartitionMetrics.java | 2 +-
.../iotdb/confignode/manager/pipe/PipeManager.java | 7 +
.../manager/pipe/PipeRuntimeCoordinator.java | 82 ++++++++
.../manager/pipe/PipeTaskCoordinator.java | 32 ++-
.../manager/{ => schema}/ClusterSchemaManager.java | 22 ++-
.../schema/ClusterSchemaQuotaStatistics.java | 33 ++--
.../persistence/executor/ConfigPlanExecutor.java | 7 +
.../partition/DatabasePartitionTable.java | 6 +-
.../persistence/partition/PartitionInfo.java | 13 ++
.../persistence/pipe/PipePluginInfo.java | 49 ++++-
.../confignode/persistence/pipe/PipeTaskInfo.java | 56 ++++++
.../persistence/pipe/PipeTaskOperation.java | 1 +
.../procedure/env/ConfigNodeProcedureEnv.java | 9 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 196 ++++++++++++++++++
.../pipe/task/AbstractOperatePipeProcedureV2.java | 28 ++-
.../impl/pipe/task/CreatePipeProcedureV2.java | 27 +--
.../impl/pipe/task/DropPipeProcedureV2.java | 12 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 12 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 12 +-
.../impl/schema/DeleteDatabaseProcedure.java | 8 +-
.../procedure/store/ProcedureFactory.java | 14 ++
.../confignode/procedure/store/ProcedureType.java | 11 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 18 ++
.../manager/ClusterSchemaManagerTest.java | 2 +
.../PipeHandleLeaderChangeProcedureTest.java | 63 ++++++
consensus/pom.xml | 2 +-
.../consensus/iot/IoTConsensusServerImpl.java | 2 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 2 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 8 +-
.../iot/logdispatcher/SyncStatusTest.java | 10 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 56 ++++++
.../zh/UserGuide/Reference/Common-Config-Manual.md | 58 ++++++
.../iotdb/it/env/cluster/MppCommonConfig.java | 12 ++
.../it/env/cluster/MppSharedCommonConfig.java | 14 ++
.../iotdb/it/env/remote/RemoteCommonConfig.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +
.../db/it/schema/IoTDBClusterDeviceQuotaIT.java | 44 +++++
.../it/schema/IoTDBClusterMeasurementQuotaIT.java | 126 ++++++++++++
.../resources/conf/iotdb-common.properties | 36 ++++
.../apache/iotdb/commons/path/MeasurementPath.java | 31 +--
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 9 +-
.../commons/pipe/task/meta/PipeRuntimeMeta.java | 27 ++-
.../commons/pipe/task/meta/PipeStaticMeta.java | 88 +++++++--
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 59 ++++--
.../commons/schema/ClusterSchemaQuotaLevel.java | 16 +-
.../commons/schema/view}/LogicalViewSchema.java | 23 ++-
.../view/viewExpression/ViewExpression.java | 56 +++---
.../view/viewExpression/ViewExpressionType.java | 2 +-
.../binary/BinaryViewExpression.java | 6 +-
.../binary/arithmetic/AdditionViewExpression.java | 8 +-
.../arithmetic/ArithmeticBinaryViewExpression.java | 8 +-
.../binary/arithmetic/DivisionViewExpression.java | 8 +-
.../binary/arithmetic/ModuloViewExpression.java | 8 +-
.../arithmetic/MultiplicationViewExpression.java | 8 +-
.../arithmetic/SubtractionViewExpression.java | 8 +-
.../compare/CompareBinaryViewExpression.java | 8 +-
.../binary/compare/EqualToViewExpression.java | 8 +-
.../binary/compare/GreaterEqualViewExpression.java | 8 +-
.../binary/compare/GreaterThanViewExpression.java | 8 +-
.../binary/compare/LessEqualViewExpression.java | 8 +-
.../binary/compare/LessThanViewExpression.java | 8 +-
.../binary/compare/NonEqualViewExpression.java | 8 +-
.../binary/logic/LogicAndViewExpression.java | 8 +-
.../binary/logic/LogicBinaryViewExpression.java | 8 +-
.../binary/logic/LogicOrViewExpression.java | 8 +-
.../viewExpression/leaf/ConstantViewOperand.java | 6 +-
.../view/viewExpression/leaf/LeafViewOperand.java | 4 +-
.../view/viewExpression/leaf/NullViewOperand.java | 6 +-
.../viewExpression/leaf/TimeSeriesViewOperand.java | 6 +-
.../viewExpression/leaf/TimestampViewOperand.java | 6 +-
.../multi/FunctionViewExpression.java | 8 +-
.../ternary/BetweenViewExpression.java | 8 +-
.../ternary/TernaryViewExpression.java | 6 +-
.../viewExpression/unary/InViewExpression.java | 8 +-
.../viewExpression/unary/IsNullViewExpression.java | 8 +-
.../viewExpression/unary/LikeViewExpression.java | 8 +-
.../unary/LogicNotViewExpression.java | 8 +-
.../unary/NegationViewExpression.java | 8 +-
.../unary/RegularViewExpression.java | 8 +-
.../viewExpression/unary/UnaryViewExpression.java | 6 +-
.../visitor/ViewExpressionVisitor.java | 70 +++----
.../commons/pipe/task/meta/PipeMetaDeSerTest.java | 77 ++++++++
.../org/apache/iotdb/pipe/api/PipeCollector.java | 1 +
.../schemaregion/rocksdb/RSchemaRegion.java | 15 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 15 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 82 ++++++++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 62 +++++-
.../db/consensus/DataRegionConsensusImpl.java | 9 +
.../compaction/execute/utils/CompactionUtils.java | 22 +--
.../db/engine/storagegroup/TsFileResource.java | 5 +
.../metadata/SchemaQuotaExceededException.java} | 27 ++-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 14 +-
.../cache/DeviceUsingTemplateSchemaCache.java | 18 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 36 ++--
.../db/metadata/cache/TimeSeriesSchemaCache.java | 6 +-
.../metadata/mnode/mem/impl/LogicalViewMNode.java | 3 +-
.../metadata/mnode/mem/info/LogicalViewInfo.java | 12 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 21 ++
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 23 ++-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 2 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 3 +-
.../db/metadata/mtree/store/MemMTreeStore.java | 4 +
.../impl/SchemaRegionPlanDeserializer.java | 2 +-
.../impl/SchemaRegionPlanSerializer.java | 2 +-
.../impl/SchemaRegionPlanTxtSerializer.java | 2 +-
.../impl/write/CreateLogicalViewPlanImpl.java | 2 +-
.../schemaregion/result/ShowTimeSeriesResult.java | 3 +-
.../schemaregion/write/ICreateLogicalViewPlan.java | 2 +-
.../rescon/DataNodeSchemaQuotaManager.java | 92 +++++++++
.../db/metadata/schemaregion/ISchemaRegion.java | 16 +-
.../db/metadata/schemaregion/SchemaEngine.java | 92 +++++++--
.../schemaregion/SchemaRegionMemoryImpl.java | 83 +++-----
.../schemaregion/SchemaRegionSchemaFileImpl.java | 71 ++-----
.../visitor/GetSourcePathsVisitor.java | 13 +-
.../visitor/TransformToExpressionVisitor.java | 67 +++----
.../metadata/visitor/SchemaExecutionVisitor.java | 2 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 6 +-
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 18 +-
.../common/schematree/IMeasurementSchemaInfo.java | 8 +-
.../common/schematree/MeasurementSchemaInfo.java | 22 ++-
.../schematree/node/SchemaMeasurementNode.java | 42 +++-
.../execution/executor/RegionWriteExecutor.java | 84 +++++++-
.../process/join/HorizontallyConcatOperator.java | 8 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 4 +
.../analyze/schema/ClusterSchemaFetchExecutor.java | 5 +-
.../config/executor/ClusterConfigTaskExecutor.java | 5 +-
.../visitor/TransformToViewExpressionVisitor.java | 52 ++---
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 12 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 2 +-
.../node/metedata/write/CreateLogicalViewNode.java | 2 +-
.../write/InternalCreateMultiTimeSeriesNode.java | 1 +
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 5 +
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 214 ++++++++++++++++++++
.../db/pipe/config/PipeCollectorConstant.java | 5 +-
.../apache/iotdb/db/pipe/config/PipeConfig.java | 6 +
.../realtime/PipeRealtimeDataRegionCollector.java | 6 +-
.../PipeRealtimeDataRegionHybridCollector.java | 31 ++-
.../realtime/assigner/PipeDataRegionAssigner.java | 20 +-
.../matcher/CachedSchemaPatternMatcher.java | 6 +-
.../realtime/matcher/PipeDataRegionMatcher.java | 9 +-
.../connector/PipeConnectorSubtaskManager.java | 23 ++-
.../iotdb/db/pipe/core/event/EnrichedEvent.java | 54 +++++
.../core/event/impl/PipeTabletInsertionEvent.java | 27 ++-
.../core/event/impl/PipeTsFileInsertionEvent.java | 48 ++++-
.../event/realtime/PipeRealtimeCollectEvent.java | 20 +-
.../realtime/PipeRealtimeCollectEventFactory.java | 2 -
.../event/view/collector/PipeEventCollector.java | 6 +
.../db/pipe/resource/PipeFileResourceManager.java | 186 ++++++++++++++++++
.../db/pipe/resource/PipeResourceManager.java | 16 +-
.../iotdb/db/pipe/resource/PipeTsFileHolder.java | 22 ---
.../iotdb/db/pipe/resource/PipeWALHolder.java | 22 ---
.../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 2 +-
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 25 ++-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 44 +++--
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 26 ++-
.../db/pipe/task/subtask/PipeProcessorSubtask.java | 32 +--
.../impl/DataNodeInternalRPCServiceImpl.java | 17 +-
.../engine/compaction/AbstractCompactionTest.java | 3 +-
.../FastCrossCompactionPerformerTest.java | 5 +
...eCompactionWithFastPerformerValidationTest.java | 16 +-
.../metadata/view/ViewExpressionToStringTest.java | 16 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 34 ++++
.../schema/SchemaFetchScanOperatorTest.java | 3 +-
.../collector/CachedSchemaPatternMatcherTest.java | 12 +-
.../core/collector/PipeRealtimeCollectTest.java | 53 +++--
.../pipe/resource/PipeFileResourceManagerTest.java | 218 +++++++++++++++++++++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../src/main/thrift/confignode.thrift | 5 +-
thrift/src/main/thrift/datanode.thrift | 18 +-
.../tsfile/write/schema/IMeasurementSchema.java | 4 +
.../tsfile/write/schema/MeasurementSchema.java | 10 +
.../tsfile/write/schema/MeasurementSchemaType.java | 20 +-
.../write/schema/VectorMeasurementSchema.java | 10 +
195 files changed, 3739 insertions(+), 860 deletions(-)
copy server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/LeafViewOperand.java => confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/pipe/task/ShowPipePlanV2.java (57%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/coordinator/PipeHandleLeaderChangePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/PipeRuntimeCoordinator.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ => schema}/ClusterSchemaManager.java (97%)
copy server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeResourceManager.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaQuotaStatistics.java (52%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedureTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBClusterDeviceQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBClusterMeasurementQuotaIT.java
rename server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeRaftlogHolder.java => node-commons/src/main/java/org/apache/iotdb/commons/schema/ClusterSchemaQuotaLevel.java (76%)
rename {server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/impl => node-commons/src/main/java/org/apache/iotdb/commons/schema/view}/LogicalViewSchema.java (91%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/ViewExpression.java (77%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/ViewExpressionType.java (97%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/BinaryViewExpression.java (93%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/arithmetic/AdditionViewExpression.java (84%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/arithmetic/ArithmeticBinaryViewExpression.java (82%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/arithmetic/DivisionViewExpression.java (84%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/arithmetic/ModuloViewExpression.java (84%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/arithmetic/MultiplicationViewExpression.java (84%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/arithmetic/SubtractionViewExpression.java (84%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/compare/CompareBinaryViewExpression.java (82%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/compare/EqualToViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/compare/GreaterEqualViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/compare/GreaterThanViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/compare/LessEqualViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/compare/LessThanViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/compare/NonEqualViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/logic/LogicAndViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/logic/LogicBinaryViewExpression.java (82%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/binary/logic/LogicOrViewExpression.java (83%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/leaf/ConstantViewOperand.java (92%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/leaf/LeafViewOperand.java (89%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/leaf/NullViewOperand.java (87%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/leaf/TimeSeriesViewOperand.java (90%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/leaf/TimestampViewOperand.java (88%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/multi/FunctionViewExpression.java (95%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/ternary/BetweenViewExpression.java (91%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/ternary/TernaryViewExpression.java (93%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/unary/InViewExpression.java (90%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/unary/IsNullViewExpression.java (88%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/unary/LikeViewExpression.java (94%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/unary/LogicNotViewExpression.java (85%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/unary/NegationViewExpression.java (85%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/unary/RegularViewExpression.java (90%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/unary/UnaryViewExpression.java (89%)
rename {server/src/main/java/org/apache/iotdb/db/metadata => node-commons/src/main/java/org/apache/iotdb/commons/schema}/view/viewExpression/visitor/ViewExpressionVisitor.java (68%)
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/pipe/task/meta/PipeMetaDeSerTest.java
copy server/src/main/java/org/apache/iotdb/db/{pipe/agent/runtime/PipeRuntimeAgent.java => exception/metadata/SchemaQuotaExceededException.java} (52%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/DataNodeSchemaQuotaManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/EnrichedEvent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeFileResourceManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeTsFileHolder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeWALHolder.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/pipe/resource/PipeFileResourceManagerTest.java
rename server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeFileManager.java => tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/MeasurementSchemaType.java (69%)