This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f6835ad8560 change log level
add 3ca454e2fb9 Add isDebugEnable judgement for each LOGGER.DEBUG
add 023f5f89103 Accelerate the process of PlanNode to Operator
add c3c5cbc011e [IOTDB-6254] Fix limit push down bug in aligned sensor
add 278ee6570ea Fix AutoCreateSchema using template without WRITE_SCHEMA
add 7f425fc586d Fix flasky ITs (#11574)
add 89708420e16 Use template to reduce the repeated creation and
serialization in align by device query
add 0f18f38b11d Improve Statistics deserialization
add f94b365350d Fix Some Code Smells of DataNode Module (#11606)
add d0c88113033 fix iotdb-common.sh to check port (#11524)
add cb253412e25 Asynchronously make memtable checkpoints for wal (#11556)
add a216d372d1c Fix Some Code Smells of Examples Module (#11607)
add 022bd455f89 Fix fetch nested device with template will miss some
devices (#11597)
add a5b668ba67c Pipe: introduce global cache for TsFile metadatas and
support TTL of Pipe TsFile (#11240)
add 9619aac1988 [IOTDB-6256] Fix FLUSH deadlock
add a41439e2ab6 Fix Some Code Smells of Node Commons Module (#11604)
add fa3612d96ad Optimize memory usage of fetchSchema when inserting data
(#11591)
add 028a06f9c6b Use `Expression` to represent predicate in FE & Refactor
`tsfile/read/filter` module
add dcb6d8e3caa Fix explain error when align by device + template
add 7a17343a569 To adapt activation (#11613)
add fa7fc93b040 [IOTDB-6251] Make read in SchemaRegion linearizable by
default (#11571)
add fdda945f178 Rename THeartbeat to TDataNodeHeart (#11603)
add ed8595aae03 Pipe: add async connector retry queue / cache hit and
request count / commit queue metrics & initialize pipe metrics on CN (#11601)
add b5214cbca03 [IOTDB-6255] Scatter width metric (#11609)
add c7ab4723eaa Use min(limt, page size) as the init capacity of result
block
add 1a52ca3822d Pipe IT: Add tests for iotdb-legacy-pipe-sink & Add
forced-log & file mode tests for real-time mode & Refactor ITs (#11617)
add f34e950d0d1 Fix concurrent bug in PartitonCache
add cac7a525776 Fix follower data may out of order (#11625)
add 2253eedef80 Fix query return unexpected result with authority
add 27d265e597a Adjust series_partition_slot_num to series_slot_num in the
response message (#11628)
add 2d8b9550a2c [RatisConsensus] Fix ReadRecoverTest CI failure (#11616)
add 3b4fb7b6d96 [IOTDB-6257] Safely Delete IoT WAL with LastFlushedIndex
To Support Kill -9 (#11614)
add 4fa35d57cd0 Pipe: Implement down-sampling-processor plugin for
reducing the amount of data transferred during data sync (#11557)
add 34fc2237819 Pipe: degrade exception to log when executing pipe
procedure operations on DN to enhance the availability (#11623)
add 57b9194a459 Optimizing the Binary comparison method in
CompareBinaryColumnTransformer
add f68fdaea159 Bump org.springframework.boot:spring-boot from 2.7.15 to
2.7.18 (#11634)
add bb20b5f3f8f [RatisConsensus] Cache group id in the write/read critical
path (#11615)
add 259d3fcd618 Fix npe in TopKOperator when topKResult is null
add 7b82a00764d Fix compaction selector ut running time is too long
(#11635)
add afc6c7f916f Only root can alter template
add 431e9b81e80 Fix error judgement for MainFragmentLocatedRegion and
MostlyUsedDataRegion in distributed plan
add 919a24f3d37 fix:grafana plugin build
add 80c5b2ad138 auth.add IT for create role/user with identifier.
add 2a1fad8c871 Bump ch.qos.logback:logback-classic from 1.3.11 to 1.3.12
(#11645)
add 0dcb04086e3 Get correct TsFileSequenceReader from FileReaderManager
add 0cc841b7639 Fix close method of TopOperator and make close method of
Operator an interface
add d0918bd367a Temporarily ignore testPBTreeMemoryStatistics (#11648)
add 2aadeb4a93c [IOTDB-6259] Bump ratis version to 3.0.0 (#11618)
add 477e8e5480c [IOTDB-6248] Fix the connection will close when
WebSocketConnectorServer doesn't response in Flink-CDC-Connector & Fix multiple
cdc tasks cannot run properly at the same time (#11598)
add 35c29e16cfc Fix concurrent bug During Heartbeat and Region Creation
(#11656)
add 636bd465714 delete data and files together
add 0144133481c PBTree Improvement: WrappedSegment Layout Revision for
Reduced GC Overhead (#11652)
add 9eb60a9faa8 Bump logback.version from 1.3.12 to 1.3.13 (#11653)
add b2be051adb0 fix the error when last query non-writble view with same
sensors (#11658)
add b232fcf163d fix inner compaction select task base on mod file (#11654)
add 4a9fb924391 Fix file counted twice in TsFileMetrics (#11662)
add 3427b320b62 Fix compaction UTs and add concurrency control when
schedule compaction (#11638)
add f48454ab50a Update iotdb-doap.rdf
add 2edc91d287f Add format check for Prometheus Reporter Check (#11666)
add ec118416f36 Added getRegionId api for partitionManager (#11663)
add 24f0a606cbc Ignore MismatchedType caused by delete
add 788b0bc9523 Refactor Device Node Implementation in SchemaRegion
(#11661)
add dcaedd336e3 Extend `Filter` interface to support aligned timeseries
add 235a3f3c14e Pipe Schema: Added ConcurrentIterableLinkedQueue to record
the ConsensusRequest and SnapShot event (#11650)
add 5e89a90ece5 TopKNode will use IdentityNode but not ShuffleSinkNode
add 9b19cf72ac4 [IOTDB-6174] Support ColumnInjectOperator for '__endTime'
output
add 6c92fbc8c77 Optimize the efficiency of map-related code in
IRegionGroupAllocator (#11673)
add 78ce7e74bce [IOTDB-6259][RatisConsensus] Fix missing prefix in gauge
metrics (#11677)
add c185c6c9c92 [IOTDB-6263] Enhance IoTDBPartitionCreationIT (#11676)
add 0fa7f403130 Fix reconnect bug for JDBC
add 3b4788614c2 Pipe: avoid useless pipe meta sync (stopped status) to DN
to achieve high availability (#11641)
add 90ce01eb7e8 [RatisConsensus] Retry Read Requests on
StatusRuntimeException (#11679)
add 11adc7c920a [IOTDB-6252] Greedy CopySet allocation algorithm (#11572)
add ee5e23dbb94 Rest service code optimization and fixed insertRecords
error prompt returning null issue (#11678)
add 9ded0bdf7dd Bump ch.qos.logback:logback-core from 1.3.13 to 1.3.14
(#11683)
add 60d66ae873f Enhance the note of parameter seed_config_node (#11685)
add a93cf09d1bd Enhance the exapmle of parameter dn_seed_config_node
(#11686)
add c450e768980 Enhance parameter dn_seed_config_node commets order
(#11687)
add 4922dad4d17 Add last time check for inner space compaction task
(#11553)
add 9af1e765c5d Cache the internal compaction estimation result if
compaction task is failed to run (#11586)
add acde4457a3d [IOTDB-6264] Load: Optimized Validation Messages with
'write_data' Permissions When Loading TsFiles Without schema Creation (#11684)
add 09b7e86fd63 add config for inner compaction selector (#11693)
add b1d3dc63c9e [IOTDB-6265] Construct SessionPool using empty nodeUrls
should throw exception
add 5caeeb3e3b7 Pipe: automatically start pipe upon creation & allow to
start RUNNING pipe & allow to stop STOPPED pipe (#11690)
add a061c0d4514 Pipe: Make error message reported by pipe parameter check
clearer (#11695)
add b57f320153b Make slimit and soffset available in align by device with
template
add 1dfdae910bf [IOTDB-6266] Add the ability to flush syncIndex and update
reader periodically for IoTConsensus (#11691)
add e75bc1c4675 Enable Jenkins Log when CI failed (#11700)
add f5a05fba466 Enable jenkins log when ci failed (#11701)
add bcc3b3dd4a1 Pipe schema: RPC request & response datastructures (#11680)
add 63475a16592 Pipe: Add pipeSinkHandshakeTimeout parameter to
distinguish it from pipeSinkTransferTimeout & Call handshake() method of
temporary connector's to validate createPipeStatement (#11655)
add baae7ce0332 Fix snapshot UT (#11697)
add 4e72d07de9b Featrue add insertRecords and insertTablets to the rest v2
service for data type verification (#11708)
add fb23bd43639 fix(cli): add jna for windows (#11707)
add f61f310c277 fix Precondition failure (#11710)
add f12b5eb5f51 add IT testing to rest service (#11437)
add 795d420db86 Pipe: rename iotdb-thrift-ssl-sink & allow not specifying
connector in kv attrs & support kv attrs that don't have sink. / processor. /
sink. prefixes (#11715)
add 3e4c6a4df91 Pipe Schema: Receiver Agent: Added pipe enriched planNode
to enable pipe request detection to configure "forwarding-pipe-request" (#11672)
add ac326a59e40 Improved stability of Ratis addMemberToGroup and
testThresholdSnapshot UT (#11717)
add 88549541f6b Add a param to switch whether to enable data separation or
not (#11692)
add 8c8c8d58523 [IOTDB-5706] Data inconsistency between IoT protocol
replications (#11727)
add 13c047fe7bc IT: enable REST service when needed to fix IT (#11726)
add 54a3733263f Take snapshot for mods using copy instead of hard link
(#11728)
add 1c886d255b6 change default config value of
inner_compaction_task_selection_mods_file_threshold (#11703)
add fd9cb6ed8b7 Implement Cluster ID (#11702)
add 301033fe015 Show devices with template (#11681)
add 40c32518da0 Pipe Schema: Receiver Agent: config plan node to statement
transformation logic (#11689)
add ef6dc0a8e14 Pipe: enhance the idempotence of start / stop pipe
(#11713)
add 720d4729bd1 SeriesScanUtil support predicate pushdown
add 2da2255c75e Fix UT testLargeFileInLowerLevel of
CompactionSchedulerTestWithFastCompactionPerformer (#11735)
add 2c29fbc9f50 Pipe: validate the value of extractor.pattern (#11720)
add f98b3d218e0 Fix LIMIT/OFFSET push down in GROUP BY MONTH
add 14048939836 Fix some problems of FastCompactionPerformer (#11743)
add 82139d433eb Pipe: fix losing points when enable batch mode introduced
by progress commit framework refactor (#11722)
add 28833cbb360 Refactor query optimization rule: ColumnInjectionPushDown
(#11738)
add 7dea735db98 [IOTDB-6266] Add the ability to flush syncIndex and update
reader periodically for IoTConsensus (#11737)
add 81af7f4c7e7 Add more query metrics in the fragment instance level
(#11719)
add 64599d9db38 Pipe IT: Avoid infinite self-loop request forwarding in
IoTDBPipeLifeCycleIT.testDoubleLiving (#11746)
add fc5d228abb3 fix(session): remove ignored logs (#11749)
add 6351e765b40 PBTree Mode supports node-level read/write locking with
concurrent flush and querying (#11736)
add 50d01a78f56 Fix ColumnInjectionPushDown bug & add UTs
add a287355c46e [IOTDB-5706] Data inconsistency between IoT protocol
replications (#11748)
add a0ac60e0bf2 [IOTDB-6262] Pipe: fix NPE while deserializing WAL (caused
by non-atomic WAL rename operation during pipe read) (#11753)
add 349397f4553 Pipe Schema: execution framework for config regions and
schema regions (#11639)
add 13ea7e6bb61 Load: Fix InstanceAlreadyExistsException caused by
concurrent registration on JMXService (#11755)
add 06810e69568 [IOTDB-6272] Fix wrong RealNumber check for PartialPath
add 440935489cc Pipe: Changed the property files' "extractor" and
"connector" related parameters to their "source" and "sink" counterparts
(#11751)
add cc4d0835e0f flink-sql-iotdb-connector: add property cdc.mode in cdc
connector (#11758)
add 1e7395ac524 Pipe: set pipe_sink_selector_number to
pipe_sink_core_client_number to improves the performance of concurrent file
transfers (#11760)
add 571ea729702 Bump org.apache.tomcat.embed:tomcat-embed-core from 9.0.58
to 9.0.83 (#11766)
add d406f40f768 [IOTDB-6276] Load IT: Add ConnectionTimeoutMs for
IOTDBLoadTsFileIT.testLoadWithMods (#11764)
add 7507f4b7b4f Pipe: Ignore ConcurrentModificationException caused by
PipeWALResourceManager#ttlCheck() & PipeTsFileResourceManager#ttlCheck()
(#11761)
add f2a63b0cdcf Fix TsFile with TimeseriesMetadata over 2GB cannot be read
(#11739)
add 057f307a740 Bump org.apache.zookeeper:zookeeper from 3.6.3 to 3.7.2
(#11767)
add 75fb67cf80e Bump org.apache.avro:avro from 1.8.2 to 1.11.3 (#11768)
add a0bf520a3b8 Fix UT DataRegion.testMerge (#11771)
add 331946821b0 Try to fix CQ IT
add 315eacb5c3b Show regionId supports SQL queries by time range. (#11747)
add ef3ab7b378b Update example/client-cpp-example/README.md (#11730)
add 0300a8a8ef6 Compaction rate limiter parameter supports negative value
(#11774)
add 5d900ab1680 Enhance IoTDBClusterRestartIT (#11775)
add 6954461c799 Fix bug using null as measurement name (#11742)
add 9ceba0f95c4 PBTree: Fix NPE in SchemaFile conccurency control (#11770)
add d3593925305 Merge branch 'master' into native_raft
No new revisions were added by this update.
Summary of changes:
.github/workflows/grafana-plugin.yml | 2 +-
Jenkinsfile | 4 +
example/client-cpp-example/README.md | 4 +-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 4 +-
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 4 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 4 +-
.../iotdb/flink/FlinkTsFileStreamSource.java | 4 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 4 +-
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 8 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 8 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 6 +-
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 4 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 4 +-
.../org/apache/iotdb/PrepareStatementDemo.java | 6 +-
.../main/java/org/apache/iotdb/kafka/Consumer.java | 8 +-
.../org/apache/iotdb/kafka/ConsumerThread.java | 4 +-
.../main/java/org/apache/iotdb/kafka/Producer.java | 4 +-
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 4 -
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 4 +-
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 4 +-
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 6 +-
.../apache/iotdb/rabbitmq/RabbitMQProducer.java | 4 +-
.../main/java/org/apache/iotdb/HttpExample.java | 20 +-
.../main/java/org/apache/iotdb/HttpsExample.java | 20 +-
.../src/main/java/org/apache/iotdb/SSLClient.java | 4 +-
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 6 +-
.../apache/iotdb/rocketmq/RocketMQProducer.java | 5 +-
example/schema/pom.xml | 2 +-
.../org/apache/iotdb/schema/PathCheckExample.java | 26 +-
.../org/apache/iotdb/DataMigrationExample.java | 14 +-
.../iotdb/HybridTimeseriesSessionExample.java | 7 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 12 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 6 +-
.../iotdb/SyntaxConventionRelatedExample.java | 7 +-
.../iotdb/tsfile/TsFileForceAppendWrite.java | 8 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 22 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 4 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 4 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 4 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 26 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 11 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../apache/iotdb/itbase/constant/TestConstant.java | 1 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 1 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../iotdb/itbase/runtime/ClusterTestStatement.java | 10 +-
.../it/cluster/IoTDBClusterRestartIT.java | 26 +-
.../confignode/it/cluster/IoTDBClusterStartIT.java | 93 +
.../it/partition/IoTDBPartitionCreationIT.java | 4 +-
.../it/partition/IoTDBPartitionGetterIT.java | 59 +-
.../apache/iotdb/db/it/GrafanaApiServiceIT.java | 451 +++++
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 34 +
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 2119 ++++++++++++++++++++
.../IoTDBAlignByDeviceWithTemplateIT.java | 105 +
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 7 +
.../aligned/IoTDBAlignedOffsetLimitPushDownIT.java | 151 ++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 45 +
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 5 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 4 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 75 +-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 60 +-
.../apache/iotdb/db/it/cq/IoTDBCQExecInNsIT.java | 60 +-
.../apache/iotdb/db/it/cq/IoTDBCQExecInUsIT.java | 60 +-
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 253 +++
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 44 +-
.../IoTDBGroupByNaturalMonthNsPrecisionIT.java | 12 +-
.../IoTDBGroupByNaturalMonthUsPrecisionIT.java | 12 +-
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 71 +
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 7 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 4 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 85 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 89 +-
.../iotdb/pipe/PipeEnvironmentException.java | 31 +
.../apache/iotdb/pipe/it/AbstractPipeDualIT.java | 60 +
.../apache/iotdb/pipe/it/IoTDBPipeClusterIT.java | 254 ++-
.../pipe/it/IoTDBPipeConnectorParallelIT.java | 77 +-
.../apache/iotdb/pipe/it/IoTDBPipeDataSinkIT.java | 183 ++
.../apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java | 202 --
.../apache/iotdb/pipe/it/IoTDBPipeExtractorIT.java | 532 +++++
.../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 163 +-
.../apache/iotdb/pipe/it/IoTDBPipeProcessorIT.java | 104 +
.../apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java | 61 +-
.../iotdb/pipe/it/IoTDBPipeSingleEnvDemoIT.java | 16 +-
.../iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java | 51 +-
.../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 31 +-
.../pipe/it/extractor/IoTDBPipeExtractorIT.java | 700 -------
.../session/it/IoTDBSessionSyntaxConventionIT.java | 34 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 10 +-
.../java/org/apache/iotdb/pipe/api/access/Row.java | 10 +-
.../parameter/PipeParameterValidator.java | 6 +-
.../api/customizer/parameter/PipeParameters.java | 104 +-
iotdb-client/cli/pom.xml | 17 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 19 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 23 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 8 +-
.../java/org/apache/iotdb/session/SessionTest.java | 12 +
.../session/pool/SessionPoolExceptionTest.java | 12 +
.../flink/sql/client/IoTDBWebSocketClient.java | 20 +-
.../org/apache/iotdb/flink/sql/common/Options.java | 7 +
.../sql/factory/IoTDBDynamicTableFactory.java | 1 +
.../flink/sql/function/IoTDBCDCSourceFunction.java | 103 +-
iotdb-connector/grafana-plugin/backend-compile.bat | 2 +-
iotdb-connector/grafana-plugin/backend-compile.sh | 31 +-
iotdb-connector/grafana-plugin/go.mod | 35 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 56 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 56 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 15 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../resources/conf/iotdb-confignode.properties | 2 +
.../async/AsyncDataNodeHeartbeatClientPool.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 8 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../request/read/region/GetRegionIdPlan.java | 35 +-
.../write/confignode/UpdateClusterIdPlan.java | 76 +
.../request/write/pipe/PipeEnrichedPlan.java | 79 +
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ClusterManager.java | 67 +
.../iotdb/confignode/manager/ConfigManager.java | 25 +-
.../apache/iotdb/confignode/manager/IManager.java | 12 +-
.../iotdb/confignode/manager/ProcedureManager.java | 17 +-
.../manager/load/balancer/RegionBalancer.java | 21 +-
.../region/CopySetRegionGroupAllocator.java | 160 --
.../region/GreedyCopySetRegionGroupAllocator.java | 191 ++
.../region/GreedyRegionGroupAllocator.java | 31 +-
.../load/cache/node/NodeHeartbeatSample.java | 7 +-
.../manager/load/cache/node/NodeStatistics.java | 4 +-
.../manager/load/service/HeartbeatService.java | 8 +-
.../iotdb/confignode/manager/node/NodeManager.java | 11 +-
.../manager/partition/PartitionManager.java | 50 +-
.../manager/partition/PartitionMetrics.java | 36 +
.../iotdb/confignode/manager/pipe/PipeManager.java | 54 -
.../manager/pipe/agent/PipeConfigNodeAgent.java | 54 +
.../PipeConfigRegionConnectorConstructor.java | 68 +
.../PipeConfigRegionExtractorConstructor.java | 49 +
.../PipeConfigRegionProcessorConstructor.java | 41 +
.../agent/plugin/PipePluginConfigNodeAgent.java | 41 +
.../pipe/agent/task/PipeTaskConfigNodeAgent.java | 84 +
.../pipe/connector/IoTDBConfigRegionConnector.java | 30 +
.../payload/request/PipeTransferConfigPlanReq.java | 78 +
.../manager/pipe/coordinator/PipeManager.java | 54 +
.../coordinator/plugin/PipePluginCoordinator.java | 110 +
.../coordinator/runtime/PipeHeartbeatParser.java | 270 +++
.../runtime/PipeHeartbeatScheduler.java | 123 ++
.../runtime/PipeLeaderChangeHandler.java | 94 +
.../pipe/coordinator/runtime/PipeMetaSyncer.java | 182 ++
.../runtime/PipeRuntimeCoordinator.java | 98 +
.../pipe/coordinator/task/PipeTaskCoordinator.java | 209 ++
.../coordinator/task/PipeTaskCoordinatorLock.java | 107 +
.../pipe/execution/PipeConfigNodeSubtask.java | 314 +++
.../execution/PipeConfigNodeSubtaskExecutor.java | 50 +
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 30 +
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 47 +
.../manager/pipe/metric/PipeProcedureMetrics.java | 97 +
.../manager/pipe/metric/PipeTaskInfoMetrics.java | 99 +
.../manager/pipe/plugin/PipePluginCoordinator.java | 110 -
.../manager/pipe/runtime/PipeHeartbeatParser.java | 270 ---
.../pipe/runtime/PipeHeartbeatScheduler.java | 123 --
.../pipe/runtime/PipeLeaderChangeHandler.java | 94 -
.../manager/pipe/runtime/PipeMetaSyncer.java | 187 --
.../pipe/runtime/PipeRuntimeCoordinator.java | 98 -
.../manager/pipe/task/PipeConfigNodeTask.java | 51 +
.../pipe/task/PipeConfigNodeTaskBuilder.java | 72 +
.../manager/pipe/task/PipeConfigNodeTaskStage.java | 75 +
.../manager/pipe/task/PipeTaskCoordinator.java | 182 --
.../manager/pipe/task/PipeTaskCoordinatorLock.java | 107 -
.../iotdb/confignode/persistence/ClusterInfo.java | 109 +
.../persistence/executor/ConfigPlanExecutor.java | 13 +
.../confignode/persistence/node/NodeInfo.java | 29 +-
.../partition/DatabasePartitionTable.java | 44 +-
.../persistence/partition/PartitionInfo.java | 39 +-
.../persistence/pipe/PipePluginInfo.java | 23 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 50 +-
.../confignode/persistence/schema/ConfigMTree.java | 2 +-
.../persistence/schema/ConfigMTreeStore.java | 7 +
.../persistence/schema/mnode/IConfigMNode.java | 28 +
.../schema/mnode/basic/ConfigBasicMNode.java | 50 +-
.../mnode/impl/ConfigBasicInternalMNode.java | 37 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 21 +-
.../procedure/impl/pipe/PipeTaskOperation.java | 24 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 3 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 3 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 3 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 28 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 12 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 25 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 25 +-
.../iotdb/confignode/service/ConfigNode.java | 3 +
.../confignode/service/ConfigNodeShutdownHook.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 51 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 12 +
.../response/pipe/PipePluginTableRespTest.java | 4 +-
.../GreedyCopySetRegionGroupAllocatorTest.java | 203 ++
.../router/priority/GreedyPriorityTest.java | 4 +-
.../priority/LeaderPriorityBalancerTest.java | 4 +-
.../manager/load/cache/NodeCacheTest.java | 8 +-
.../connector/IoTDBConfigRegionConnectorTest.java | 53 +
.../PipeConfigNodeSubtaskExecutorTest.java | 181 ++
.../extractor/IoTDBConfigRegionExtractorTest.java | 59 +
.../confignode/persistence/ClusterInfoTest.java | 67 +
.../confignode/persistence/PartitionInfoTest.java | 70 +-
iotdb-core/consensus/pom.xml | 10 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 2 +-
.../exception/RatisReadUnavailableException.java | 31 +
.../exception/RatisUnderRecoveryException.java | 32 -
.../apache/iotdb/consensus/iot/IoTConsensus.java | 31 +-
.../consensus/iot/IoTConsensusServerImpl.java | 37 +-
.../consensus/iot/IoTConsensusServerMetrics.java | 2 +-
.../consensus/iot/client/DispatchLogHandler.java | 20 +-
.../iot/logdispatcher/IndexController.java | 5 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 28 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 4 +-
.../service/IoTConsensusRPCServiceProcessor.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 17 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 58 +-
.../consensus/ratis/metrics/CounterProxy.java | 6 +-
.../iotdb/consensus/ratis/metrics/GaugeProxy.java | 24 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 121 +-
.../ratis/metrics/MetricRegistryManager.java | 2 +-
.../ratis/metrics/RatisMetricsManager.java | 20 +-
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 32 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 27 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 30 +-
.../iot/logdispatcher/IndexControllerTest.java | 14 +-
.../iotdb/consensus/ratis/DiskGuardianTest.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 25 +-
.../iotdb/consensus/ratis/RecoverReadTest.java | 16 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 29 +-
.../resources/conf/iotdb-datanode.properties | 10 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 56 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 124 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 119 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 1 +
.../dataregion/DataExecutionVisitor.java | 50 +-
.../dataregion/DataRegionStateMachine.java | 52 +-
.../IoTConsensusDataRegionStateMachine.java | 7 +-
.../schemaregion/SchemaExecutionVisitor.java | 14 +
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 20 +-
.../agent/plugin/PipeConnectorConstructor.java | 112 --
.../agent/plugin/PipeExtractorConstructor.java | 58 -
.../db/pipe/agent/plugin/PipePluginAgent.java | 263 ---
.../pipe/agent/plugin/PipePluginConstructor.java | 85 -
.../pipe/agent/plugin/PipePluginDataNodeAgent.java | 215 ++
.../agent/plugin/PipeProcessorConstructor.java | 52 -
.../PipeDataRegionConnectorConstructor.java | 91 +
.../PipeDataRegionExtractorConstructor.java | 46 +
.../dataregion/PipeDataRegionPluginAgent.java | 48 +
.../PipeDataRegionProcessorConstructor.java | 41 +
.../PipeSchemaRegionConnectorConstructor.java | 68 +
.../PipeSchemaRegionExtractorConstructor.java | 49 +
.../schemaregion/PipeSchemaRegionPluginAgent.java | 41 +
.../PipeSchemaRegionProcessorConstructor.java | 41 +
.../agent/runtime/PipePeriodicalJobExecutor.java | 65 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 23 +
.../SimpleConsensusProgressIndexAssigner.java | 113 --
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 921 ---------
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 285 +++
.../db/pipe/commit/PipeEventCommitManager.java | 106 -
.../iotdb/db/pipe/commit/PipeEventCommitter.java | 79 -
.../config/constant/PipeConnectorConstant.java | 107 -
.../config/constant/PipeExtractorConstant.java | 62 -
.../config/constant/PipeProcessorConstant.java | 29 -
.../configuraion/PipeTaskRuntimeConfiguration.java | 42 -
.../env/PipeTaskConnectorRuntimeEnvironment.java | 34 -
.../env/PipeTaskExtractorRuntimeEnvironment.java | 44 -
.../plugin/env/PipeTaskRuntimeEnvironment.java | 43 -
.../payload/evolvable/PipeRequestType.java | 63 -
.../builder/PipeTransferBatchReqBuilder.java | 17 +-
.../request/PipeTransferFilePieceReq.java | 4 +-
.../evolvable/request/PipeTransferFileSealReq.java | 4 +-
.../request/PipeTransferHandshakeReq.java | 4 +-
.../request/PipeTransferSchemaPlanReq.java | 105 +
.../request/PipeTransferTabletBatchReq.java | 6 +-
.../request/PipeTransferTabletBinaryReq.java | 4 +-
.../request/PipeTransferTabletInsertNodeReq.java | 4 +-
.../request/PipeTransferTabletRawReq.java | 4 +-
.../db/pipe/connector/protocol/IoTDBConnector.java | 128 --
.../protocol/IoTDBConnectorRequestVersion.java | 35 -
.../protocol/airgap/IoTDBAirGapConnector.java | 16 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 34 +-
.../connector/protocol/opcua/OpcUaConnector.java | 30 +-
.../protocol/opcua/OpcUaKeyStoreLoader.java | 5 +-
.../protocol/opcua/OpcUaServerBuilder.java | 6 +-
.../thrift/async/IoTDBThriftAsyncConnector.java | 14 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 57 +-
.../sync/IoTDBThriftSyncConnectorClient.java | 84 -
.../protocol/websocket/WebSocketConnector.java | 97 +-
.../websocket/WebSocketConnectorServer.java | 467 +++--
.../protocol/writeback/WriteBackConnector.java | 4 +-
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 4 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 4 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 5 +
.../tsfile/TsFileInsertionDataContainer.java | 56 +-
.../executor/PipeAssignerSubtaskExecutor.java | 10 +-
.../executor/PipeConnectorSubtaskExecutor.java | 10 +-
.../executor/PipeProcessorSubtaskExecutor.java | 10 +-
.../execution/executor/PipeSubtaskExecutor.java | 158 --
.../executor/PipeSubtaskExecutorManager.java | 47 +-
.../PipeDataRegionAssignerSubtaskExecutor.java | 33 +
.../PipeDataRegionConnectorSubtaskExecutor.java | 33 +
.../PipeDataRegionProcessorSubtaskExecutor.java | 33 +
.../PipeSchemaRegionAssignerSubtaskExecutor.java | 31 +
.../PipeSchemaRegionConnectorSubtaskExecutor.java | 31 +
.../PipeSchemaRegionProcessorSubtaskExecutor.java | 31 +
.../execution/scheduler/PipeSubtaskScheduler.java | 90 -
.../pipe/extractor/IoTDBDataRegionExtractor.java | 81 +-
.../pipe/extractor/IoTDBSchemaRegionExtractor.java | 30 +
.../PipeHistoricalDataRegionTsFileExtractor.java | 85 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 18 +-
.../realtime/assigner/DisruptorQueue.java | 5 +-
.../listener/PipeInsertionDataNodeListener.java | 10 +-
.../iotdb/db/pipe/metric/PipeConnectorMetrics.java | 22 +
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 71 +
.../db/pipe/metric/PipeDataRegionEventCounter.java | 86 +
.../db/pipe/metric/PipeEventCommitMetrics.java | 141 ++
.../iotdb/db/pipe/metric/PipeEventCounter.java | 79 -
.../apache/iotdb/db/pipe/metric/PipeMetrics.java | 69 -
.../pipe/metric/PipeWALInsertNodeCacheMetrics.java | 24 +
.../downsampling/DownSamplingProcessor.java | 213 ++
.../downsampling/PartialPathLastTimeCache.java | 111 +
.../SimpleConsensusProgressIndexAssigner.java | 113 ++
.../progress/committer/PipeEventCommitManager.java | 110 +
.../progress/committer/PipeEventCommitter.java | 98 +
.../pipe/receiver/PipePlanToStatementVisitor.java | 186 ++
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 2 +-
.../pipe/receiver/thrift/IoTDBThriftReceiver.java | 2 +-
.../receiver/thrift/IoTDBThriftReceiverAgent.java | 2 +-
.../receiver/thrift/IoTDBThriftReceiverV1.java | 46 +-
.../db/pipe/resource/memory/PipeMemoryBlock.java | 16 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 37 +
.../pipe/resource/memory/PipeMemoryWeighUtil.java | 58 +
.../pipe/resource/tsfile/PipeTsFileResource.java | 217 ++
.../resource/tsfile/PipeTsFileResourceManager.java | 219 +-
.../db/pipe/resource/wal/PipeWALResource.java | 4 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 71 +-
.../org/apache/iotdb/db/pipe/task/PipeBuilder.java | 64 -
.../iotdb/db/pipe/task/PipeDataNodeTask.java | 84 +
.../org/apache/iotdb/db/pipe/task/PipeTask.java | 79 -
.../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 74 -
.../apache/iotdb/db/pipe/task/PipeTaskManager.java | 122 --
.../db/pipe/task/builder/PipeDataNodeBuilder.java | 79 +
.../pipe/task/builder/PipeDataNodeTaskBuilder.java | 88 +
.../builder/PipeDataNodeTaskDataRegionBuilder.java | 38 +
.../PipeDataNodeTaskSchemaRegionBuilder.java | 38 +
.../pipe/task/connection/BlockingPendingQueue.java | 129 --
.../connection/BoundedBlockingPendingQueue.java | 31 -
.../db/pipe/task/connection/EnrichedDeque.java | 4 +-
.../db/pipe/task/connection/EventSupplier.java | 34 -
.../pipe/task/connection/PipeEventCollector.java | 3 +-
.../connection/UnboundedBlockingPendingQueue.java | 39 -
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 12 +-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 9 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 24 +-
.../iotdb/db/pipe/task/stage/PipeTaskStage.java | 144 --
.../iotdb/db/pipe/task/subtask/DecoratingLock.java | 44 -
.../db/pipe/task/subtask/PipeDataNodeSubtask.java | 133 ++
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 255 ---
.../subtask/connector/PipeConnectorSubtask.java | 16 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../connector/PipeConnectorSubtaskManager.java | 16 +-
.../subtask/processor/PipeProcessorSubtask.java | 8 +-
.../processor/PipeProcessorSubtaskWorker.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 37 +-
.../rest/v1/handler/RequestValidationHandler.java | 12 -
.../v1/handler/StatementConstructionHandler.java | 59 -
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 47 -
.../rest/v2/handler/RequestValidationHandler.java | 43 +
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 36 +-
.../iotdb/db/protocol/session/SessionManager.java | 2 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 8 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 8 +-
.../db/queryengine/common/MPPQueryContext.java | 15 +
.../common/header/ColumnHeaderConstant.java | 16 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../common/schematree/ClusterSchemaTree.java | 35 +-
.../queryengine/common/schematree/ISchemaTree.java | 11 +-
.../timerangeiterator/AggrWindowIterator.java | 39 +-
.../db/queryengine/execution/driver/Driver.java | 4 -
.../execution/exchange/MPPDataExchangeManager.java | 174 +-
.../execution/exchange/sink/LocalSinkChannel.java | 39 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 27 +-
.../execution/exchange/sink/SinkChannel.java | 73 +-
.../exchange/source/LocalSourceHandle.java | 49 +-
.../execution/exchange/source/SourceHandle.java | 80 +-
.../execution/executor/RegionWriteExecutor.java | 276 ++-
.../fragment/FragmentInstanceContext.java | 88 +-
.../fragment/FragmentInstanceExecution.java | 3 +-
.../fragment/FragmentInstanceManager.java | 17 +-
.../execution/fragment/QueryContext.java | 14 +-
.../execution/fragment/QueryStatistics.java | 69 +
.../execution/load/LoadTsFileManager.java | 4 +-
.../queryengine/execution/load/TsFileSplitter.java | 2 +-
.../queryengine/execution/memory/MemoryPool.java | 6 +-
.../execution/operator/AbstractOperator.java | 8 +-
.../execution/operator/AggregationUtil.java | 16 +-
.../queryengine/execution/operator/Operator.java | 12 +-
.../operator/process/AggregationOperator.java | 19 +-
.../operator/process/ColumnInjectOperator.java | 115 ++
.../process/SlidingWindowAggregationOperator.java | 18 +-
.../execution/operator/process/TopKOperator.java | 35 +-
.../operator/process/last/LastQueryUtil.java | 8 +-
.../operator/schema/SchemaFetchScanOperator.java | 13 +-
.../operator/schema/source/DeviceSchemaSource.java | 15 +
.../source/AbstractDataSourceOperator.java | 15 +
.../AbstractSeriesAggregationScanOperator.java | 65 +-
.../AlignedSeriesAggregationScanOperator.java | 25 +
.../operator/source/AlignedSeriesScanOperator.java | 26 +-
.../operator/source/AlignedSeriesScanUtil.java | 163 +-
.../execution/operator/source/FileLoaderUtils.java | 350 ++++
.../operator/source/LastCacheScanOperator.java | 5 +
.../source/SeriesAggregationScanOperator.java | 25 +
.../operator/source/SeriesScanOperator.java | 26 +-
.../execution/operator/source/SeriesScanUtil.java | 605 +++---
.../operator/source/ShowQueriesOperator.java | 5 +
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../metric/QueryExecutionMetricSet.java | 24 +-
.../queryengine/metric/QueryPlanCostMetricSet.java | 10 +-
.../metric/QueryRelatedResourceMetricSet.java | 144 +-
.../metric/SeriesScanCostMetricSet.java | 825 +++++---
.../db/queryengine/plan/analyze/Analysis.java | 14 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 172 +-
.../plan/analyze/ExpressionAnalyzer.java | 217 --
.../queryengine/plan/analyze/ExpressionUtils.java | 105 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 43 +-
.../queryengine/plan/analyze/PredicateUtils.java | 347 ++++
.../queryengine/plan/analyze/TemplatedAnalyze.java | 59 +-
.../db/queryengine/plan/analyze/TemplatedInfo.java | 275 +++
.../db/queryengine/plan/analyze/TypeProvider.java | 99 +-
.../analyze/cache/partition/PartitionCache.java | 12 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 25 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 17 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 13 +-
.../plan/analyze/schema/ISchemaFetcher.java | 6 +-
.../queryengine/plan/execution/QueryExecution.java | 11 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 120 +-
.../config/executor/IConfigTaskExecutor.java | 10 +
.../config/metadata/ShowClusterIdTask.java | 65 +
.../memory/StatementMemorySourceVisitor.java | 3 +-
.../db/queryengine/plan/expression/Expression.java | 5 +
.../plan/expression/ExpressionFactory.java | 53 +
.../plan/expression/ExpressionType.java | 3 +-
.../expression/other/GroupByTimeExpression.java | 159 ++
.../plan/expression/unary/InExpression.java | 15 +-
.../plan/expression/unary/IsNullExpression.java | 5 -
.../plan/expression/unary/LikeExpression.java | 84 +-
.../plan/expression/unary/LogicNotExpression.java | 5 -
.../plan/expression/unary/NegationExpression.java | 5 -
.../plan/expression/unary/RegularExpression.java | 31 +-
.../plan/expression/unary/UnaryExpression.java | 2 -
.../plan/expression/visitor/ExpressionVisitor.java | 5 +
.../visitor/TransformToViewExpressionVisitor.java | 10 +-
.../ConvertPredicateToTimeFilterVisitor.java | 241 +++
.../visitor/predicate/PredicateVisitor.java | 102 +
.../visitor/predicate/ReversePredicateVisitor.java | 148 ++
.../plan/optimization/ColumnInjectionPushDown.java | 119 ++
.../plan/optimization/LimitOffsetPushDown.java | 80 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 79 +-
.../plan/parser/StatementGenerator.java | 5 +
.../plan/planner/LocalExecutionPlanContext.java | 15 +-
.../plan/planner/LogicalPlanBuilder.java | 99 +-
.../plan/planner/LogicalPlanVisitor.java | 82 +-
.../plan/planner/OperatorTreeGenerator.java | 192 +-
.../plan/planner/SubPlanTypeExtractor.java | 9 +-
.../plan/planner/TemplatedLogicalPlan.java | 35 +-
.../plan/planner/TemplatedLogicalPlanBuilder.java | 9 +-
.../distribution/DistributionPlanContext.java | 5 +
.../planner/distribution/DistributionPlanner.java | 30 +-
.../planner/distribution/ExchangeNodeAdder.java | 41 +-
.../SimpleFragmentParallelPlanner.java | 6 +-
.../plan/planner/distribution/SourceRewriter.java | 26 +-
.../distribution/WriteFragmentParallelPlanner.java | 6 +-
.../plan/planner/plan/FragmentInstance.java | 41 +-
.../plan/planner/plan/PlanFragment.java | 36 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 22 +-
.../plan/planner/plan/node/PlanNode.java | 28 +-
.../plan/planner/plan/node/PlanNodeType.java | 39 +-
.../plan/planner/plan/node/PlanVisitor.java | 40 +-
.../planner/plan/node/load/LoadTsFileNode.java | 7 +-
.../node/metedata/read/SchemaFetchScanNode.java | 17 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 2 +-
.../metedata/write/view/AlterLogicalViewNode.java | 43 +-
.../node/pipe/PipeEnrichedConfigSchemaNode.java | 161 ++
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 169 ++
.../plan/node/pipe/PipeEnrichedInsertNode.java | 292 +++
.../node/pipe/PipeEnrichedWriteSchemaNode.java | 192 ++
.../planner/plan/node/process/AggregationNode.java | 4 +
.../plan/node/process/ColumnInjectNode.java | 145 ++
.../plan/node/process/SingleDeviceViewNode.java | 28 +
.../node/process/SlidingWindowAggregationNode.java | 51 +-
.../plan/node/process/last/LastQueryNode.java | 45 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 8 +-
.../source/AlignedSeriesAggregationScanNode.java | 85 +-
.../plan/node/source/AlignedSeriesScanNode.java | 183 +-
.../plan/node/source/LastQueryScanNode.java | 8 +-
.../plan/node/source/LastSeriesSourceNode.java | 7 +
.../node/source/SeriesAggregationScanNode.java | 85 +-
.../node/source/SeriesAggregationSourceNode.java | 61 +-
.../planner/plan/node/source/SeriesScanNode.java | 146 +-
.../planner/plan/node/source/SeriesSourceNode.java | 4 +-
.../planner/plan/node/write/DeleteDataNode.java | 4 +-
.../plan/planner/plan/node/write/InsertNode.java | 10 -
.../plan/node/write/PipeEnrichedInsertNode.java | 277 ---
.../planner/plan/parameter/SeriesScanOptions.java | 65 +-
.../queryengine/plan/statement/StatementType.java | 3 +-
.../plan/statement/StatementVisitor.java | 18 +-
.../crud/PipeEnrichedInsertBaseStatement.java | 220 --
.../crud/PipeEnrichedLoadTsFileStatement.java | 137 --
.../InternalBatchActivateTemplateStatement.java | 33 +-
.../statement/internal/SchemaFetchStatement.java | 11 +-
.../metadata/CreateContinuousQueryStatement.java | 4 +-
.../statement/metadata/GetRegionIdStatement.java | 28 +-
.../statement/metadata/ShowClusterIdStatement.java | 36 +
.../template/AlterSchemaTemplateStatement.java | 4 +-
.../metadata/view/CreateLogicalViewStatement.java | 10 +-
.../plan/statement/pipe/PipeEnrichedStatement.java | 72 +
.../binary/CompareBinaryColumnTransformer.java | 33 +-
.../column/ternary/BetweenColumnTransformer.java | 21 +-
.../binary/CompareEqualToTransformer.java | 5 +-
.../binary/CompareGreaterEqualTransformer.java | 5 +-
.../binary/CompareGreaterThanTransformer.java | 5 +-
.../binary/CompareLessEqualTransformer.java | 5 +-
.../binary/CompareLessThanTransformer.java | 5 +-
.../binary/CompareNonEqualTransformer.java | 5 +-
.../transformer/ternary/BetweenTransformer.java | 15 +-
.../transformation/dag/util/TransformUtils.java | 41 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 39 +-
.../metric/SchemaEngineCachedMetric.java | 65 +-
.../schemaengine/metric/SchemaMetricManager.java | 4 +-
.../rescon/CachedSchemaRegionStatistics.java | 12 +-
.../schemaengine/rescon/SchemaResourceManager.java | 6 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 5 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 9 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 19 +-
.../schemaregion/mtree/IMTreeStore.java | 3 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 65 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 32 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 26 +-
.../impl/mem/mnode/factory/MemMNodeFactory.java | 11 +-
.../impl/mem/mnode/impl/BasicInternalMNode.java | 83 +-
.../impl/mem/mnode/impl/DatabaseDeviceMNode.java | 37 -
.../mtree/impl/mem/mnode/impl/DatabaseMNode.java | 17 +-
.../mtree/impl/mem/mnode/impl/DeviceMNode.java | 36 -
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 2 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 75 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 374 ++--
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 117 +-
.../mtree/impl/pbtree/PBTreeFactory.java | 104 +
.../pbtree/ReentrantReadOnlyCachedMTreeStore.java | 10 +-
.../impl/pbtree/StampedWriterPreferredLock.java | 220 --
.../mtree/impl/pbtree/cache/CacheEntry.java | 48 -
.../mtree/impl/pbtree/cache/CacheManager.java | 741 -------
.../impl/pbtree/cache/CacheMemoryManager.java | 363 ----
.../mtree/impl/pbtree/cache/ICacheManager.java | 61 -
.../mtree/impl/pbtree/cache/LRUCacheManager.java | 287 ---
.../mtree/impl/pbtree/cache/PlainCacheManager.java | 83 -
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 124 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 237 +++
.../mtree/impl/pbtree/lock/LockEntry.java | 45 +
.../mtree/impl/pbtree/lock/LockManager.java | 147 ++
.../pbtree/lock/StampedWriterPreferredLock.java | 242 +++
.../pbtree/memcontrol/IReleaseFlushStrategy.java | 3 -
.../mtree/impl/pbtree/memcontrol/MemManager.java | 84 -
.../impl/pbtree/memcontrol/MemoryStatistics.java | 84 +
.../ReleaseFlushStrategyNumBasedImpl.java | 5 -
.../ReleaseFlushStrategySizeBasedImpl.java | 11 +-
.../mtree/impl/pbtree/memory/IMemoryManager.java | 92 +
.../mtree/impl/pbtree/memory/MemoryManager.java | 596 ++++++
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 404 ++++
.../impl/pbtree/memory/buffer/INodeBuffer.java | 53 +
.../impl/pbtree/memory/buffer/NodeBuffer.java | 188 ++
.../mtree/impl/pbtree/memory/cache/CacheEntry.java | 62 +
.../mtree/impl/pbtree/memory/cache/INodeCache.java | 43 +
.../impl/pbtree/memory/cache/LRUNodeCache.java | 271 +++
.../impl/pbtree/memory/cache/PlainNodeCache.java | 73 +
.../mtree/impl/pbtree/mnode/ICachedMNode.java | 7 +-
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 38 +-
.../mnode/container/CachedMNodeContainer.java | 8 +-
.../pbtree/mnode/factory/CacheMNodeFactory.java | 11 +-
.../mnode/impl/CachedAboveDatabaseMNode.java | 13 +-
.../mnode/impl/CachedBasicInternalMNode.java | 91 +-
.../mnode/impl/CachedDatabaseDeviceMNode.java | 49 -
.../pbtree/mnode/impl/CachedDatabaseMNode.java | 31 +-
.../impl/pbtree/mnode/impl/CachedDeviceMNode.java | 48 -
.../pbtree/mnode/impl/CachedMeasurementMNode.java | 13 +-
.../impl/pbtree/mnode/info/CacheMNodeInfo.java | 15 +-
.../mtree/impl/pbtree/schemafile/ISchemaPage.java | 35 +-
.../impl/pbtree/schemafile/ISegmentedPage.java | 2 +-
.../mtree/impl/pbtree/schemafile/InternalPage.java | 27 +-
.../impl/pbtree/schemafile/MockSchemaFile.java | 20 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 9 +-
.../mtree/impl/pbtree/schemafile/SchemaPage.java | 49 +-
.../mtree/impl/pbtree/schemafile/Segment.java | 478 -----
.../impl/pbtree/schemafile/SegmentedPage.java | 16 +-
.../impl/pbtree/schemafile/WrappedSegment.java | 708 +++++--
.../schemafile/pagemgr/BTreePageManager.java | 381 ++--
.../pbtree/schemafile/pagemgr/IPageManager.java | 9 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 858 +++++---
.../schemaregion/mtree/traverser/Traverser.java | 9 +-
.../read/resp/info/IDeviceSchemaInfo.java | 2 +
.../read/resp/info/impl/ShowDevicesResult.java | 11 +
.../reader/impl/TimeseriesReaderWithViewFetch.java | 3 +-
.../schemaregion/utils/MNodeUtils.java | 54 +-
.../schemaregion/utils/ResourceByPathUtils.java | 21 +-
.../utils/filter/DeviceFilterVisitor.java | 26 +
.../view/visitor/TransformToExpressionVisitor.java | 10 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 3 +-
.../db/service/metrics/CompactionMetrics.java | 2 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 6 +-
.../db/service/metrics/file/TsFileMetrics.java | 8 +-
.../iotdb/db/storageengine/StorageEngine.java | 76 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 10 +-
.../db/storageengine/dataregion/DataRegion.java | 428 ++--
.../dataregion/HashLastFlushTimeMap.java | 115 +-
.../dataregion/IDataRegionForQuery.java | 5 +-
.../dataregion/ILastFlushTimeMap.java | 31 +-
.../dataregion/VirtualDataRegion.java | 5 +-
.../CompactionLastTimeCheckFailedException.java | 34 +
.../execute/recover/CompactionRecoverTask.java | 27 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 8 +-
.../fast/AlignedSeriesCompactionExecutor.java | 19 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 15 +-
.../executor/fast/SeriesCompactionExecutor.java | 46 +-
.../executor/fast/element/AlignedPageElement.java | 94 +
.../fast/element/NonAlignedPageElement.java | 74 +
.../utils/executor/fast/element/PageElement.java | 96 +-
.../utils/executor/fast/element/PointElement.java | 11 +-
.../fast/reader/CompactionAlignedChunkReader.java | 122 ++
.../fast/reader/CompactionChunkReader.java | 94 +
.../readchunk/AlignedSeriesCompactionExecutor.java | 12 +
.../readchunk/SingleSeriesCompactionExecutor.java | 15 +-
.../execute/utils/reader/PointPriorityReader.java | 2 +-
.../utils/writer/AbstractCompactionWriter.java | 11 +
.../writer/AbstractCrossCompactionWriter.java | 11 +-
.../writer/AbstractInnerCompactionWriter.java | 8 +-
.../utils/writer/FastInnerCompactionWriter.java | 12 +-
.../compaction/schedule/CompactionScheduler.java | 13 +
.../compaction/schedule/CompactionTaskManager.java | 2 +-
.../compaction/schedule/CompactionWorker.java | 22 +-
.../estimator/AbstractCompactionEstimator.java | 27 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../impl/SizeTieredCompactionSelector.java | 11 +-
.../compaction/settle/SettleRequestHandler.java | 24 +-
.../dataregion/memtable/AbstractMemTable.java | 8 +-
.../memtable/AlignedReadOnlyMemChunk.java | 21 +-
.../dataregion/memtable/IMemTable.java | 6 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 11 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +-
.../io/LocalTextModificationAccessor.java | 3 -
.../read/reader/chunk/DiskAlignedChunkLoader.java | 30 +-
.../read/reader/chunk/DiskChunkLoader.java | 31 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 22 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 6 +-
.../read/reader/chunk/MemAlignedPageReader.java | 129 +-
.../read/reader/chunk/MemChunkLoader.java | 15 +-
.../read/reader/chunk/MemChunkReader.java | 13 +-
.../read/reader/chunk/MemPageReader.java | 283 +--
.../metadata/DiskAlignedChunkMetadataLoader.java | 57 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 50 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 40 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 33 +-
.../dataregion/snapshot/SnapshotTaker.java | 14 +-
.../dataregion/tsfile/TsFileResource.java | 8 +-
.../dataregion/utils/TsFileResourceUtils.java | 52 +-
.../dataregion/wal/buffer/AbstractWALBuffer.java | 14 +-
.../dataregion/wal/buffer/WALBuffer.java | 52 +-
.../dataregion/wal/buffer/WALEntry.java | 3 +
.../dataregion/wal/buffer/WALEntryType.java | 2 +
.../dataregion/wal/buffer/WALInfoEntry.java | 2 +
.../dataregion/wal/buffer/WALSignalEntry.java | 13 +-
.../dataregion/wal/checkpoint/Checkpoint.java | 10 +-
.../wal/checkpoint/CheckpointManager.java | 25 +-
.../dataregion/wal/checkpoint/MemTableInfo.java | 10 +-
.../storageengine/dataregion/wal/node/WALNode.java | 22 +-
.../file/AbstractTsFileRecoverPerformer.java | 4 +-
.../dataregion/wal/utils/WALEntryHandler.java | 14 +-
.../dataregion/wal/utils/WALFileUtils.java | 8 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 18 +-
.../rescon/disk/strategy/DirectoryStrategy.java | 4 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 2 +-
.../quotas/DataNodeThrottleQuotaManager.java | 2 +-
.../rescon/quotas/DefaultOperationQuota.java | 16 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 8 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 80 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 16 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../db/trigger/executor/TriggerFireVisitor.java | 17 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 12 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 378 ----
.../java/org/apache/iotdb/db/utils/MemUtils.java | 4 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 8 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 62 -
.../db/utils/columngenerator/ColumnGenerator.java | 28 +
.../utils/columngenerator/ColumnGeneratorType.java | 34 +
.../SlidingTimeColumnGenerator.java | 52 +
.../parameter/ColumnGeneratorParameter.java | 82 +
.../SlidingTimeColumnGeneratorParameter.java | 80 +
.../dataregion/DataRegionStateMachineTest.java | 78 +
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 31 +-
.../mtree/lock/StampedWriterPreferredLockTest.java | 16 +-
.../db/metadata/mtree/schemafile/MonitorTest.java | 106 +
.../mtree/schemafile/SchemaFileLogTest.java | 4 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 3 +-
.../schemaRegion/SchemaRegionBasicTest.java | 88 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 37 +-
.../schemaRegion/SchemaStatisticsTest.java | 14 +-
.../db/pipe/agent/plugin/PipePluginAgentTest.java | 120 --
.../agent/plugin/PipePluginDataNodeAgentTest.java | 123 ++
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 2 +-
.../connector/PipeDataNodeThriftRequestTest.java | 248 +++
.../db/pipe/connector/PipeThriftRequestTest.java | 170 --
.../PipeConnectorSubtaskExecutorTest.java | 6 +-
.../PipeProcessorSubtaskExecutorTest.java | 6 +-
.../db/pipe/execution/PipeSubtaskExecutorTest.java | 4 +-
.../extractor/CachedSchemaPatternMatcherTest.java | 6 +-
.../extractor/IoTDBDataRegionExtractorTest.java | 50 +-
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 6 +-
.../resource/PipeTsFileResourceManagerTest.java | 18 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 15 +
.../aggregation/TimeRangeIteratorTest.java | 66 +-
.../operator/AggregationOperatorTest.java | 1 +
.../AlignedSeriesAggregationScanOperatorTest.java | 14 +-
.../execution/operator/FillOperatorTest.java | 15 +
.../operator/LastQueryMergeOperatorTest.java | 20 +
.../execution/operator/LinearFillOperatorTest.java | 35 +
.../execution/operator/OperatorMemoryTest.java | 10 +-
.../operator/RawDataAggregationOperatorTest.java | 5 +-
.../SeriesAggregationScanOperatorTest.java | 14 +-
.../SlidingWindowAggregationOperatorTest.java | 1 +
.../execution/operator/TopKOperatorTest.java | 297 ++-
.../operator/UpdateLastCacheOperatorTest.java | 6 +-
.../schema/SchemaFetchScanOperatorTest.java | 4 +-
.../schema/SchemaQueryScanOperatorTest.java | 6 +-
.../other/CaseWhenThenExpressionTest.java | 73 -
.../ConvertPredicateToTimeFilterTest.java | 148 ++
.../predicate/PredicateRemoveNotTest.java | 95 +
.../serde/CaseWhenThenExpressionTest.java | 73 +
.../db/queryengine/plan/analyze/AnalyzeTest.java | 26 +-
.../plan/analyze/ExpressionAnalyzerTest.java | 2 +-
.../plan/analyze/FakeSchemaFetcherImpl.java | 12 +-
.../plan/analyze/QueryTimePartitionTest.java | 168 +-
.../optimization/ColumnInjectionPushDownTest.java | 657 ++++++
.../plan/optimization/LimitOffsetPushDownTest.java | 45 +-
.../plan/optimization/OptimizationTestUtil.java | 75 +
.../plan/optimization/TestPlanBuilder.java | 157 +-
.../plan/plan/FragmentInstanceSerdeTest.java | 4 +-
.../plan/plan/QueryLogicalPlanUtil.java | 49 +-
.../distribution/AggregationDistributionTest.java | 3 +-
.../AlignByDeviceOrderByLimitOffsetTest.java | 4 +-
.../plan/plan/distribution/LastQueryTest.java | 2 +-
.../queryengine/plan/plan/distribution/Util.java | 6 +-
.../queryengine/plan/plan/distribution/Util2.java | 6 +-
.../plan/plan/node/PlanGraphPrinterTest.java | 2 +-
.../metadata/read/SchemaFetchMergeNodeTest.java | 1 +
.../metadata/read/SchemaFetchScanNodeTest.java | 2 +
.../node/process/AggregationNodeSerdeTest.java | 8 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 11 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 9 +-
.../plan/plan/node/process/LimitNodeSerdeTest.java | 2 -
.../plan/node/process/OffsetNodeSerdeTest.java | 2 -
.../plan/plan/node/process/SortNodeSerdeTest.java | 2 -
.../plan/node/process/TimeJoinNodeSerdeTest.java | 4 -
.../source/SeriesAggregationScanNodeSerdeTest.java | 9 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 2 -
.../db/storageengine/buffer/ChunkCacheTest.java | 6 +-
.../storageengine/dataregion/DataRegionTest.java | 151 +-
.../compaction/CompactionOverlapCheckTest.java | 269 +++
.../compaction/CompactionSchedulerTest.java | 24 +-
.../CompactionSchedulerWithFastPerformerTest.java | 24 +-
.../compaction/CompactionTaskManagerTest.java | 10 +-
...InconsistentCompressionTypeAndEncodingTest.java | 4 +-
.../ReadPointCompactionPerformerTest.java | 2 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 63 +-
.../compaction/utils/CompactionCheckerUtils.java | 7 +-
.../utils/CompactionUpdateFileCountTest.java | 2 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 17 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 250 +++
.../reader/chunk/MemAlignedChunkLoaderTest.java | 15 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 25 +-
.../read/reader/chunk/MemPageReaderTest.java | 134 ++
.../series/AbstractAlignedSeriesScanTest.java | 435 ++++
.../read/reader/series/AbstractSeriesScanTest.java | 236 +++
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 408 +---
.../AlignedSeriesScanPredicatePushDownTest.java | 225 +++
...gleColumnSeriesScanLimitOffsetPushDownTest.java | 201 ++
.../series/SeriesScanLimitOffsetPushDownTest.java | 214 +-
.../series/SeriesScanPredicatePushDownTest.java | 318 +++
.../dataregion/snapshot/IoTDBSnapshotTest.java | 4 +
.../wal/checkpoint/CheckpointManagerTest.java | 7 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 2 +
.../dataregion/wal/node/WALNodeTest.java | 4 +
.../wal/recover/WALRecoverManagerTest.java | 40 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 25 +-
.../wal/utils/WALInsertNodeCacheTest.java | 9 +-
.../datanode/src/test/resources/logback-test.xml | 2 +
.../metricsets/disk/LinuxDiskMetricsManager.java | 12 +-
.../metricsets/net/LinuxNetMetricManager.java | 12 +-
iotdb-core/node-commons/pom.xml | 5 +
.../resources/conf/iotdb-common.properties | 30 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 15 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 6 +-
.../apache/iotdb/commons/client/ClientManager.java | 7 +-
.../iotdb/commons/client/ClientPoolFactory.java | 2 +-
.../commons/concurrent/IoTDBThreadPoolFactory.java | 22 +
.../iotdb/commons/concurrent/ThreadName.java | 46 +-
.../threadpool/WrappedThreadPoolExecutor.java | 18 +
.../apache/iotdb/commons/conf/CommonConfig.java | 23 +-
.../iotdb/commons/conf/CommonDescriptor.java | 120 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../commons/partition/DataPartitionTable.java | 16 +-
.../commons/partition/SeriesPartitionTable.java | 26 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 8 +
.../iotdb/commons/path/fa/dfa/PatternDFA.java | 18 +-
.../iotdb/commons/path/fa/dfa/graph/DFAGraph.java | 75 +-
.../agent/plugin/PipeConnectorConstructor.java | 53 +
.../agent/plugin/PipeExtractorConstructor.java | 53 +
.../commons/pipe/agent/plugin/PipePluginAgent.java | 113 ++
.../pipe/agent/plugin/PipePluginConstructor.java | 99 +
.../agent/plugin/PipeProcessorConstructor.java | 50 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 798 ++++++++
.../iotdb/commons/pipe/config/PipeConfig.java | 11 +-
.../config/constant/PipeConnectorConstant.java | 107 +
.../config/constant/PipeExtractorConstant.java | 73 +
.../config/constant/PipeProcessorConstant.java | 41 +
.../configuraion/PipeTaskRuntimeConfiguration.java | 42 +
.../env/PipeTaskConnectorRuntimeEnvironment.java | 27 +
.../env/PipeTaskExtractorRuntimeEnvironment.java | 37 +
.../env/PipeTaskProcessorRuntimeEnvironment.java | 27 +
.../plugin/env/PipeTaskRuntimeEnvironment.java | 49 +
.../env/PipeTaskTemporaryRuntimeEnvironment.java | 28 +
.../client/IoTDBThriftSyncConnectorClient.java | 86 +
.../request/IoTDBConnectorRequestVersion.java | 35 +
.../connector/payload/request/PipeRequestType.java | 69 +
.../request/PipeTransferSnapshotPieceReq.java | 132 ++
.../request/PipeTransferSnapshotSealReq.java | 119 ++
.../payload/request/TransferConfigPlanReq.java | 24 +
.../response/PipeTransferSnapshotPieceResp.java | 81 +
.../ConcurrentIterableLinkedQueue.java | 345 ++++
.../execution/executor/PipeSubtaskExecutor.java | 158 ++
.../execution/scheduler/PipeSubtaskScheduler.java | 90 +
.../commons/pipe/metric/PipeEventCounter.java | 43 +
.../commons/pipe/metric/PipeFakeEventCounter.java | 34 +
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 83 +-
.../builtin/connector/DoNothingConnector.java | 72 -
.../builtin/connector/IoTDBAirGapConnector.java | 28 -
.../connector/IoTDBLegacyPipeConnector.java | 28 -
.../connector/IoTDBThriftAsyncConnector.java | 28 -
.../builtin/connector/IoTDBThriftConnector.java | 28 -
.../connector/IoTDBThriftSyncConnector.java | 28 -
.../plugin/builtin/connector/OpcUaConnector.java | 28 -
.../builtin/connector/WebSocketConnector.java | 28 -
.../builtin/connector/WriteBackConnector.java | 28 -
.../connector/donothing/DoNothingConnector.java | 72 +
.../builtin/connector/iotdb/IoTDBConnector.java | 128 ++
.../iotdb/airgap/IoTDBAirGapConnector.java | 30 +
.../iotdb/thrift/IoTDBLegacyPipeConnector.java | 30 +
.../connector/iotdb/thrift/IoTDBMetaConnector.java | 257 +++
.../iotdb/thrift/IoTDBSchemaRegionConnector.java | 22 +
.../iotdb/thrift/IoTDBThriftAsyncConnector.java | 28 +
.../iotdb/thrift/IoTDBThriftConnector.java | 30 +
.../iotdb/thrift/IoTDBThriftSslConnector.java | 30 +
.../iotdb/thrift/IoTDBThriftSyncConnector.java | 28 +
.../builtin/connector/opcua/OpcUaConnector.java | 30 +
.../connector/websocket/WebSocketConnector.java | 30 +
.../connector/writeback/WriteBackConnector.java | 30 +
.../plugin/builtin/extractor/IoTDBExtractor.java | 63 -
.../extractor/donothing/DoNothingExtractor.java | 55 +
.../builtin/extractor/iotdb/IoTDBExtractor.java | 64 +
.../extractor/iotdb/IoTDBMetaExtractor.java | 150 ++
.../builtin/processor/DoNothingProcessor.java | 67 -
.../builtin/processor/PlaceHolderProcessor.java | 68 +
.../processor/donothing/DoNothingProcessor.java | 67 +
.../downsampling/DownSamplingProcessor.java | 30 +
.../meta/ConfigNodePipePluginMetaKeeper.java | 2 +-
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 45 +-
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 28 +
.../iotdb/commons/pipe/task/DecoratingLock.java | 44 +
.../iotdb/commons/pipe/task/EventSupplier.java | 34 +
.../apache/iotdb/commons/pipe/task/PipeTask.java | 31 +
.../iotdb/commons/pipe/task/PipeTaskManager.java | 121 ++
.../pipe/task/connection/BlockingPendingQueue.java | 130 ++
.../connection/BoundedBlockingPendingQueue.java | 32 +
.../connection/UnboundedBlockingPendingQueue.java | 40 +
.../commons/pipe/task/meta/PipeMetaKeeper.java | 32 +
.../commons/pipe/task/stage/PipeTaskStage.java | 144 ++
.../commons/pipe/task/subtask/PipeSubtask.java | 155 ++
.../iotdb/commons/schema/filter/SchemaFilter.java | 3 +
.../commons/schema/filter/SchemaFilterFactory.java | 5 +
.../commons/schema/filter/SchemaFilterType.java | 3 +
.../commons/schema/filter/SchemaFilterVisitor.java | 5 +
.../commons/schema/filter/impl/TemplateFilter.java | 73 +
.../apache/iotdb/commons/schema/node/IMNode.java | 12 +-
.../node/common/AbstractAboveDatabaseMNode.java | 18 +-
.../node/common/AbstractDatabaseDeviceMNode.java | 299 ---
.../schema/node/common/AbstractDatabaseMNode.java | 26 +-
.../schema/node/common/AbstractDeviceMNode.java | 289 ---
.../node/common/AbstractMeasurementMNode.java | 19 +-
.../schema/node/common/DeviceMNodeWrapper.java | 263 +++
.../commons/schema/node/role/IDeviceMNode.java | 2 +-
.../commons/schema/node/role/IInternalMNode.java | 55 +
.../commons/schema/node/visitor/MNodeVisitor.java | 7 -
.../viewExpression/unary/LikeViewExpression.java | 20 +-
.../unary/RegularViewExpression.java | 24 +-
.../apache/iotdb/commons/service/JMXService.java | 8 +-
.../iotdb/commons/service/metric/enums/Metric.java | 9 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 16 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 7 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 8 -
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 3 +
.../apache/iotdb/commons/path/PatternDFATest.java | 10 +-
.../iotdb/commons/pipe/PipeMetaDeSerTest.java | 133 --
.../ConcurrentIterableLinkedQueueTest.java | 439 ++++
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 10 +-
.../commons/pipe/task/meta/PipeMetaDeSerTest.java | 128 ++
.../iotdb/tsfile/file/header/ChunkGroupHeader.java | 2 +-
.../iotdb/tsfile/file/header/PageHeader.java | 23 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 44 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 59 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 42 +
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 6 +-
.../iotdb/tsfile/file/metadata/IMetadata.java | 44 +
.../tsfile/file/metadata/ITimeSeriesMetadata.java | 9 +-
.../tsfile/file/metadata/MetadataIndexEntry.java | 7 +
.../tsfile/file/metadata/MetadataIndexNode.java | 13 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 59 +
.../file/metadata/statistics/BinaryStatistics.java | 6 +-
.../apache/iotdb/tsfile/read/TimeValuePair.java | 20 +
.../read/TsFileAlignedSeriesReaderIterator.java | 3 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 181 +-
...leSequenceReaderTimeseriesMetadataIterator.java | 29 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 10 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 32 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 7 +-
.../tsfile/read/common/parser/PathVisitor.java | 10 +-
.../read/controller/CachedChunkLoaderImpl.java | 4 +-
.../iotdb/tsfile/read/controller/IChunkLoader.java | 3 +-
.../read/expression/impl/GlobalTimeExpression.java | 12 +-
.../expression/impl/SingleSeriesExpression.java | 11 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 181 --
.../tsfile/read/filter/GroupByMonthFilter.java | 271 ---
.../read/filter/PredicateRemoveNotRewriter.java | 30 +-
.../iotdb/tsfile/read/filter/TimeFilter.java | 321 ---
.../iotdb/tsfile/read/filter/ValueFilter.java | 164 --
.../tsfile/read/filter/basic/BinaryFilter.java | 95 -
.../read/filter/basic/BinaryLogicalFilter.java | 68 +
.../filter/basic/DisableStatisticsTimeFilter.java | 33 +
.../filter/basic/DisableStatisticsValueFilter.java | 46 +
.../iotdb/tsfile/read/filter/basic/Filter.java | 196 +-
.../tsfile/read/filter/basic/OperatorType.java | 75 +
.../iotdb/tsfile/read/filter/basic/TimeFilter.java | 68 +
.../tsfile/read/filter/basic/UnaryFilter.java | 97 -
.../tsfile/read/filter/basic/ValueFilter.java | 137 ++
.../tsfile/read/filter/factory/FilterFactory.java | 108 +-
.../read/filter/factory/FilterSerializeId.java | 39 -
.../tsfile/read/filter/factory/FilterType.java | 37 -
.../tsfile/read/filter/factory/TimeFilterApi.java | 101 +
.../tsfile/read/filter/factory/ValueFilterApi.java | 186 ++
.../iotdb/tsfile/read/filter/operator/And.java | 137 ++
.../tsfile/read/filter/operator/AndFilter.java | 125 --
.../iotdb/tsfile/read/filter/operator/Between.java | 168 --
.../iotdb/tsfile/read/filter/operator/Eq.java | 115 --
.../tsfile/read/filter/operator/GroupByFilter.java | 155 ++
.../read/filter/operator/GroupByMonthFilter.java | 270 +++
.../iotdb/tsfile/read/filter/operator/Gt.java | 113 --
.../iotdb/tsfile/read/filter/operator/GtEq.java | 113 --
.../iotdb/tsfile/read/filter/operator/In.java | 153 --
.../iotdb/tsfile/read/filter/operator/Like.java | 201 --
.../iotdb/tsfile/read/filter/operator/Lt.java | 113 --
.../iotdb/tsfile/read/filter/operator/LtEq.java | 113 --
.../iotdb/tsfile/read/filter/operator/Not.java | 159 ++
.../iotdb/tsfile/read/filter/operator/NotEq.java | 115 --
.../tsfile/read/filter/operator/NotFilter.java | 151 --
.../iotdb/tsfile/read/filter/operator/Or.java | 185 ++
.../tsfile/read/filter/operator/OrFilter.java | 153 --
.../iotdb/tsfile/read/filter/operator/Regexp.java | 199 --
.../read/filter/operator/TimeFilterOperators.java | 601 ++++++
.../read/filter/operator/ValueFilterOperators.java | 954 +++++++++
.../tsfile/read/reader/IAlignedPageReader.java | 29 -
.../iotdb/tsfile/read/reader/IPageReader.java | 9 +-
.../read/reader/chunk/AbstractChunkReader.java | 83 +
.../read/reader/chunk/AlignedChunkReader.java | 474 ++---
.../tsfile/read/reader/chunk/ChunkReader.java | 239 +--
.../tsfile/read/reader/page/AlignedPageReader.java | 488 +++--
.../iotdb/tsfile/read/reader/page/PageReader.java | 404 ++--
.../tsfile/read/reader/page/ValuePageReader.java | 131 +-
.../reader/series/AbstractFileSeriesReader.java | 16 +-
.../read/reader/series/EmptyFileSeriesReader.java | 4 +-
.../read/reader/series/FileSeriesReader.java | 6 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 4 +-
.../read/reader/series/PaginationController.java | 1 -
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 10 +
.../apache/iotdb/tsfile/utils/Preconditions.java | 39 +
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 55 +-
.../org/apache/iotdb/tsfile/utils/RegexUtils.java | 92 +
.../apache/iotdb/tsfile/utils/TimeDuration.java | 93 +-
.../iotdb/tsfile/common/block/TsBlockTest.java | 77 +
.../file/metadata/TimeseriesMetadataTest.java | 34 +-
.../tsfile/file/metadata/utils/TestHelper.java | 4 +-
.../apache/iotdb/tsfile/read/ExpressionTest.java | 36 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 8 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 60 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 64 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 66 +-
.../apache/iotdb/tsfile/read/common/PathTest.java | 32 +
.../tsfile/read/filter/FilterSerializeTest.java | 92 +-
.../iotdb/tsfile/read/filter/FilterTestUtil.java | 105 +
.../tsfile/read/filter/GroupByFilterTest.java | 33 +-
.../tsfile/read/filter/GroupByMonthFilterTest.java | 88 +-
.../read/filter/IExpressionOptimizerTest.java | 81 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 75 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 93 +-
.../filter/PredicateRemoveNotRewriterTest.java | 109 +-
.../tsfile/read/filter/StatisticsFilterTest.java | 300 ++-
.../read/query/executor/QueryExecutorTest.java | 11 +-
.../read/query/timegenerator/ReadWriteTest.java | 10 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 10 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 10 +-
.../query/timegenerator/TimeGeneratorTest.java | 10 +-
.../read/reader/AlignedPageReaderPushDownTest.java | 322 +++
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 4 +-
.../tsfile/read/reader/PageReaderPushDownTest.java | 145 ++
.../iotdb/tsfile/read/reader/PageReaderTest.java | 6 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 8 +-
.../iotdb/tsfile/utils/TimeDurationTest.java | 40 +-
.../tsfile/write/TsFileIntegrityCheckingTool.java | 7 +-
iotdb-doap.rdf | 33 +
.../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 52 -
.../src/main/thrift/confignode.thrift | 52 +-
.../src/main/thrift/datanode.thrift | 8 +-
pom.xml | 22 +-
1044 files changed, 46104 insertions(+), 25022 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterStartIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/GrafanaApiServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRestServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedOffsetLimitPushDownIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/PipeEnvironmentException.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/AbstractPipeDualIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeDataSinkIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeExtractorIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProcessorIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/extractor/IoTDBPipeExtractorIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/UpdateClusterIdPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/PipeEnrichedPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterManager.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/CopySetRegionGroupAllocator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRegionGroupAllocator.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/PipeManager.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/PipeConfigNodeAgent.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipeConfigRegionConnectorConstructor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipeConfigRegionExtractorConstructor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipeConfigRegionProcessorConstructor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipePluginConfigNodeAgent.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeTaskConfigNodeAgent.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/IoTDBConfigRegionConnector.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/payload/request/PipeTransferConfigPlanReq.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/PipeManager.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/plugin/PipePluginCoordinator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeHeartbeatParser.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeHeartbeatScheduler.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeLeaderChangeHandler.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeMetaSyncer.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeRuntimeCoordinator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLock.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtask.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtaskExecutor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/IoTDBConfigRegionExtractor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeMetrics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeProcedureMetrics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeTaskInfoMetrics.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/plugin/PipePluginCoordinator.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeHeartbeatParser.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeHeartbeatScheduler.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeLeaderChangeHandler.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeMetaSyncer.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeRuntimeCoordinator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTask.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTaskBuilder.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTaskStage.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeTaskCoordinator.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeTaskCoordinatorLock.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ClusterInfo.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRegionGroupAllocatorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/connector/IoTDBConfigRegionConnectorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtaskExecutorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/IoTDBConfigRegionExtractorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterInfoTest.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisReadUnavailableException.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisUnderRecoveryException.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeExtractorConstructor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipePluginAgent.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipePluginConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipePluginDataNodeAgent.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeProcessorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/PipeDataRegionConnectorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/PipeDataRegionExtractorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/PipeDataRegionPluginAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/PipeDataRegionProcessorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/PipeSchemaRegionConnectorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/PipeSchemaRegionExtractorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/PipeSchemaRegionPluginAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/PipeSchemaRegionProcessorConstructor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/SimpleConsensusProgressIndexAssigner.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskDataNodeAgent.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/commit/PipeEventCommitManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/commit/PipeEventCommitter.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeConnectorConstant.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeExtractorConstant.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeProcessorConstant.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/configuraion/PipeTaskRuntimeConfiguration.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskConnectorRuntimeEnvironment.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskExtractorRuntimeEnvironment.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/PipeRequestType.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferSchemaPlanReq.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/IoTDBConnector.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/IoTDBConnectorRequestVersion.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBThriftSyncConnectorClient.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/dataregion/PipeDataRegionAssignerSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/dataregion/PipeDataRegionConnectorSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/dataregion/PipeDataRegionProcessorSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/schemaregion/PipeSchemaRegionAssignerSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/schemaregion/PipeSchemaRegionConnectorSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/schemaregion/PipeSchemaRegionProcessorSubtaskExecutor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeSubtaskScheduler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/IoTDBSchemaRegionExtractor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataRegionEventCounter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeEventCommitMetrics.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeEventCounter.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/DownSamplingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/PartialPathLastTimeCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/progress/assigner/SimpleConsensusProgressIndexAssigner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/progress/committer/PipeEventCommitManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/progress/committer/PipeEventCommitter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipePlanToStatementVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeighUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/tsfile/PipeTsFileResource.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/PipeBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/PipeDataNodeTask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/PipeTask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/PipeTaskBuilder.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/PipeTaskManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/builder/PipeDataNodeBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/builder/PipeDataNodeTaskBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/builder/PipeDataNodeTaskDataRegionBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/builder/PipeDataNodeTaskSchemaRegionBuilder.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/BlockingPendingQueue.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/BoundedBlockingPendingQueue.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/EventSupplier.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/UnboundedBlockingPendingQueue.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskStage.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/DecoratingLock.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeDataNodeSubtask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeSubtask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryStatistics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/ColumnInjectOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/FileLoaderUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/PredicateUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterIdTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/other/GroupByTimeExpression.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ConvertPredicateToTimeFilterVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/PredicateVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ReversePredicateVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/ColumnInjectionPushDown.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedConfigSchemaNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedInsertNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedWriteSchemaNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/ColumnInjectNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/PipeEnrichedInsertNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedLoadTsFileStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/ShowClusterIdStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/pipe/PipeEnrichedStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/impl/DatabaseDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/impl/DeviceMNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/PBTreeFactory.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/StampedWriterPreferredLock.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/CacheEntry.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/CacheManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/CacheMemoryManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/ICacheManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/LRUCacheManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/PlainCacheManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/flush/Scheduler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/lock/LockEntry.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/lock/LockManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/lock/StampedWriterPreferredLock.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memcontrol/MemManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memcontrol/MemoryStatistics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/IMemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/MemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/ReleaseFlushMonitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/buffer/INodeBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/buffer/NodeBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/cache/CacheEntry.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/cache/INodeCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/cache/LRUNodeCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/cache/PlainNodeCache.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/impl/CachedDatabaseDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/impl/CachedDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/Segment.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/CompactionLastTimeCheckFailedException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/element/AlignedPageElement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/element/NonAlignedPageElement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/reader/CompactionAlignedChunkReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/reader/CompactionChunkReader.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/FileLoaderUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/ColumnGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/ColumnGeneratorType.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/SlidingTimeColumnGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/parameter/ColumnGeneratorParameter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/parameter/SlidingTimeColumnGeneratorParameter.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachineTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/MonitorTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/PipePluginAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/PipePluginDataNodeAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/connector/PipeDataNodeThriftRequestTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/connector/PipeThriftRequestTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/other/CaseWhenThenExpressionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/ConvertPredicateToTimeFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/PredicateRemoveNotTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/serde/CaseWhenThenExpressionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/optimization/ColumnInjectionPushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/optimization/OptimizationTestUtil.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionOverlapCheckTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/AlignedMemPageReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/MemPageReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AbstractAlignedSeriesScanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AbstractSeriesScanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AlignedSeriesScanPredicatePushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AlignedSingleColumnSeriesScanLimitOffsetPushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/SeriesScanPredicatePushDownTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipeConnectorConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipeExtractorConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipePluginAgent.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipePluginConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipeProcessorConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTaskAgent.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeConnectorConstant.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeExtractorConstant.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeProcessorConstant.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/configuraion/PipeTaskRuntimeConfiguration.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskConnectorRuntimeEnvironment.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskExtractorRuntimeEnvironment.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskProcessorRuntimeEnvironment.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskTemporaryRuntimeEnvironment.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/IoTDBThriftSyncConnectorClient.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/IoTDBConnectorRequestVersion.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/PipeRequestType.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/PipeTransferSnapshotPieceReq.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/PipeTransferSnapshotSealReq.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/TransferConfigPlanReq.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/response/PipeTransferSnapshotPieceResp.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/ConcurrentIterableLinkedQueue.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/execution/executor/PipeSubtaskExecutor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/execution/scheduler/PipeSubtaskScheduler.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/metric/PipeEventCounter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/metric/PipeFakeEventCounter.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/DoNothingConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBAirGapConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBLegacyPipeConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftAsyncConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftSyncConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/OpcUaConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/WebSocketConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/WriteBackConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/donothing/DoNothingConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/IoTDBConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/airgap/IoTDBAirGapConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBLegacyPipeConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBMetaConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBSchemaRegionConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftAsyncConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSslConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSyncConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/opcua/OpcUaConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/websocket/WebSocketConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/writeback/WriteBackConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/extractor/IoTDBExtractor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/extractor/donothing/DoNothingExtractor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/extractor/iotdb/IoTDBExtractor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/extractor/iotdb/IoTDBMetaExtractor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/DoNothingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/PlaceHolderProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/donothing/DoNothingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/DownSamplingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/DecoratingLock.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/EventSupplier.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/PipeTask.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/PipeTaskManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/connection/BlockingPendingQueue.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/connection/BoundedBlockingPendingQueue.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/connection/UnboundedBlockingPendingQueue.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/stage/PipeTaskStage.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/subtask/PipeSubtask.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/TemplateFilter.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractDatabaseDeviceMNode.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractDeviceMNode.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/DeviceMNodeWrapper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/role/IInternalMNode.java
delete mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/PipeMetaDeSerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/ConcurrentIterableLinkedQueueTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/task/meta/PipeMetaDeSerTest.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/IMetadata.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/GroupByFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/GroupByMonthFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/TimeFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/ValueFilter.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/BinaryFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/BinaryLogicalFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/DisableStatisticsTimeFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/DisableStatisticsValueFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/OperatorType.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/TimeFilter.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/UnaryFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/ValueFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterSerializeId.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/TimeFilterApi.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/ValueFilterApi.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/And.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/AndFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Between.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Eq.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/GroupByFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/GroupByMonthFilter.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Gt.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/GtEq.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/In.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Like.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Lt.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/LtEq.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Not.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/NotEq.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/NotFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Or.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/OrFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Regexp.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/TimeFilterOperators.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/ValueFilterOperators.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/IAlignedPageReader.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AbstractChunkReader.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/Preconditions.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/RegexUtils.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/FilterTestUtil.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/AlignedPageReaderPushDownTest.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/PageReaderPushDownTest.java
