This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch new-rpc-format-impl
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 5d418ed2969 temp
discard 983d68dc063 assemble with session
discard 5109de75b0a finish
discard 97871b7b116 temp
discard 87dd78dd889 add compression support
discard f230c2f1eec pass schema serialize and deserialize test
add 5aa6ac53da6 Fix bug: parent procedure should not execute before
sub-procedure finished (#12134)
add a21e2b79cc3 Pipe: fix legacy receiver's unsafe execution race problem
(fix IoTDBPipeDataSinkIT.testLegacyConnector) (#12152)
add 9bbe9a5c457 Pipe IT: add parameter "connector.batch.enable" = "false"
for IoTDBPipeNullValueIT to temp fix CI (#12153)
add 48c11629c56 fix StorageEngine recover slowly (#12151)
add 90616032db0 Pipe: Fixed potential lose point bug when an unclosed
tsfile reaches `isEventTimeOverlappedWithTimeRange()` judgement (CI fails on
testInsertNullValueTemplate) (#12156)
add b1589f913ab [IOTDB-6301] Optimize insert first (#12136)
add f00763dc5cd Pipe: support IoTDB-style pattern (#12085)
add fbddcfd62a2 Pipe Meta: Completed the logical view related logics &
some bug fixes in IT and dirs (#12159)
add b61739ab41e UDF: add "timestampPrecision" system parameter in
UDFParameters (#12158)
add 580b0250222 Fix cpp client IT on windows (#12162)
add 9ceeeb5aabb Pipe IT: Refactored IT to complement necessary flush to
all the pipe ITs (#12164)
add e0074edf420 [IOTDB-6310] Optimize for query resource init
add 101ca41e037 fix error log caused by ClosedByInterruptException in
compaction module
add c6d901ca76c Refactor IQueryExecution to support Table Model in the
future
add 0191563f172 fix(jdbc): when catalog is "Apache IoTDB", ignore it
(#12166)
add de5405fef83 Print native request api in datanode_slow_sql.log
add 0443aa6a0c8 Bump google.golang.org/protobuf in
/iotdb-connector/grafana-plugin (#12168)
add fd831b7d964 Random schedule compaction of bound data regions in one
compaction schedule worker (#12167)
add 7b34fa91e42 Fixed logical view creation with "into" pattern failure
problem
add 613afa5365e Support schema region snapshot parser (#12145)
add aa547fb3889 Pipe: implemented sdt-sampling-processor & refactored
down-sampling-processor (#12114)
add 792cf133c31 UDF: add an udf function for envelope demodulation
analysis (#12146)
add c12b8b765cf Pipe: Fixed create logical view idempotency problem & some
IT check coverage missing (#12170)
add cf67dc259cf fix: Fix the build.
add 5cb15970ef7 Optimize the result of EXPLAIN ANALYZE
add 86b942dc25a Integration test cluster stop faster (#12110)
add 277c1567b8f Fix Concurrent bug between NodeSupplier.close() and its
run()
add 797aa491b8f Fix wal delete sort method (#12176)
add 6114fd4cbe4 Fixed simple consensus correctness problem when recovering
(#12173)
add f781e730e51 Update iotdb-doap.rdf to update the info in
https://projects.apache.org/project.html?iotdb (#12179)
add 5b056644f28 Thrift zero-copy optimization for TElasticFramedTransport
(#12050)
add a9751f7c9ce Optimize Count/Delete Timeseries root.** or root.db.**
new 689ab4408a2 pass schema serialize and deserialize test
new 6a6fb2c2282 add compression support
new 503beb0733a temp
new 034a54fffa7 finish
new 62d9ab584dc assemble with session
new d3713d92550 temp
new 7b88f906233 pass test
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 (5d418ed2969)
\
N -- N -- N refs/heads/new-rpc-format-impl (7b88f906233)
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 7 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:
.github/workflows/client-cpp.yml | 2 +-
.github/workflows/pipe-it-2cluster.yml | 2 -
.../iotdb/it/env/cluster/env/AbstractEnv.java | 2 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 15 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 +
.../confignode/it/procedure/IoTDBProcedureIT.java | 113 +++-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 18 +
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 30 +-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 5 +-
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 5 +
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 7 +-
.../IoTDBPipePatternFormatIT.java} | 148 ++---
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 6 +-
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 6 +-
.../api/customizer/parameter/UDFParameters.java | 112 +++-
.../org/apache/iotdb/tool/WriteCsvFileTest.java | 4 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 10 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 4 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 65 --
...rtFactory.java => BaseRpcTransportFactory.java} | 30 +-
.../iotdb/rpc/DeepCopyRpcTransportFactory.java | 39 +-
.../rpc/TCompressedElasticFramedTransport.java | 7 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 47 +-
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 22 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 13 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 12 +-
.../iotdb/rpc/ZeroCopyRpcTransportFactory.java | 39 +-
.../org/apache/iotdb/session/NodesSupplier.java | 7 +-
.../java/org/apache/iotdb/session/Session.java | 3 +-
.../apache/iotdb/session/SessionConnection.java | 12 +-
.../org/apache/iotdb/session/ThriftConnection.java | 10 +-
.../apache/iotdb/session/util/SessionRPCUtils.java | 29 +-
iotdb-connector/grafana-plugin/go.mod | 2 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 5 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 13 -
.../statemachine/ConfigRegionStateMachine.java | 7 +-
.../iotdb/confignode/manager/ConfigManager.java | 78 ++-
.../apache/iotdb/confignode/manager/IManager.java | 9 -
.../iotdb/confignode/manager/ProcedureManager.java | 25 +-
.../manager/consensus/ConsensusManager.java | 5 +-
.../confignode/manager/load/cache/LoadCache.java | 2 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 9 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 9 +-
.../PipeConfigNodeSnapshotResourceManager.java | 4 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 11 +
.../manager/schema/ClusterSchemaManager.java | 19 +
.../persistence/schema/ClusterSchemaInfo.java | 23 +
.../confignode/procedure/ProcedureExecutor.java | 11 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 20 +-
.../AddNeverFinishSubProcedureProcedure.java | 78 +++
.../CreateManyDatabasesProcedure.java | 12 +-
.../impl/testonly/NeverFinishProcedure.java | 68 ++
.../impl/testonly/ProcedureTestUtils.java | 39 +-
.../procedure/store/ProcedureFactory.java | 14 +-
.../confignode/procedure/store/ProcedureType.java | 10 +-
.../iotdb/confignode/service/ConfigNode.java | 4 +-
.../service/thrift/ConfigNodeRPCService.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 14 +-
.../persistence/schema/ConfigMTreeTest.java | 7 +
.../iot/client/SyncIoTConsensusServiceClient.java | 4 +-
.../iot/service/IoTConsensusRPCService.java | 4 +-
.../simple/SimpleConsensusServerImpl.java | 17 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 20 +-
.../PipeDataRegionProcessorConstructor.java | 9 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 5 +-
.../protocol/writeback/WriteBackConnector.java | 2 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 13 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 9 +-
.../pipe/event/common/row/PipeRemarkableRow.java | 55 ++
.../iotdb/db/pipe/event/common/row/PipeRow.java | 18 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 9 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 9 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 20 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 19 +-
.../tablet/TabletInsertionDataContainer.java | 28 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 19 +-
.../tsfile/TsFileInsertionDataContainer.java | 21 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 15 +-
.../dataregion/IoTDBDataRegionExtractor.java | 68 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 20 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 31 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 6 +-
.../realtime/epoch/TsFileEpochManager.java | 4 +-
.../matcher/CachedSchemaPatternMatcher.java | 67 +-
.../matcher/PipeDataRegionMatcher.java | 2 +-
.../downsampling/DownSamplingProcessor.java | 122 ++--
...eCache.java => PartialPathLastObjectCache.java} | 38 +-
.../sdt/SwingingDoorTrendingFilter.java | 145 +++++
.../sdt/SwingingDoorTrendingSamplingProcessor.java | 201 ++++++
.../tumbling/TumblingTimeSamplingProcessor.java | 135 ++++
.../pipe/receiver/PipePlanToStatementVisitor.java | 16 +-
.../receiver/PipeStatementTSStatusVisitor.java | 17 +
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 6 +-
.../receiver/legacy/loader/DeletionLoader.java | 2 +-
.../pipe/receiver/legacy/loader/TsFileLoader.java | 2 +-
.../receiver/thrift/IoTDBDataNodeReceiver.java | 5 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +-
.../db/protocol/client/DataNodeInternalClient.java | 2 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 2 +-
.../rest/v1/impl/GrafanaApiServiceImpl.java | 6 +-
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 6 +-
.../rest/v2/impl/GrafanaApiServiceImpl.java | 6 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 8 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 166 +++--
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../db/queryengine/common/MPPQueryContext.java | 2 +-
.../execution/aggregation/UDAFAccumulator.java | 7 +-
.../execution/exchange/MPPDataExchangeService.java | 4 +-
.../fragment/FragmentInstanceContext.java | 10 +-
.../fragment/FragmentInstanceExecution.java | 7 +-
.../execution/operator/ExplainAnalyzeOperator.java | 18 +-
.../queryengine/execution/operator/Operator.java | 10 +-
.../execution/operator/OperatorContext.java | 10 +-
.../operator/schema/source/DeviceSchemaSource.java | 4 +-
.../schema/source/LogicalViewSchemaSource.java | 9 +-
.../schema/source/TimeSeriesSchemaSource.java | 4 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 117 ++--
.../db/queryengine/plan/analyze/Analysis.java | 45 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 262 ++++----
.../db/queryengine/plan/analyze/IAnalysis.java | 29 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 2 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 4 +-
.../plan/execution/IQueryExecution.java | 3 +-
.../queryengine/plan/execution/QueryExecution.java | 209 ++-----
.../plan/execution/config/ConfigExecution.java | 32 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../plan/parser/StatementGenerator.java | 25 +
.../db/queryengine/plan/planner/IPlanner.java | 54 ++
.../plan/planner/LogicalPlanVisitor.java | 3 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 197 ++++++
.../SimpleFragmentParallelPlanner.java | 3 +-
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../plan/planner/plan/DistributedQueryPlan.java | 8 +-
.../plan/planner/plan/FragmentInstance.java | 23 +-
.../plan/planner/plan/PlanFragment.java | 2 +-
.../db/queryengine/plan/planner/plan/SubPlan.java | 2 +-
.../plan/planner/plan/TimePredicate.java | 32 +-
.../plan/planner/plan/TreeModelTimePredicate.java | 64 ++
.../plan/planner/plan/node/ExplainAnalyzeNode.java | 22 +-
.../plan/statement/crud/InsertRowStatement.java | 5 +
.../metadata/view/CreateLogicalViewStatement.java | 12 +-
.../FragmentInstanceStatisticsDrawer.java | 9 +-
.../statistics/StatisticsMergeUtil.java | 2 +-
.../dag/udf/UDAFInformationInferrer.java | 6 +-
.../dag/udf/UDFParametersFactory.java | 54 ++
.../transformation/dag/udf/UDTFExecutor.java | 6 +-
.../dag/udf/UDTFInformationInferrer.java | 7 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 5 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 1 +
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 32 +
.../db/service/DataNodeInternalRPCService.java | 4 +-
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../metrics/IoTDBInternalLocalReporter.java | 3 +-
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../execute/task/InnerSpaceCompactionTask.java | 6 +-
.../compaction/io/CompactionTsFileInput.java | 104 +++
.../compaction/io/CompactionTsFileReader.java | 1 +
.../compaction/repair/RepairDataFileScanUtil.java | 8 +-
.../schedule/CompactionScheduleTaskWorker.java | 13 +-
.../compaction/schedule/CompactionScheduler.java | 6 +-
.../estimator/AbstractCompactionEstimator.java | 5 +-
.../estimator/AbstractCrossSpaceEstimator.java | 8 +
.../estimator/AbstractInnerSpaceEstimator.java | 13 +
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../dataregion/tsfile/TsFileManager.java | 10 +-
.../storageengine/dataregion/wal/WALManager.java | 9 +-
.../db/tools/schema/SRStatementGenerator.java | 355 +++++++++++
.../tools/schema/SchemaRegionSnapshotParser.java | 175 ++++++
.../org/apache/iotdb/db/utils/CommonUtils.java | 78 +++
.../pipe/event/PipeTabletInsertionEventTest.java | 43 +-
.../event/TsFileInsertionDataContainerTest.java | 493 +++++++++------
.../CachedSchemaPatternMatcherTest.java | 20 +-
.../db/pipe/pattern/IoTDBPipePatternTest.java | 110 ++++
.../db/pipe/pattern/PrefixPipePatternTest.java | 105 ++++
.../execution/operator/MergeSortOperatorTest.java | 3 +-
.../plan/planner/FragmentInstanceSerdeTest.java | 3 +-
.../db/utils/SchemaRegionSnapshotParserTest.java | 694 +++++++++++++++++++++
.../resources/conf/iotdb-common.properties | 6 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 4 +-
.../sync/SyncDataNodeInternalServiceClient.java | 4 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 4 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../config/constant/PipeExtractorConstant.java | 9 +-
.../config/constant/PipeProcessorConstant.java | 17 +-
.../pipe/connector/client/IoTDBSyncClient.java | 6 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 42 +-
.../commons/pipe/event/PipeSnapshotEvent.java | 5 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 5 +-
.../commons/pipe/pattern/IoTDBPipePattern.java | 113 ++++
.../iotdb/commons/pipe/pattern/PipePattern.java | 133 ++++
.../commons/pipe/pattern/PrefixPipePattern.java | 121 ++++
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 10 +-
... => SwingingDoorTrendingSamplingProcessor.java} | 10 +-
...sor.java => TumblingTimeSamplingProcessor.java} | 10 +-
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 9 +-
.../service/AbstractThriftServiceThread.java | 18 +-
.../iotdb/commons/service/ThriftServiceThread.java | 25 +-
.../org/apache/iotdb/commons/utils/TestOnly.java | 2 +-
.../iotdb/commons/utils/TimePartitionUtils.java | 7 +-
.../client/mock/MockInternalRPCService.java | 4 +-
.../StopReadTsFileByInterruptException.java | 27 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 37 ++
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 6 +-
iotdb-doap.rdf | 10 +-
.../src/main/thrift/confignode.thrift | 9 +-
.../src/main/thrift/datanode.thrift | 3 +-
library-udf/pom.xml | 5 +
.../library/frequency/UDFEnvelopeAnalysis.java | 248 ++++++++
.../org/apache/iotdb/library/UDFEnvelopeTest.java | 121 ++++
pom.xml | 1 +
215 files changed, 5752 insertions(+), 1681 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/{manual/IoTDBPipeInclusionIT.java
=> autocreate/IoTDBPipePatternFormatIT.java} (61%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/{RpcTransportFactory.java
=> BaseRpcTransportFactory.java} (79%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/DeepCopyRpcTransportFactory.java
(51%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/ZeroCopyRpcTransportFactory.java
(51%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/AddNeverFinishSubProcedureProcedure.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/{
=> testonly}/CreateManyDatabasesProcedure.java (88%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/NeverFinishProcedure.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/ProcedureTestUtils.java
(53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRemarkableRow.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/realtime
=> pattern}/matcher/CachedSchemaPatternMatcher.java (66%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/realtime
=> pattern}/matcher/PipeDataRegionMatcher.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/{PartialPathLastTimeCache.java
=> PartialPathLastObjectCache.java} (77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/sdt/SwingingDoorTrendingFilter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/sdt/SwingingDoorTrendingSamplingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/tumbling/TumblingTimeSamplingProcessor.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/IAnalysis.java
(57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/IPlanner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TreeModelPlanner.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/TimePredicate.java
(55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/TreeModelTimePredicate.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/udf/UDFParametersFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/io/CompactionTsFileInput.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SRStatementGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SchemaRegionSnapshotParser.java
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{extractor
=> pattern}/CachedSchemaPatternMatcherTest.java (92%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/IoTDBPipePatternTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/PrefixPipePatternTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/SchemaRegionSnapshotParserTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/pattern/IoTDBPipePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/pattern/PipePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/pattern/PrefixPipePattern.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/{DownSamplingProcessor.java
=> SwingingDoorTrendingSamplingProcessor.java} (75%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/{DownSamplingProcessor.java
=> TumblingTimeSamplingProcessor.java} (74%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java
=>
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/exception/StopReadTsFileByInterruptException.java
(70%)
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/frequency/UDFEnvelopeAnalysis.java
create mode 100644
library-udf/src/test/java/org/apache/iotdb/library/UDFEnvelopeTest.java
