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/10 04:24:16 UTC
[iotdb] branch forward_schema_validate updated (b84a3054b8 -> c4711c95e7)
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 b84a3054b8 Merge branch 'master' of https://github.com/apache/iotdb into forward_schema_validate
add c98016f996 [IOTDB-5840] Enhance the problem that the insertRecords interface may cause the number of threads to balloon when there are too many data regions (#9768)
add 2ac9b5197c Add config min_cross_compaction_unseq_file_level for cross compaction (#9766)
add ee4df02d5b [IOTDB-5842] Sync: Delete BufferedPipeDataQueueTest (#9774)
add 478e4d1795 [IOTDB-5839] Pipe task management (CN -> DN): squash all operation rpcs into one (#9750)
add 10b8be2c66 [IOTDB-5765] Support Order By Expression [BE Part] (#9746)
add b754b03ea0 [IOTDB-5787] PipeTaskAgent: Pipe task management on data nodes (#9782)
add aaf7fa2804 [IOTDB-5811] Pipe: PipeHistoricalCollector (#9700)
add 6118e6cec6 [IOTDB-5837] Fix exception in select-into of ALIGN BY DEVICE query
add b5d13d1876 Delete abandoned API in document (#9773)
add 109b15434c Use two params to distinguish fsync delay in the wal sync mode and async mode (#9707)
add 6160095863 [IOTDB-5841] Modify IoTConsensus default parameters to improve performance in more scenarios (#9771)
add e39060e1d1 update ratis version to 2.5.1 (#9785)
add 299f33c80c [IOTDB-5821] Pipe: PipeCollector Stage (#9789)
add db8849fce1 [IOTDB-5740] Fix drop database does not delete its template (#9792)
add f579e3ca0d Support Create and Query Schema of Logical View (#9742)
add 3b44a55bb2 [Doc] Fix error path of Dockerfile (#9725)
add 16011faf94 [To rel/1.1] [IOTDB-5844] Fix compaction module getting stuck (#9776) (#9790)
add dde59e204e Refactor SchemaIT for Acceleration (#9794)
add 5c20ee49d3 [IOTDB-5831] Fix create region failure after recreate db (#9800)
add f3e7ce2286 [IOTDB-5818][Atmos][Compaction]Cross_space compaction of Aligned timeseries is stucked (#9795)
add c84a66e669 [IOTDB-5827] Fix the description for dn_multi_dir_strategy in iotdb-datanode.properties and update corresponding user manual (#9804)
add 9044d55640 Merge branch 'master' of https://github.com/apache/iotdb into forward_schema_validate
add c4711c95e7 add annotation
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 22 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
client-py/tests/test_dataframe.py | 2 +
.../confignode/client/DataNodeRequestType.java | 7 +-
.../client/async/AsyncDataNodeClientPool.java | 15 +-
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../confignode/manager/ClusterSchemaManager.java | 13 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 32 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 23 +-
.../pipe/task/AbstractOperatePipeProcedureV2.java | 50 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 34 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 16 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 28 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 28 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 1 +
consensus/pom.xml | 2 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 36 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 8 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 22 +
.../consensus/iot/logdispatcher/SyncStatus.java | 2 -
docs/UserGuide/API/Programming-Java-Native-API.md | 98 ---
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 29 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 6 +-
.../UserGuide/API/Programming-Java-Native-API.md | 93 ---
.../zh/UserGuide/Reference/Common-Config-Manual.md | 29 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 6 +-
.../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 +
.../iotdb/db/it/orderBy/IoTDBOrderBy2IT.java | 48 ++
.../apache/iotdb/db/it/orderBy/IoTDBOrderByIT.java | 6 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 2 +
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 17 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 17 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 18 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 17 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 26 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 18 +-
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 17 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 18 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 49 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 63 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 49 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 20 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 17 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 17 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 30 +
.../org/apache/iotdb/util/AbstractSchemaIT.java | 48 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 14 +-
.../resources/conf/iotdb-common.properties | 23 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 8 +-
.../plugin/builtin/collector/DefaultCollector.java | 60 ++
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 10 +-
.../commons/pipe/task/meta/PipeMetaKeeper.java | 4 +
.../commons/pipe/task/meta/PipeRuntimeMeta.java | 20 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 83 ++-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 51 +-
.../node/common/AbstractMeasurementMNode.java | 4 +
.../schema/node/role/IMeasurementMNode.java | 2 +
.../commons/schema/node/utils/IMNodeFactory.java | 4 +
.../iotdb/pipe/api/customizer/PipeParameters.java | 22 +
.../exception/PipeRuntimeCriticalException.java | 23 +-
.../pipe/api/exception/PipeRuntimeException.java | 23 +-
.../exception/PipeRuntimeNonCriticalException.java | 23 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 7 +
.../rocksdb/mnode/RMeasurementMNode.java | 5 +
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 7 +
.../resources/conf/iotdb-datanode.properties | 15 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 63 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 41 +-
.../CompactionMemoryNotEnoughException.java} | 11 +-
.../execute/task/CrossSpaceCompactionTask.java | 6 +-
.../estimator/AbstractCompactionEstimator.java | 3 +-
.../ReadPointCrossCompactionEstimator.java | 6 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 6 +
.../mnode/config/factory/ConfigMNodeFactory.java | 7 +
.../mnode/mem/factory/MemMNodeFactory.java | 14 +
...MeasurementMNode.java => LogicalViewMNode.java} | 30 +-
.../metadata/mnode/mem/impl/LogicalViewSchema.java | 215 +++++++
.../metadata/mnode/mem/impl/MeasurementMNode.java | 5 +
.../metadata/mnode/mem/info/LogicalViewInfo.java | 161 +++++
.../schemafile/factory/CacheMNodeFactory.java | 7 +
.../schemafile/impl/CachedMeasurementMNode.java | 5 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 10 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 75 ++-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 41 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 2 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 5 +
.../impl/SchemaRegionPlanDeserializer.java | 24 +
.../impl/SchemaRegionPlanSerializer.java | 27 +
.../impl/SchemaRegionPlanTxtSerializer.java | 21 +
.../impl/write/CreateLogicalViewPlanImpl.java | 75 +++
.../schemaregion/result/ShowTimeSeriesResult.java | 14 +-
.../schemaregion/write/ICreateLogicalViewPlan.java | 66 +++
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 6 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 8 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 5 +
.../schemaregion/SchemaRegionMemoryImpl.java | 40 ++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 7 +
.../metadata/template/ClusterTemplateManager.java | 36 ++
.../view/viewExpression/ViewExpression.java | 318 ++++++++++
.../view/viewExpression/ViewExpressionType.java | 76 +++
.../binary/BinaryViewExpression.java | 119 ++++
.../binary/arithmetic/AdditionViewExpression.java | 61 ++
.../arithmetic/ArithmeticBinaryViewExpression.java | 52 ++
.../binary/arithmetic/DivisionViewExpression.java | 61 ++
.../binary/arithmetic/ModuloViewExpression.java | 61 ++
.../arithmetic/MultiplicationViewExpression.java | 63 ++
.../arithmetic/SubtractionViewExpression.java | 61 ++
.../compare/CompareBinaryViewExpression.java | 52 ++
.../binary/compare/EqualToViewExpression.java | 57 ++
.../binary/compare/GreaterEqualViewExpression.java | 57 ++
.../binary/compare/GreaterThanViewExpression.java | 57 ++
.../binary/compare/LessEqualViewExpression.java | 57 ++
.../binary/compare/LessThanViewExpression.java | 57 ++
.../binary/compare/NonEqualViewExpression.java | 57 ++
.../binary/logic/LogicAndViewExpression.java | 57 ++
.../binary/logic/LogicBinaryViewExpression.java | 52 ++
.../binary/logic/LogicOrViewExpression.java | 57 ++
.../viewExpression/leaf/ConstantViewOperand.java | 98 +++
.../view/viewExpression/leaf/LeafViewOperand.java} | 22 +-
.../view/viewExpression/leaf/NullViewOperand.java | 61 ++
.../viewExpression/leaf/TimeSeriesViewOperand.java | 87 +++
.../viewExpression/leaf/TimestampViewOperand.java | 72 +++
.../multi/FunctionViewExpression.java | 198 +++++++
.../ternary/BetweenViewExpression.java | 111 ++++
.../ternary/TernaryViewExpression.java | 105 ++++
.../viewExpression/unary/InViewExpression.java | 106 ++++
.../viewExpression/unary/IsNullViewExpression.java | 89 +++
.../viewExpression/unary/LikeViewExpression.java | 163 +++++
.../unary/LogicNotViewExpression.java | 61 ++
.../unary/NegationViewExpression.java | 61 ++
.../unary/RegularViewExpression.java | 105 ++++
.../viewExpression/unary/UnaryViewExpression.java | 73 +++
.../visitor/GetSourcePathsVisitor.java | 95 +++
.../visitor/TransformToExpressionVisitor.java | 320 ++++++++++
.../visitor/ViewExpressionVisitor.java | 219 +++++++
.../metadata/visitor/SchemaExecutionVisitor.java | 22 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 6 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 21 +
.../db/mpp/execution/driver/DriverContext.java | 9 +
.../execution/executor/RegionWriteExecutor.java | 49 ++
.../fragment/FragmentInstanceContext.java | 10 +
.../fragment/FragmentInstanceExecution.java | 17 +
.../operator/process/DeviceViewIntoOperator.java | 6 +-
.../operator/process/MergeSortOperator.java | 9 +-
.../execution/operator/process/SortOperator.java | 258 ++++++--
.../process/join/merge/MergeSortComparator.java | 45 +-
...rtKeyComparator.java => SortKeyComparator.java} | 11 +-
.../schema/source/TimeSeriesSchemaSource.java | 14 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 50 +-
.../db/mpp/plan/execution/QueryExecution.java | 3 +
.../visitor/TransformToViewExpressionVisitor.java | 391 ++++++++++++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 100 +++-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 6 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 21 +
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 28 +-
.../plan/planner/distribution/SourceRewriter.java | 4 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../node/metedata/write/CreateLogicalViewNode.java | 250 ++++++++
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 74 ++-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 27 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 20 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 2 +
.../db/mpp/plan/statement/StatementVisitor.java | 7 +
.../plan/statement/component/OrderByComponent.java | 6 +-
.../component/{SortKey.java => OrderByKey.java} | 2 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 2 +-
.../metadata/CreateLogicalViewStatement.java | 246 ++++++++
.../plan/statement/sys/ShowQueriesStatement.java | 4 +-
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 2 +-
.../db/pipe/agent/plugin/PipePluginAgent.java | 7 +
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 270 ++++++++-
.../PipeCollectorConstant.java} | 12 +-
.../core/collector/IoTDBDataRegionCollector.java | 84 +++
.../PipeHistoricalDataRegionTsFileCollector.java | 103 ++++
.../realtime/PipeRealtimeDataRegionCollector.java | 21 +-
... => PipeRealtimeDataRegionHybridCollector.java} | 13 +-
.../core/event/impl/PipeTsFileInsertionEvent.java | 1 -
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 34 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 20 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 68 +--
.../org/apache/iotdb/db/tools/DiskSpiller.java | 166 ++++++
.../apache/iotdb/db/tools/FileSpillerReader.java | 143 +++++
.../MemoryReader.java} | 35 +-
.../apache/iotdb/db/tools/SortBufferManager.java | 73 +++
.../PipeTaskAgent.java => tools/SortReader.java} | 24 +-
.../db/utils/datastructure/MergeSortHeap.java | 4 +-
.../iotdb/db/utils/datastructure/MergeSortKey.java | 25 +-
.../{MergeSortKey.java => SortKey.java} | 14 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 9 +-
.../metadata/view/ViewExpressionToStringTest.java | 183 ++++++
.../execution/operator/MergeSortOperatorTest.java | 36 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 14 +-
.../mpp/execution/operator/SortOperatorTest.java | 273 +++++++++
.../db/mpp/plan/optimization/TestPlanBuilder.java | 6 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 16 +-
.../plan/node/process/DeviceViewNodeSerdeTest.java | 6 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 4 +-
.../collector/CachedSchemaPatternMatcherTest.java | 48 +-
.../core/collector/PipeRealtimeCollectTest.java | 58 +-
.../DataNodeInternalRPCServiceImplTest.java | 31 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 658 ---------------------
thrift/src/main/thrift/datanode.thrift | 35 +-
208 files changed, 8584 insertions(+), 1721 deletions(-)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/orderBy/IoTDBOrderBy2IT.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/collector/DefaultCollector.java
copy server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeCriticalException.java (62%)
copy server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeException.java (63%)
copy server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeNonCriticalException.java (61%)
copy server/src/main/java/org/apache/iotdb/db/{pipe/core/collector/historical/PipeHistoricalCollector.java => engine/compaction/execute/exception/CompactionMemoryNotEnoughException.java} (73%)
copy server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/impl/{MeasurementMNode.java => LogicalViewMNode.java} (67%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/impl/LogicalViewSchema.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/info/LogicalViewInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/CreateLogicalViewPlanImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/ICreateLogicalViewPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ViewExpressionType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/BinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/AdditionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/ArithmeticBinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/DivisionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/ModuloViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/MultiplicationViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/SubtractionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/CompareBinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/EqualToViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/GreaterEqualViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/GreaterThanViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/LessEqualViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/LessThanViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/NonEqualViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/logic/LogicAndViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/logic/LogicBinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/logic/LogicOrViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/ConstantViewOperand.java
copy server/src/main/java/org/apache/iotdb/db/{pipe/agent/task/PipeTaskAgent.java => metadata/view/viewExpression/leaf/LeafViewOperand.java} (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/NullViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/TimeSeriesViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/TimestampViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/multi/FunctionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ternary/BetweenViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ternary/TernaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/InViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/IsNullViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/LikeViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/LogicNotViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/NegationViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/RegularViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/UnaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/visitor/GetSourcePathsVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/visitor/TransformToExpressionVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/visitor/ViewExpressionVisitor.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/merge/{MergeSortKeyComparator.java => SortKeyComparator.java} (79%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/TransformToViewExpressionVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateLogicalViewNode.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{SortKey.java => OrderByKey.java} (97%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateLogicalViewStatement.java
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/collector/historical/PipeHistoricalCollector.java => config/PipeCollectorConstant.java} (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/IoTDBDataRegionCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/historical/PipeHistoricalDataRegionTsFileCollector.java
rename server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/{PipeRealtimeHybridDataRegionCollector.java => PipeRealtimeDataRegionHybridCollector.java} (95%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/DiskSpiller.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/FileSpillerReader.java
copy server/src/main/java/org/apache/iotdb/db/{pipe/core/event/impl/PipeTsFileInsertionEvent.java => tools/MemoryReader.java} (51%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/SortBufferManager.java
copy server/src/main/java/org/apache/iotdb/db/{pipe/agent/task/PipeTaskAgent.java => tools/SortReader.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/utils/datastructure/{MergeSortKey.java => SortKey.java} (74%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/view/ViewExpressionToStringTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SortOperatorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/pipedata/BufferedPipeDataQueueTest.java