This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/master/net.minidev-json-smart-2.5.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 8dded237731 Bump net.minidev:json-smart from 2.5.0 to 2.5.1
add 996ce09753b Bump ratis version from 3.1.0 to 3.1.1-0133c90-SNAPSHOT
#13357
add b0501ae6eda Pipe IT: Avoid IoTDBPipeTypeConversionIT from creating too
many DataRegions and SchemaRegions (#13378)
add 71f765b727c Pipe: add timely consistency check for pipe memory control
(#13354)
add 08fc8abe247 Pipe: better memory control for in-memory tablets (#13301)
add f56f388fbbe Pipe IT: req size automatic fragmentation integration test
(#13342)
add 37c58c82840 Pipe: avoid logging warn when clearing event ref after
releasing the event & minor improve for javadoc (#13371)
add ed9d6c0da8b Update iotdb client example reference (#13386)
add 334c457438b Pipe: Fixed the bug that OPCUASink's model effect is
reverted (#13377)
add 9460661d256 Fix WAL Exception catch & support new DataTypes in
QueryDataSetUtils (#13359)
add 0d9fc3a8801 Add query metrics for table model
add 64cf3844c02 Change FileTimeIndexCache to region level (#13353)
add 91f5c6ca921 Fix IoTDBSetConfigurationIT.setClusterNameTest (wait
DataNode's restarting for more time, and slow down requesting frequency) #13373
add aaa72b1161a Fix cpp client IT on macos (#13392)
add 7f6211e80c9 Remove unnecessary type cast log (#13391)
add 0f6e0d6c7a2 PruneColumn firstly in RelationPlanner
add 51ee13be2da AINode: Introduce IT framework (#13387)
add 6692075e368 Fix deserialize logic for DeleteDataNode (#13370)
add b9cc8f90591 Fix/removed ip option from config node remove script
(#13402)
add eb6a5d37af2 fix the error usage of HierarchyFieldIndex
add 380b0b4e0e4 FreeMarker code generation for mathematical functions and
operators
add a43c0e3ac74 fix bug (#13396)
add 271270fa776 Fix default authentication of C++ Client (#13363)
add 6b5aa85d762 Bump torch from 2.1.0 to 2.2.0 in /iotdb-core/ainode
(#13336)
add 27f90650fe8 Fix query stuck caused by restarting DN while doing query
add beabc195167 Pipe: Fix TsFileInsertionDataContainer may generate
ClassCastException (#13415)
add 717c2a71bf4 Subscription: reduce the length of the stringified
subscription event & do not print warn logs for eagerly pollable events (#13405)
add 8aa36e51e01 Introduce JoinNode in logical plan and distributed plan
add 1765f067698 Make status code and error msg be consistent in any case
add 9cef05eecbb Change version to 2.0.0-SNAPSHOT
add 6f5f6a5b7e1 Calculate metadata memory when estimate compaction task
memory (#13404)
add 04fa109aff9 clear AsyncTsFileResourceRecoverTaskList after data region
recoverd (#13412)
add 566b11214b0 Fix error log when drop database or migrate region (#13398)
add 16a6eea2147 modify pom.xml (#13376)
add 62a04dc1676 Properly handle the case where a single IndexedRequest
contains multiple “delete PlanNode” operations on the receiving end of
IoTConsensus. #13418
add bfdbcb1c721 Pipe: Optimized the opc key store behaviour (#13417)
add 8ee9863838b Repair task may create compaction log file twice in
sequence and unsequence dir (#13413)
add 2a015fc4ed8 AINode: Fix restart functionality and enhance error
clarity (#13424)
add d982a220cb4 [Inconsistent copies] Enhance IoTConsensus Retry (#13395)
add 8a2aba23c06 Load: Support remote load in import-tsfile script (#13352)
add c9d6dd977c9 Revert "Load: Support remote load in import-tsfile script
(#13352)" (#13437)
add a660d80c7b9 Fix: remote load in import-tsfile script (#13438)
add 0ac492f362b Support "`" & disable "." in database name
add 2cbd0777ea4 Check decoded page size in compaction (#13380)
add ba944cba052 Automatically trigger CI for active non-committer again
(#13442)
add ba1bac55203 Make the JDK version check in remove-datanode.bat
consistent with other .bat files #13445
add 0be6fdbe545 Pipe: Tolerate the error of listening queues in cluster
restart (#13434)
add cb09e2fdecc Fix table name serialization for table-model insertion
(#13446)
add 47689551c50 Support the pushdown of between predicate to schema region
add d502232b2df Rename IoTDBShutdownHook to DataNodeShutdownHook & Delay
the execution of the “clear lock file” step in DataNodeShutdownHook (#13452)
add 67bee6e3a16 Automatically trigger CI for active non-committer #13450
add 3e882a41d50 Pipe: refactor committer key for event committer after
pipe restart to avoid non-monotonic increase (#13416)
add 74fb62206b8 Fixed the bug that schema related query fails when get
from cache with complicated filter
add 15365ffe363 Allow duplicated column names in table model
add 77ce37f0940 Fix compaction device info cache (#13453)
add b7562e3cd17 fix index out of bound exception in settle compaction task
(#13462)
add 900de3e9098 Pipe: Added conflict detection of params for reusing of
OPCUA server (#13458)
add f43cac5713b Add deserializeFromWAL and related code for
ContinuousSameSearchIndexSeparatorNode (#13464)
add f3b76555802 [Py-Client] Support table model with python client (#13443)
add cfc4eee7c91 AINode: Refined architecture for enhanced modularity &
Added basic IT (#13423)
add 15469a276ff Optimize column batch selection when there are many value
columns (#13456)
add 4aff3bba3f4 [PY-Client] fix python client package issue (#13468)
add 9dd8d3be95c Pipe: Remove and close asynchronous connector manager when
all clients are useless (#13399)
add 2ec74a41a63 Support FE of Aggregation in TableModel
add d4074920d44 Load: modify TsFile version check to enable V3 load to V4
(#13400)
add 453bc7b39cd Remove redundant closing of consensus layer in DataNode
shutdown process (#13478)
add dd900cfa27b Support dictionary encoding for STRING & refactor encoding
support condition (#13474)
add f1d6b3fa4cb trim (#13477)
add 6b43820c134 fix last time check (#13479)
add c4ace325364 Reduce IDeviceID creation in insert process (#13472)
add 13097fe60d6 Automatically trigger CI for active non-committer #13486
add 5ea130120ef Active Load: Fix load_active_listing_enable &
load_active_listing_dirs hot load failure (#13491)
add 006ea2af65a Load: add detailed exception message in rpc returned
status (#13493)
add 1d40792d965 Active Load: Check dir r/w permissions before loading from
listening dirs (#13488)
add 1b7d159d07d Pipe: perform deep copy for incoming progress index when
constructing and updating progress index & fix hash code of progress index
(#13441)
add d962d2967d7 Fix the allocation of target file name in repair data task
(#13490)
add 126fbefb8b8 Fix error in last query with sort + limit
add 72175750334 [Py-Client] support new data types (#13494)
add bc2cc044c91 Pipe: Fix asynchronous connector manager leak when the
receiverAttributes exists on constructing (#13501)
add 5ff214ef313 Pipe: Fixed the bug that certificate cannot be trusted in
OPC UA connector (#13495)
add 80c016a4c31 Active Load: Fix load failures due to memory constraints
not be reloaded (#13505)
add 14057a3cd93 Pipe: Add 'data.delete' & 'realtime-first' conflict check
in PipeParameters (#13433)
add 3f4fa64c5a6 Fix the logic of catch ServerNotReadyException to enable
read retry (#13509)
add 0cd0c874862 Feat/cli disable history (#13461)
add f99509b4705 [Metrics] Fix the grafana panel display error caused by
not initializing trigTime (#13496)
add f227d9ac4d3 Keep all null rows in table model
add 3453796ba2e Fix bug while using NOT IN predicate for INT64 type
add 9ef116528ef Active Load: Fix load_active_listening_max_thread_num or
load_active_listening_check_interval_seconds less than 0 throwing exception
(#13516)
add b21b2cd08af Pipe: rebind progress index to prematurely flushed tsfile
insertion event to avoid data loss when syncing data between clusters (#13483)
add 55998590366 Use CountDownLatch to replace Semaphore in IoTConsensus
log dispatcher closing #13517
add 7a389dd647c Fix memory calculate error when insertRecords with both
aligned and non-aligned devices (#12720)
add 2667d547ac5 Add SKIP as reserved key word
add f1cfc48867d Support database properties in table model
add e07d39daba4 Pipe & IT : Refactor pipe / IT and improved IT behaviour
(#13521)
add b4266d16a87 Pipe: fix event counter decrement operations to avoid
inconsistent final counts (#13520)
add f244e0ed0d8 Fix the bug in using negation for timestamp type
add 6b71f769693 Pipe: Fix data lost when syncing between clusters cause by
senders' data region leader change (#13532)
add 43710fd6efb Pipe: Fix the Out of memory problem in WALInsertNodeCache
memory management under extreme conditions (#13460)
add ebe37680f33 Use consensus read in show table
add 324275f2759 Fix NPE after keeping all null rows in memtable
add 07f14753418 Pipe: Fix startup failure of
PipeHistoricalDataRegionTsFileExtractor due to unprepared StorageEngine (#13526)
add a322ab556a6 Fix the issue of restarting DataNode to clean up
InvalidDataRegion (#13535)
add 6cca2e1b1e1 Fix print a log every time startup and error exception
handling (#13545)
add e5e4980331e Support OFFSET XXX LIMIT XXXX in relational model
add 5387a102543 Modify regionMigrateService's ThreadPool to
IoTThreadPoolFactory.cachedThreadPool (#13548)
add 3f922e72c59 Load: New SQL grammer `LOAD <filePath> with ('k'='v',
...)` (#13466)
add 1940261bdce Fix AINode status error after ConfigNode Leader restarts
#13547
add 68eb91af45b Support print plan when assert fails in PlanMatchPattern
add 598cabe238b Keep all null rows in table model compaction (#13523)
add d7888e84f28 Pipe: eliminate progress index for raw tablet event to
avoid endless rebind (#13542)
add 453cd46c26b Pipe: Fixed the bug that the relative path in
OPCUAConnector security dir is not formulated (#13555)
add b339ba86a47 Pipe: optimize the 'Create Pipe' SQL statement to allow
omitting 'With Sink' when no Source or Processor attributes are defined.
(#13534)
add e48b8b925b5 Pipe / Subscription : Fixed the bug that
TsFileInsertionScanDataContainer may use wrong isMultiPage flag for aligned
chunk when value chunk is not continuous (#13554)
add 3ca3f44aec1 Pipe: make progress index immutable (#13544)
add 0ea84cadb15 Don't print warn log for sort tmp file delete
add a37b0edf12e [IOTDB-6351] Don't retry if operation has already succeed
even if the DN is not running status
add 97e5c353258 Improve like predicate speed
add f87de7f9d25 Pipe: Avoid type conversion if error on receiver is caused
by insufficient memory (#13569)
add 612ccb5b08e Optimized the error message for database containing
illegal characters' creation in table model
add 80b7805e3e4 Subscription IT: explicitly declare `setUp` method for
test class to avoid `UNKNOWN-IT` test class name (#13565)
add 00c9a2a8fb7 Support no measurement columns in the select clause
add 6b17e71bbd9 Add join operator implementation, fix the problem in join
logical planner and distributed planner
add 7ceddaee37d Pipe: Refactor pipe related packages (#13578)
add 697871705ec Refactor: Removed the useless Ser/de logic in configNode
read plans (#13577)
add 5de8dc7a4db IoTConsensusV2: Introduce IoTConsensusV2 and corresponding
mode option (#13440)
add acda1a0f092 Make log dispatcher stop in parallel #13588
add cb4befcbd45 fix bug (#13590)
add 24d1191a8e7 Fix potential NPE when write FileTimeIndexCache (#13583)
add 197965e9ae9 Skip the file timestamp check of tsfiles generated by
repair task (#13581)
add 737c4ccea98 Fix print error log when dir is not exist (#13591)
add 5b22e7b010b Handle commit failure of table procedures
add ed8f61cb38d Update tsfile version to 1.2.0-240924-SNAPSHOT (#13603)
add 1ded38ce5fd Optimized the error log for illegal database names in tree
model
add 98addd823bc Pipe: basic support for table model from SQL to
IConfigTask (#13600)
add 905c2e2af03 Support syntactic sugar of aggregation function last and
first in TableModel (#13596)
add 9dda5d93acf Add CoalesceExpression support
add 9ed645db6cc Pipe: Fix relative path in SSLConnector trustStorePath is
not formulated & Fix inclusion option 'delete' fails to parse (#13580)
add 040dcf18236 Pipe: basic support for table model (a follow-up fix for
#13600) (#13611)
add 1ed2023d01c Fix compaction with all null rows ut (#13610)
add fc6eef2d636 Enhance repair compaction & exception handle with full
disks (#13602)
add 1447d41ccf5 Fix push-down level of global aggregation in TableModel
add d0c0fd76473 Make last_by, first_by with time can push-down in
TableModel
add 8a50d59eb2d Pipe: Added count-point-processor to black list (#13605)
add d5c854d6eb2 Pipe: Fix null output-series device issue in Two-Stage
Processor (#13604)
add 3140521f548 [region migration] Catch Ratis Read InterruptedException
#13612
add 2a31c57398f Fix fill aligned chunk metadata by schema list (#13560)
add 3c1eace43f0 Change the error infomation when insert a timestamp over
Long.MaxValue (#13597)
add dce69e7f3d6 Subscription: register metrics to count the number of pipe
events in sink queue and prefetching queue in subscription task (#13575)
add 59475a6a603 Load: Fix the source parameter of the load tsfile script
cannot specify a file (#13617)
add ee9b752bacc AINode: Correcting the Omissions and Redundancies (#13594)
add 01370932799 Feature/show ainodes command (#13592)
add 99037029548 Fix the error in aggregation merge sort when device
locates in multi data regions
add 734786f09e4 Fixed database names in "show regions" in table model
add 574bbd1b2ba Feature/dependency check (#13587)
add 374deefeb86 Update ConfigPhysicalReadPlan.java (#13624)
add c4f17560624 Pipe: Fixed the bug that different types in schema
snapshot transfer may cause transfer failure (#13627)
add e7a37dc03ab Pipe: Fixed the bug that alter source will not alter the
reference count of ConfigRegionListeningQueue (#13626)
add aa2fc4c326c [RatisConsensus] Bump ratis version to 3.1.1 #13629
add b9a181a1cd9 Fix NodeInfo processLoadSnapshot method (avoid
compatibility issues caused by ainode serialization) (#13622)
add cd3e8af7e47 Make each execution acquire a schema read lock only once
add 43d07b52a25 Support table model insert redirection (#13550)
add 879715174f2 PipePlugin: Add pipe consensus related plugins to
blackList (#13642)
add 8753985882d Pipe: Fix the problem of missing precision when converting
String type to Int32 and int64 types (#13643)
add 85ec9ad9af1 Bump net.minidev:json-smart from 2.5.0 to 2.5.1
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (8dded237731)
\
N -- N -- N
refs/heads/dependabot/maven/master/net.minidev-json-smart-2.5.1 (85ec9ad9af1)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 4 +-
.github/workflows/cluster-it-1c1d1a.yml | 62 +
.github/workflows/dependency-check.yml | 59 +
.github/workflows/multi-language-client.yml | 28 +-
code-coverage/pom.xml | 2 +-
dependencies.json | 167 +++
distribution/pom.xml | 10 +-
example/client-cpp-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/TabletExample.java | 4 +
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
.../java/org/apache/iotdb/udf/UDAFExample.java | 4 +
integration-test/pom.xml | 46 +-
integration-test/src/assembly/mpp-test.xml | 19 +
.../apache/iotdb/db/query/udf/example/UDAFAvg.java | 4 +
.../apache/iotdb/db/query/udf/example/UDAFSum.java | 4 +
.../java/org/apache/iotdb/it/env/EnvFactory.java | 4 +
.../main/java/org/apache/iotdb/it/env/EnvType.java | 1 +
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 11 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 17 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 92 +-
.../it/env/cluster/config/MppCommonConfig.java | 10 +
.../env/cluster/config/MppSharedCommonConfig.java | 8 +
.../org/apache/iotdb/it/env/cluster/env/AIEnv.java | 38 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 435 +++---
.../iotdb/it/env/cluster/env/MultiClusterEnv.java | 8 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 179 +++
.../it/env/cluster/node/AbstractNodeWrapper.java | 14 +-
.../it/env/cluster/node/ConfigNodeWrapper.java | 35 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 32 +-
.../it/env/remote/config/RemoteCommonConfig.java | 6 +
.../apache/iotdb/itbase/category/AIClusterIT.java | 22 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 3 +
.../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 228 ++++
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 9 +
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 100 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBRecoverIT.java | 40 +-
.../apache/iotdb/db/it/IoTDBRecoverUnclosedIT.java | 29 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 3 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 237 ++--
.../aggregation/IoTDBAggregationLargeDataIT.java | 133 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 113 +-
.../iotdb/db/it/aggregation/IoTDBCountIfIT.java | 2 +-
.../iotdb/db/it/aggregation/IoTDBModeIT.java | 2 +-
.../db/it/aggregation/IoTDBTimeDurationIT.java | 2 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 113 ++
.../scalar/IoTDBSubStringFunctionIT.java | 6 +-
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 14 +
.../it/last/IoTDBLastQueryWithLimitOffsetIT.java | 34 +
.../db/it/orderBy/IoTDBOrderByForDebugIT.java | 1406 --------------------
.../apache/iotdb/db/it/path/IoTDBQuotedPathIT.java | 11 +-
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 2 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 8 +-
.../db/it/schema/IoTDBDeleteTimeSeriesIT.java | 52 +-
.../iotdb/db/it/udaf/IoTDBUDAFNormalQueryIT.java | 44 +-
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 6 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 1 +
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 21 +-
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 8 +-
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 20 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 2 +-
.../pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 11 +
.../pipe/it/manual/AbstractPipeDualManualIT.java | 8 +-
.../pipe/it/manual/IoTDBPipeReqAutoSliceIT.java | 482 +++++++
.../pipe/it/manual/IoTDBPipeTypeConversionIT.java | 48 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 56 +-
.../it/db/it/IoTDBInsertAlignedValuesTableIT.java | 36 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 10 +
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 156 ++-
.../it/query/old/IoTDBDatetimeFormatTableIT.java | 4 +-
.../it/query/old/IoTDBNestedQueryTableIT.java | 146 +-
.../alignbydevice/IoTDBAlignByDeviceTableIT.java | 31 +-
.../aligned/IoTDBAlignedSeriesQueryTableIT.java | 20 +
.../old/aligned/IoTDBPredicatePushDownTableIT.java | 402 +++---
.../scalar/IoTDBRoundFunctionTableIT.java | 10 +
.../scalar/IoTDBScalarFunctionTableIT.java | 19 +-
.../scalar/IoTDBSubStringFunctionTableIT.java | 2 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 6 +-
.../it/query/old/query/IoTDBArithmeticTableIT.java | 342 +++--
.../it/query/old/query/IoTDBPaginationTableIT.java | 39 +-
.../it/query/recent/IoTDBNullIdQueryIT.java | 278 ++++
.../relational/it/schema/IoTDBDatabaseIT.java | 156 ++-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 11 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 4 +-
.../pool/IoTDBInsertTableSessionPoolIT.java | 245 ++++
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 76 ++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 22 +-
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 7 +
.../it/dual/IoTDBSubscriptionTopicIT.java | 7 +
.../it/local/IoTDBSubscriptionBasicIT.java | 7 +
.../it/local/IoTDBSubscriptionDataTypeIT.java | 7 +
.../it/local/IoTDBSubscriptionIdempotentIT.java | 7 +
.../it/local/IoTDBSubscriptionTopicIT.java | 17 +-
.../param/IoTDBTestParamSubscriptionSessionIT.java | 7 +
.../src/test/resources/ainode-example/config.yaml | 5 +
.../src/test/resources/ainode-example/model.pt | Bin 0 -> 1906 bytes
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
.../configuration/PipeRuntimeEnvironment.java | 2 +
.../api/customizer/parameter/PipeParameters.java | 4 +
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
iotdb-client/cli/pom.xml | 28 +-
.../cli/src/assembly/resources/tools/backup.bat | 2 +-
.../cli/src/assembly/resources/tools/backup.sh | 2 +-
.../src/assembly/resources/tools/export-data.bat | 2 +-
.../src/assembly/resources/tools/export-data.sh | 2 +-
.../src/assembly/resources/tools/export-schema.bat | 2 +-
.../src/assembly/resources/tools/export-schema.sh | 2 +-
.../src/assembly/resources/tools/export-tsfile.bat | 2 +-
.../src/assembly/resources/tools/export-tsfile.sh | 2 +-
.../src/assembly/resources/tools/import-data.bat | 2 +-
.../src/assembly/resources/tools/import-data.sh | 2 +-
.../src/assembly/resources/tools/import-schema.bat | 2 +-
.../src/assembly/resources/tools/import-schema.sh | 2 +-
.../src/assembly/resources/tools/load-tsfile.bat | 2 +-
.../src/assembly/resources/tools/load-tsfile.sh | 2 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 4 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 8 +-
.../org/apache/iotdb/cli/utils/CliContext.java | 16 +
.../org/apache/iotdb/tool/AbstractDataTool.java | 304 -----
.../org/apache/iotdb/tool/AbstractSchemaTool.java | 242 ----
.../org/apache/iotdb/tool/AbstractTsFileTool.java | 144 --
.../java/org/apache/iotdb/tool/ExportData.java | 589 --------
.../java/org/apache/iotdb/tool/ExportSchema.java | 339 -----
.../java/org/apache/iotdb/tool/ExportTsFile.java | 424 ------
.../java/org/apache/iotdb/tool/ImportData.java | 1069 ---------------
.../java/org/apache/iotdb/tool/ImportSchema.java | 647 ---------
.../java/org/apache/iotdb/tool/ImportTsFile.java | 580 --------
.../org/apache/iotdb/tool/IoTDBDataBackTool.java | 1150 ----------------
.../iotdb/tool/backup/IoTDBDataBackTool.java | 1151 ++++++++++++++++
.../apache/iotdb/tool/data/AbstractDataTool.java | 304 +++++
.../org/apache/iotdb/tool/data/ExportData.java | 589 ++++++++
.../org/apache/iotdb/tool/data/ImportData.java | 1072 +++++++++++++++
.../iotdb/tool/schema/AbstractSchemaTool.java | 242 ++++
.../org/apache/iotdb/tool/schema/ExportSchema.java | 339 +++++
.../org/apache/iotdb/tool/schema/ImportSchema.java | 647 +++++++++
.../iotdb/tool/tsfile/AbstractTsFileTool.java | 144 ++
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 424 ++++++
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 396 ++++++
.../apache/iotdb/tool/tsfile/ImportTsFileBase.java | 243 ++++
.../iotdb/tool/tsfile/ImportTsFileLocally.java | 53 +
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 338 +++++
.../iotdb/tool/tsfile/ImportTsFileScanTool.java | 97 ++
.../org/apache/iotdb/tool/WriteDataFileTest.java | 2 +
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-cpp/src/main/Session.h | 2 +-
iotdb-client/client-py/README.md | 2 +-
iotdb-client/client-py/SessionExample.py | 53 +-
iotdb-client/client-py/TableModelSessionExample.py | 154 +++
.../client-py/TableModelSessionPoolExample.py | 160 +++
iotdb-client/client-py/iotdb/Session.py | 144 +-
iotdb-client/client-py/iotdb/SessionPool.py | 11 +
.../client-py/iotdb/tsfile/utils/DateUtils.py | 41 +
iotdb-client/client-py/iotdb/utils/Field.py | 49 +-
.../client-py/iotdb/utils/IoTDBConstants.py | 11 +-
.../client-py/iotdb/utils/IoTDBRpcDataSet.py | 95 +-
iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 84 +-
iotdb-client/client-py/iotdb/utils/RowRecord.py | 8 +-
.../client-py/iotdb/utils/SessionDataSet.py | 24 +-
iotdb-client/client-py/iotdb/utils/Tablet.py | 106 +-
iotdb-client/client-py/pom.xml | 8 +-
iotdb-client/client-py/release.sh | 1 +
.../tests/integration/test_new_data_types.py | 157 +++
.../tests/integration/test_relational_session.py | 143 ++
iotdb-client/isession/pom.xml | 8 +-
.../org/apache/iotdb/isession/IPooledSession.java | 1 +
.../java/org/apache/iotdb/isession/ISession.java | 9 +
.../org/apache/iotdb/isession/SessionDataSet.java | 34 +-
iotdb-client/jdbc/pom.xml | 8 +-
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 4 +
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 42 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 6 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 6 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 9 +
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 443 +++---
.../org/apache/iotdb/rpc/RedirectException.java | 15 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 17 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
iotdb-client/session/pom.xml | 10 +-
.../java/org/apache/iotdb/session/Session.java | 216 ++-
.../apache/iotdb/session/SessionConnection.java | 19 +-
.../org/apache/iotdb/session/ThriftConnection.java | 3 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 22 +-
.../apache/iotdb/session/pool/SessionWrapper.java | 8 +-
.../iotdb/session/SessionCacheLeaderTest.java | 271 +++-
.../iotdb/session/SessionConnectionTest.java | 2 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 10 +-
iotdb-core/ainode/iotdb/ainode/attribute.py | 669 ----------
iotdb-core/ainode/iotdb/ainode/client.py | 225 +---
iotdb-core/ainode/iotdb/ainode/config.py | 240 ++--
iotdb-core/ainode/iotdb/ainode/constant.py | 1 -
iotdb-core/ainode/iotdb/ainode/encryption.py | 17 -
iotdb-core/ainode/iotdb/ainode/exception.py | 23 +-
iotdb-core/ainode/iotdb/ainode/factory.py | 272 ----
iotdb-core/ainode/iotdb/ainode/handler.py | 105 +-
iotdb-core/ainode/iotdb/ainode/inference.py | 165 ---
iotdb-core/ainode/iotdb/ainode/log.py | 45 +-
.../ainode/iotdb/ainode/manager}/__init__.py | 0
.../ainode/iotdb/ainode/manager/cluster_manager.py | 41 +
.../iotdb/ainode/manager/inference_manager.py | 209 +++
.../ainode/iotdb/ainode/manager/model_manager.py | 84 ++
.../ainode/iotdb/ainode/model}/__init__.py | 0
.../iotdb/ainode/model/built_in_model_factory.py | 924 +++++++++++++
.../ainode/iotdb/ainode/model/model_factory.py | 237 ++++
.../ainode/iotdb/ainode/model/model_storage.py | 113 ++
iotdb-core/ainode/iotdb/ainode/parser.py | 191 ---
iotdb-core/ainode/iotdb/ainode/script.py | 177 ++-
iotdb-core/ainode/iotdb/ainode/service.py | 100 +-
iotdb-core/ainode/iotdb/ainode/storage.py | 318 -----
iotdb-core/ainode/iotdb/ainode/util.py | 79 --
.../ainode/iotdb/ainode/util}/__init__.py | 0
iotdb-core/ainode/iotdb/ainode/util/decorator.py | 26 +
iotdb-core/ainode/iotdb/ainode/util/lock.py | 84 ++
iotdb-core/ainode/iotdb/ainode/{ => util}/serde.py | 0
iotdb-core/ainode/iotdb/ainode/util/status.py | 33 +
iotdb-core/ainode/poetry.lock | 229 +++-
iotdb-core/ainode/pom.xml | 10 +-
iotdb-core/ainode/pyproject.toml | 4 +-
.../ainode/resources/conf/iotdb-ainode.properties | 8 +-
iotdb-core/antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 22 +-
iotdb-core/confignode/pom.xml | 26 +-
.../assembly/resources/sbin/remove-confignode.bat | 2 -
.../assembly/resources/sbin/remove-confignode.sh | 2 -
.../iotdb/confignode/conf/ConfigNodeConfig.java | 12 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../consensus/request/ConfigPhysicalPlan.java | 198 +--
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../request/ConfigPhysicalPlanVisitor.java | 2 +-
.../consensus/request/auth/AuthorPlan.java | 313 -----
.../request/read/ConfigPhysicalReadPlan.java | 44 +
.../read/ainode/GetAINodeConfigurationPlan.java | 12 +-
.../request/read/auth/AuthorReadPlan.java | 143 ++
.../consensus/request/read/cq/ShowCQPlan.java | 31 +
.../request/read/database/CountDatabasePlan.java | 51 +-
.../request/read/database/GetDatabasePlan.java | 6 +-
.../datanode/GetDataNodeConfigurationPlan.java | 30 +-
.../read/function/GetFunctionTablePlan.java | 18 +-
.../request/read/function/GetUDFJarPlan.java | 42 +-
.../request/read/model/GetModelInfoPlan.java | 10 +-
.../request/read/model/ShowModelPlan.java | 10 +-
.../read/partition/CountTimeSlotListPlan.java | 49 +-
.../read/partition/GetDataPartitionPlan.java | 66 +-
.../read/partition/GetNodePathsPartitionPlan.java | 33 +-
.../partition/GetOrCreateDataPartitionPlan.java | 10 +-
.../partition/GetOrCreateSchemaPartitionPlan.java | 3 +-
.../read/partition/GetSchemaPartitionPlan.java | 58 +-
.../read/partition/GetSeriesSlotListPlan.java | 36 +-
.../read/partition/GetTimeSlotListPlan.java | 49 +-
.../read/pipe/plugin/GetPipePluginJarPlan.java | 37 +-
.../read/pipe/plugin/GetPipePluginTablePlan.java | 18 +-
.../request/read/pipe/task/ShowPipePlanV2.java | 18 +-
.../request/read/region/GetRegionIdPlan.java | 49 +-
.../request/read/region/GetRegionInfoListPlan.java | 47 +-
.../read/subscription/ShowSubscriptionPlan.java | 18 +-
.../request/read/subscription/ShowTopicPlan.java | 18 +-
.../request/read/table/FetchTablePlan.java | 40 +
.../request/read/table/ShowTablePlan.java | 37 +
.../read/template/CheckTemplateSettablePlan.java | 33 +-
.../read/template/GetAllSchemaTemplatePlan.java | 16 +-
.../read/template/GetAllTemplateSetInfoPlan.java | 16 +-
.../read/template/GetPathsSetTemplatePlan.java | 33 +-
.../read/template/GetSchemaTemplatePlan.java | 32 +-
.../read/template/GetTemplateSetInfoPlan.java | 37 +-
.../read/trigger/GetTransferringTriggersPlan.java | 18 +-
.../request/read/trigger/GetTriggerJarPlan.java | 42 +-
.../read/trigger/GetTriggerLocationPlan.java | 38 +-
.../request/read/trigger/GetTriggerTablePlan.java | 38 +-
.../consensus/request/read/ttl/ShowTTLPlan.java | 19 +-
.../consensus/request/write/auth/AuthorPlan.java | 246 ++++
.../consensus/request/write/cq/ShowCQPlan.java | 45 -
.../write/partition/RemoveRegionLocationPlan.java | 5 -
.../write/pipe/plugin/CreatePipePluginPlan.java | 2 +-
.../pipe/runtime/PipeHandleMetaChangePlan.java | 2 +-
.../request/write/pipe/task/AlterPipePlanV2.java | 4 +-
.../request/write/pipe/task/CreatePipePlanV2.java | 4 +-
.../write/pipe/task/SetPipeStatusPlanV2.java | 2 +-
.../request/write/sync/ShowPipePlanV1.java | 59 -
.../response/pipe/plugin/PipePluginTableResp.java | 2 +-
.../response/pipe/task/PipeTableResp.java | 68 +-
.../consensus/response/table/FetchTableResp.java | 44 +
.../consensus/response/table/ShowTableResp.java | 41 +
.../statemachine/ConfigRegionStateMachine.java | 22 +-
.../iotdb/confignode/manager/ConfigManager.java | 80 +-
.../apache/iotdb/confignode/manager/IManager.java | 11 +-
.../iotdb/confignode/manager/ModelManager.java | 10 +-
.../confignode/manager/PermissionManager.java | 9 +-
.../iotdb/confignode/manager/ProcedureManager.java | 20 +-
.../manager/consensus/ConsensusManager.java | 3 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../manager/load/balancer/RouteBalancer.java | 3 -
.../confignode/manager/load/cache/LoadCache.java | 14 +-
.../manager/node/ClusterNodeStartUtils.java | 26 +
.../manager/partition/PartitionManager.java | 16 +-
.../agent/plugin/PipeConfigNodePluginAgent.java | 8 +-
.../PipeConfigRegionConnectorConstructor.java | 6 +-
.../PipeConfigRegionExtractorConstructor.java | 6 +-
.../PipeConfigRegionProcessorConstructor.java | 6 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 15 +-
.../agent/runtime/PipeConfigRegionListener.java | 7 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 265 ++++
.../agent/task/PipeConfigNodeSubtaskExecutor.java | 52 +
.../pipe/agent/task/PipeConfigNodeTask.java | 51 +
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 11 +-
.../pipe/agent/task/PipeConfigNodeTaskBuilder.java | 71 +
.../pipe/agent/task/PipeConfigNodeTaskStage.java | 76 ++
.../protocol/IoTDBConfigRegionConnector.java | 3 +-
.../coordinator/plugin/PipePluginCoordinator.java | 2 +-
.../runtime/heartbeat/PipeHeartbeat.java | 4 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 12 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 6 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 4 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 4 +-
.../pipe/execution/PipeConfigNodeSubtask.java | 265 ----
.../execution/PipeConfigNodeSubtaskExecutor.java | 52 -
.../pipe/extractor/ConfigRegionListeningQueue.java | 19 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 2 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 4 +-
.../metric/PipeConfigNodeRemainingTimeMetrics.java | 2 +-
.../PipeConfigNodeRemainingTimeOperator.java | 2 +-
.../metric/PipeConfigRegionConnectorMetrics.java | 2 +-
.../pipe/metric/PipeTemporaryMetaMetrics.java | 4 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 6 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 2 +-
.../PipeConfigNodeCopiedFileDirStartupCleaner.java | 2 +-
.../resource/PipeConfigNodeResourceManager.java | 3 +-
.../PipeConfigNodeSnapshotResourceManager.java | 33 +
.../PipeConfigNodeSnapshotResourceManager.java | 33 -
.../manager/pipe/task/PipeConfigNodeTask.java | 51 -
.../pipe/task/PipeConfigNodeTaskBuilder.java | 71 -
.../manager/pipe/task/PipeConfigNodeTaskStage.java | 78 --
.../manager/schema/ClusterSchemaManager.java | 33 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 53 +-
.../persistence/executor/ConfigPlanExecutor.java | 20 +-
.../confignode/persistence/node/NodeInfo.java | 33 +-
.../confignode/persistence/pipe/PipeInfo.java | 37 +-
.../persistence/pipe/PipePluginInfo.java | 12 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 20 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 273 ++--
.../confignode/persistence/schema/ConfigMTree.java | 17 +
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 2 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 2 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 10 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 10 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 2 +-
.../impl/schema/table/AddTableColumnProcedure.java | 1 -
.../impl/schema/table/CreateTableProcedure.java | 1 -
.../schema/table/SetTablePropertiesProcedure.java | 1 -
...bstractOperateSubscriptionAndPipeProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 2 +-
.../subscription/DropSubscriptionProcedure.java | 2 +-
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 23 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 681 ++--------
.../response/pipe/PipePluginTableRespTest.java | 6 +-
.../consensus/response/pipe/PipeTableRespTest.java | 8 +-
.../agent/PipeConfigNodeSubtaskExecutorTest.java | 186 +++
.../connector/IoTDBConfigRegionConnectorTest.java | 2 +-
.../PipeConfigNodeSubtaskExecutorTest.java | 184 ---
...eConfigPhysicalPlanPatternParseVisitorTest.java | 4 +-
.../confignode/persistence/AuthorInfoTest.java | 82 +-
.../persistence/CNPhysicalPlanGeneratorTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 10 +-
.../pipe/plugin/CreatePipePluginProcedureTest.java | 2 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../impl/sync/AuthOperationProcedureTest.java | 29 +-
iotdb-core/consensus/pom.xml | 14 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 23 +-
.../consensus/config/PipeConsensusConfig.java | 28 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +
.../consensus/iot/client/DispatchLogHandler.java | 41 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 19 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 2 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeName.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeSelector.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 15 +
iotdb-core/datanode/pom.xml | 40 +-
.../assembly/resources/sbin/remove-datanode.bat | 12 +-
iotdb-core/datanode/src/main/codegen/config.fmpp | 4 +-
.../codegen/dataModel/MathematicalDataType.tdd | 52 +
.../codegen/dataModel/MathematicalOperator.tdd | 52 +
.../ArithmeticBinaryColumnTransformer.ftl | 301 +++++
.../templates/ArithmeticColumnTransformerApi.ftl | 225 ++++
.../templates/ArithmeticUnaryColumnTransformer.ftl | 67 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 102 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 99 +-
.../db/consensus/DataRegionConsensusImpl.java | 6 +-
.../dataregion/DataExecutionVisitor.java | 8 +-
.../dataregion/DataRegionStateMachine.java | 57 +-
.../IoTConsensusDataRegionStateMachine.java | 4 +-
.../schemaregion/SchemaExecutionVisitor.java | 12 +
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 10 +-
.../PipeDataRegionConnectorConstructor.java | 8 +-
.../PipeDataRegionExtractorConstructor.java | 8 +-
.../dataregion/PipeDataRegionPluginAgent.java | 10 +-
.../PipeDataRegionProcessorConstructor.java | 10 +-
.../PipeSchemaRegionConnectorConstructor.java | 6 +-
.../PipeSchemaRegionExtractorConstructor.java | 6 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 8 +-
.../PipeSchemaRegionProcessorConstructor.java | 6 +-
.../agent/receiver/PipeDataNodeReceiverAgent.java | 2 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 8 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +-
.../runtime/PipeSchemaRegionListenerManager.java | 2 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 118 ++
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 123 ++
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 17 +-
.../agent/task/builder/PipeDataNodeBuilder.java | 85 ++
.../task/builder/PipeDataNodeTaskBuilder.java | 195 +++
.../pipe/agent/task/connection/EnrichedDeque.java | 87 ++
.../agent/task/connection/PipeEventCollector.java | 210 +++
.../execution/PipeConnectorSubtaskExecutor.java | 38 +
.../execution/PipeProcessorSubtaskExecutor.java | 34 +
.../task/execution/PipeSubtaskExecutorManager.java | 70 +
.../agent/task/stage/PipeTaskConnectorStage.java | 89 ++
.../agent/task/stage/PipeTaskExtractorStage.java | 111 ++
.../agent/task/stage/PipeTaskProcessorStage.java | 136 ++
.../subtask/connector/PipeConnectorSubtask.java | 340 +++++
.../connector/PipeConnectorSubtaskLifeCycle.java | 156 +++
.../connector/PipeConnectorSubtaskManager.java | 255 ++++
.../PipeRealtimePriorityBlockingQueue.java | 202 +++
.../subtask/processor/PipeProcessorSubtask.java | 299 +++++
.../processor/PipeProcessorSubtaskWorker.java | 129 ++
.../PipeProcessorSubtaskWorkerManager.java | 51 +
.../client/IoTDBDataNodeAsyncClientManager.java | 39 +-
.../client/IoTDBDataNodeSyncClientManager.java | 26 +-
.../evolvable/batch/PipeTabletEventBatch.java | 4 +-
.../batch/PipeTransferBatchReqBuilder.java | 6 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 12 +-
.../connector/protocol/opcua/OpcUaConnector.java | 70 +-
.../protocol/opcua/OpcUaKeyStoreLoader.java | 36 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 19 +-
.../protocol/opcua/OpcUaServerBuilder.java | 196 +--
.../pipeconsensus/PipeConsensusAsyncConnector.java | 15 +-
.../async/IoTDBDataRegionAsyncConnector.java | 17 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 3 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 4 +-
.../consensus/PipeConsensusSubtaskExecutor.java | 2 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 4 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 15 +
.../db/pipe/event/common/row/PipeRowCollector.java | 16 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 4 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 10 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 16 +-
.../tablet/TabletInsertionDataContainer.java | 8 +-
.../event/common/terminate/PipeTerminateEvent.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 37 +-
.../common/tsfile/TsFileInsertionPointCounter.java | 2 +-
.../container/TsFileInsertionDataContainer.java | 16 +-
.../TsFileInsertionDataContainerProvider.java | 6 +-
.../query/TsFileInsertionQueryDataContainer.java | 7 +-
.../TsFileInsertionQueryDataTabletIterator.java | 48 +-
.../scan/TsFileInsertionScanDataContainer.java | 80 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 4 +-
.../event/realtime/PipeRealtimeEventFactory.java | 2 +-
.../execution/PipeConnectorSubtaskExecutor.java | 38 -
.../execution/PipeProcessorSubtaskExecutor.java | 34 -
.../pipe/execution/PipeSubtaskExecutorManager.java | 70 -
.../dataregion/DataRegionListeningFilter.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 4 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 32 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 6 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 34 +-
.../PipeTimePartitionProgressIndexKeeper.java | 102 ++
.../matcher/CachedSchemaPatternMatcher.java | 209 +++
.../realtime/matcher/PipeDataRegionMatcher.java | 52 +
.../schemaregion/PipePlanPatternParseVisitor.java | 2 +-
.../schemaregion/SchemaRegionListeningQueue.java | 4 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 6 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 4 +-
.../metric/PipeDataRegionConnectorMetrics.java | 2 +-
.../db/pipe/metric/PipeDataRegionEventCounter.java | 6 +-
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 2 +-
.../metric/PipeSchemaRegionConnectorMetrics.java | 2 +-
.../pipe/pattern/CachedSchemaPatternMatcher.java | 209 ---
.../db/pipe/pattern/PipeDataRegionMatcher.java | 52 -
.../processor/aggregate/AggregateProcessor.java | 21 +-
.../CustomizedReadableIntermediateResults.java | 16 +
.../numeric/AbstractSameTypeNumericOperator.java | 18 +
.../twostage/plugin/TwoStageCountProcessor.java | 16 +-
.../pipe/progress/SimpleProgressIndexAssigner.java | 118 --
.../pipeconsensus/PipeConsensusReceiver.java | 13 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
.../transform/converter/ValueConverter.java | 12 +-
.../visitor/PipePlanToStatementVisitor.java | 2 +-
...peStatementDataTypeConvertExecutionVisitor.java | 6 +-
.../visitor/PipeStatementPatternParseVisitor.java | 2 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 2 +-
.../pipe/resource/PipeDataNodeResourceManager.java | 2 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 913 +++++++++++++
.../db/pipe/resource/memory/PipeMemoryManager.java | 86 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 128 ++
.../PipeDataNodeSnapshotResourceManager.java | 2 +-
.../iotdb/db/pipe/task/PipeDataNodeTask.java | 123 --
.../db/pipe/task/builder/PipeDataNodeBuilder.java | 85 --
.../pipe/task/builder/PipeDataNodeTaskBuilder.java | 144 --
.../db/pipe/task/connection/EnrichedDeque.java | 87 --
.../pipe/task/connection/PipeEventCollector.java | 210 ---
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 89 --
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 111 --
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 136 --
.../subtask/connector/PipeConnectorSubtask.java | 338 -----
.../connector/PipeConnectorSubtaskLifeCycle.java | 155 ---
.../connector/PipeConnectorSubtaskManager.java | 255 ----
.../PipeRealtimePriorityBlockingQueue.java | 201 ---
.../subtask/processor/PipeProcessorSubtask.java | 299 -----
.../processor/PipeProcessorSubtaskWorker.java | 129 --
.../PipeProcessorSubtaskWorkerManager.java | 51 -
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 8 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 11 +-
.../handler/AINodeRPCServiceThriftHandler.java | 60 -
.../protocol/thrift/impl/AINodeRPCServiceImpl.java | 187 ---
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 3 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../thrift/impl/DataNodeRegionManager.java | 22 +-
.../thrift/impl/IAINodeRPCServiceWithHandler.java | 26 -
.../db/queryengine/common/MPPQueryContext.java | 18 +-
.../queryengine/common/header/DatasetHeader.java | 37 +-
.../queryengine/execution/QueryStateMachine.java | 13 +
.../execution/aggregation/AccumulatorFactory.java | 4 +
.../execution/aggregation/AvgAccumulator.java | 4 +
.../execution/aggregation/ExtremeAccumulator.java | 24 +
.../aggregation/MaxMinByBaseAccumulator.java | 2 +
.../execution/aggregation/MaxValueAccumulator.java | 6 +
.../execution/aggregation/MinValueAccumulator.java | 6 +
.../execution/aggregation/SumAccumulator.java | 4 +
.../execution/aggregation/VarianceAccumulator.java | 4 +
.../execution/exchange/source/SourceHandle.java | 2 +-
.../execution/executor/RegionReadExecutor.java | 3 +-
.../fragment/FragmentInstanceContext.java | 8 +-
.../fragment/FragmentInstanceManager.java | 3 +
.../execution/fragment/QueryContext.java | 12 +
.../process/AggregationMergeSortOperator.java | 3 +-
.../operator/source/AlignedSeriesScanUtil.java | 19 +-
.../execution/operator/source/FileLoaderUtils.java | 145 +-
.../source/relational/InnerJoinOperator.java | 407 ++++++
.../operator/window/WindowManagerFactory.java | 10 +
.../relational/ColumnTransformerBuilder.java | 118 +-
.../execution/schedule/AbstractDriverThread.java | 4 +-
.../queryengine/metric/QueryPlanCostMetricSet.java | 149 ++-
.../iotdb/db/queryengine/plan/Coordinator.java | 20 +-
.../db/queryengine/plan/analyze/Analysis.java | 1 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 11 +-
.../db/queryengine/plan/analyze/Analyzer.java | 4 +-
.../plan/analyze/ClusterPartitionFetcher.java | 12 +-
.../db/queryengine/plan/analyze/IAnalysis.java | 2 +
.../plan/analyze/LoadTsFileAnalyzer.java | 57 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 3 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 4 +
.../cache/schema/DataNodeDevicePathCache.java | 12 +-
.../analyze/lock/DataNodeSchemaLockManager.java | 17 +-
.../queryengine/plan/execution/QueryExecution.java | 11 +-
.../execution/config/TableConfigTaskVisitor.java | 226 +++-
.../execution/config/TreeConfigTaskVisitor.java | 16 +-
.../config/executor/ClusterConfigTaskExecutor.java | 308 ++---
.../config/executor/IConfigTaskExecutor.java | 29 +-
.../config/metadata/CreatePipePluginTask.java | 10 +
.../config/metadata/DropPipePluginTask.java | 7 +
.../execution/config/metadata/ShowAINodesTask.java | 77 ++
.../config/metadata/ShowDataNodesTask.java | 2 +-
.../config/metadata/ShowPipePluginsTask.java | 4 +-
.../execution/config/metadata/ShowRegionTask.java | 29 +-
.../config/metadata/model/ShowAINodesTask.java | 80 --
.../config/metadata/relational/CreateDBTask.java | 24 +-
.../metadata/relational/ShowAINodesTask.java | 78 ++
.../metadata/relational/ShowConfigNodesTask.java | 9 +-
.../metadata/relational/ShowDataNodesTask.java | 9 +-
.../config/metadata/relational/ShowTablesTask.java | 2 +-
.../execution/config/sys/pipe/AlterPipeTask.java | 14 +
.../execution/config/sys/pipe/CreatePipeTask.java | 11 +
.../execution/config/sys/pipe/DropPipeTask.java | 8 +
.../execution/config/sys/pipe/ShowPipeTask.java | 7 +
.../execution/config/sys/pipe/StartPipeTask.java | 7 +
.../execution/config/sys/pipe/StopPipeTask.java | 7 +
.../TableModelStatementMemorySourceVisitor.java | 8 +-
.../multi/builtin/helper/CastFunctionHelper.java | 6 +-
.../plan/expression/unary/LikeExpression.java | 16 +-
.../plan/expression/unary/RegularExpression.java | 6 +-
.../visitor/ColumnTransformerVisitor.java | 3 +-
.../visitor/IntermediateLayerVisitor.java | 3 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 39 +-
.../plan/parser/StatementGenerator.java | 11 +-
.../plan/planner/LocalExecutionPlanner.java | 2 +
.../plan/planner/LogicalPlanVisitor.java | 11 +-
.../queryengine/plan/planner/LogicalPlanner.java | 7 +-
.../plan/planner/OperatorTreeGenerator.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 67 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 95 +-
.../plan/planner/plan/node/PlanNodeType.java | 12 +
.../plan/planner/plan/node/PlanVisitor.java | 17 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 8 +-
.../planner/plan/node/process/ExchangeNode.java | 12 +
.../plan/node/process/last/LastQueryNode.java | 3 +
.../ContinuousSameSearchIndexSeparatorNode.java | 83 +-
.../planner/plan/node/write/DeleteDataNode.java | 3 +
.../plan/planner/plan/node/write/InsertNode.java | 38 +-
.../planner/plan/node/write/InsertRowNode.java | 21 +-
.../planner/plan/node/write/InsertRowsNode.java | 13 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 12 +-
.../planner/plan/node/write/InsertTabletNode.java | 34 +-
.../plan/node/write/RelationalInsertRowNode.java | 23 +-
.../plan/node/write/RelationalInsertRowsNode.java | 2 +-
.../node/write/RelationalInsertTabletNode.java | 56 +-
.../plan/relational/analyzer/Analysis.java | 61 +
.../plan/relational/analyzer/Analyzer.java | 9 +
.../relational/analyzer/ExpressionAnalyzer.java | 27 +
.../relational/analyzer/ExpressionTreeUtils.java | 5 +-
.../relational/analyzer/StatementAnalyzer.java | 140 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 14 +-
.../PredicatePushIntoMetadataChecker.java | 11 +-
.../schema/CheckSchemaPredicateVisitor.java | 6 +-
.../ConvertSchemaPredicateToFilterVisitor.java | 115 +-
.../schema/ExtractPredicateColumnNameVisitor.java | 27 +-
.../function/arithmetic/AdditionResolver.java | 78 ++
.../function/arithmetic/DivisionResolver.java | 66 +
.../function/arithmetic/ModulusResolver.java | 66 +
.../arithmetic/MultiplicationResolver.java | 66 +
.../function/arithmetic/SubtractionResolver.java | 74 ++
.../relational/metadata/FunctionNullability.java | 10 +
.../plan/relational/metadata/Metadata.java | 41 +-
.../metadata/TableBuiltinAggregationFunction.java | 116 ++
.../relational/metadata/TableMetadataImpl.java | 112 +-
.../metadata/fetcher/SchemaPredicateUtil.java | 70 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 26 +-
.../fetcher/TableHeaderSchemaValidator.java | 60 +-
.../plan/relational/planner/EqualityInference.java | 440 ++++++
.../plan/relational/planner/LogicalPlanner.java | 349 -----
.../plan/relational/planner/NodeAndMappings.java | 38 +
.../plan/relational/planner/QueryPlanner.java | 406 ++++++
.../plan/relational/planner/RelationPlanner.java | 409 +++++-
.../relational/planner/RelationalModelPlanner.java | 154 ---
.../plan/relational/planner/SymbolAllocator.java | 10 +
.../plan/relational/planner/SymbolsExtractor.java | 27 +-
.../relational/planner/TableLogicalPlanner.java | 382 ++++++
.../plan/relational/planner/TableModelPlanner.java | 193 +++
.../plan/relational/planner/TranslationMap.java | 11 +-
.../planner/distribute/AddExchangeNodes.java | 1 +
.../distribute/TableDistributedPlanGenerator.java | 212 ++-
.../distribute/TableDistributedPlanner.java | 51 +-
.../TableModelTypeProviderExtractor.java | 25 +
.../planner/ir/ExpressionNodeInliner.java | 43 +
.../plan/relational/planner/ir/IrUtils.java | 4 +
.../planner/ir/ReplaceSymbolInExpression.java | 49 +
.../planner/ir/SubExpressionExtractor.java | 48 +
.../planner/iterative/IterativeOptimizer.java | 2 +-
...AddTableScanColumnsToTypeProviderOptimizer.java | 66 +
.../planner/iterative/rule/InlineProjections.java | 11 +-
.../planner/iterative/rule/MergeLimitWithSort.java | 24 +-
.../iterative/rule/PruneAggregationColumns.java | 47 +
.../rule/PruneAggregationSourceColumns.java | 54 +
.../iterative/rule/PruneJoinChildrenColumns.java | 77 ++
.../planner/iterative/rule/PruneJoinColumns.java | 52 +
.../iterative/rule/PruneTableScanColumns.java | 23 +-
.../relational/planner/iterative/rule/Util.java | 21 +-
.../relational/planner/node/AggregationNode.java | 542 ++++++++
.../planner/node/AggregationTableScanNode.java | 261 ++++
.../plan/relational/planner/node/JoinNode.java | 368 +++++
.../plan/relational/planner/node/Patterns.java | 18 +-
.../relational/planner/node/TableScanNode.java | 49 +-
.../optimizations/DistributedOptimizeFactory.java | 56 +-
.../planner/optimizations/JoinUtils.java | 323 +++++
.../optimizations/LogicalOptimizeFactory.java | 160 ++-
.../planner/optimizations/PlanOptimizer.java | 2 +-
.../PushAggregationIntoTableScan.java | 236 ++++
.../PushLimitOffsetIntoTableScan.java | 23 +
.../optimizations/PushPredicateIntoTableScan.java | 574 +++++++-
.../planner/optimizations/SortElimination.java | 21 +-
.../planner/optimizations/SymbolMapper.java | 248 ++++
.../TransformAggregationToStreamable.java | 160 +++
.../optimizations/TransformSortToStreamSort.java | 26 +-
.../optimizations/UnaliasSymbolReferences.java | 470 +++++++
.../relational/planner/optimizations/Util.java | 288 ++--
.../plan/relational/security/Identity.java | 19 +
.../plan/relational/sql/ast/AlterPipe.java | 143 ++
.../plan/relational/sql/ast/AstVisitor.java | 40 +
.../relational/sql/ast/CoalesceExpression.java | 28 +
.../plan/relational/sql/ast/CreateDB.java | 17 +-
.../plan/relational/sql/ast/CreatePipe.java | 113 ++
.../plan/relational/sql/ast/CreatePipePlugin.java | 95 ++
.../plan/relational/sql/ast/DropPipe.java | 75 ++
.../plan/relational/sql/ast/DropPipePlugin.java | 75 ++
.../plan/relational/sql/ast/Expression.java | 3 +
.../plan/relational/sql/ast/PipeStatement.java | 36 +
.../plan/relational/sql/ast/ShowAINodes.java | 66 +
.../plan/relational/sql/ast/ShowPipePlugins.java | 45 +
.../plan/relational/sql/ast/ShowPipes.java | 76 ++
.../plan/relational/sql/ast/StartPipe.java | 65 +
.../plan/relational/sql/ast/StopPipe.java | 65 +
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 234 +++-
.../plan/relational/sql/util/SqlFormatter.java | 208 +++
.../plan/relational/type/InternalTypeManager.java | 1 +
.../plan/relational/utils/DisjointSet.java | 132 ++
.../scheduler/FixedRateFragInsStateTracker.java | 16 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 4 +
.../plan/statement/crud/InsertRowStatement.java | 6 -
.../plan/statement/crud/InsertTabletStatement.java | 8 +-
.../plan/statement/crud/LoadTsFileStatement.java | 18 +
.../column/multi/CoalesceColumnTransformer.java | 57 +
.../dag/column/unary/InColumnTransformer.java | 86 +-
.../dag/column/unary/LikeColumnTransformer.java | 61 +
.../scalar/CastFunctionColumnTransformer.java | 2 +-
.../unary/scalar/RoundColumnTransformer.java | 6 +
.../scalar/RoundFunctionColumnTransformer.java | 6 +
.../dag/input/ConstantInputReader.java | 4 +
.../unary/ArithmeticNegationTransformer.java | 6 +
.../dag/transformer/unary/InTransformer.java | 2 +
.../dag/transformer/unary/LikeTransformer.java | 67 +
.../unary/scalar/CastFunctionTransformer.java | 34 +
.../unary/scalar/DiffFunctionTransformer.java | 6 +
.../unary/scalar/RoundFunctionTransformer.java | 6 +
.../transformation/dag/util/TransformUtils.java | 8 +
.../transformation/dag/util/TypeUtils.java | 3 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 78 +-
.../iotdb/db/schemaengine/SchemaEngineMode.java | 3 +-
.../metric/SchemaRegionCachedMetric.java | 2 +-
.../rescon/MemSchemaRegionStatistics.java | 31 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 10 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 2 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 301 +++--
.../schemaregion/utils/MetaFormatUtils.java | 5 +-
.../schemaregion/utils/ResourceByPathUtils.java | 68 +-
.../db/schemaengine/table/DataNodeTableCache.java | 215 ++-
.../apache/iotdb/db/service/AINodeRPCService.java | 94 --
.../iotdb/db/service/AINodeRPCServiceMBean.java | 22 -
.../java/org/apache/iotdb/db/service/DataNode.java | 145 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 137 ++
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 151 ---
.../iotdb/db/service/RegionMigrateService.java | 36 +-
.../db/service/ResourcesInformationHolder.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 9 +-
.../db/storageengine/dataregion/DataRegion.java | 118 +-
.../execute/performer/ICompactionPerformer.java | 2 +
.../performer/impl/FastCompactionPerformer.java | 13 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../impl/ReadPointCompactionPerformer.java | 10 +-
.../RepairUnsortedFileCompactionPerformer.java | 10 +-
.../execute/task/AbstractCompactionTask.java | 4 +-
.../execute/task/CrossSpaceCompactionTask.java | 3 +
.../execute/task/InnerSpaceCompactionTask.java | 3 +-
.../task/InsertionCrossSpaceCompactionTask.java | 10 +-
.../task/RepairUnsortedFileCompactionTask.java | 156 +--
.../execute/task/SettleCompactionTask.java | 38 +-
.../subtask/FastCompactionPerformerSubTask.java | 13 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 42 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 85 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 92 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 185 ++-
.../BatchedCompactionAlignedPagePointReader.java | 95 --
.../CompactionAlignedPageLazyLoadPointReader.java | 108 ++
.../fast/FastAlignedSeriesCompactionExecutor.java | 19 +-
.../fast/reader/CompactionAlignedChunkReader.java | 79 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 187 ++-
.../compaction/io/CompactionTsFileReader.java | 27 +
.../compaction/repair/RepairDataFileScanUtil.java | 24 +-
.../repair/RepairTimePartitionScanTask.java | 11 +-
.../repair/UnsortedFileRepairTaskScheduler.java | 2 +-
.../schedule/CompactionScheduleContext.java | 40 +-
.../compaction/schedule/CompactionScheduler.java | 15 +-
.../selector/constant/CrossCompactionSelector.java | 6 +-
.../constant/InnerSequenceCompactionSelector.java | 2 +-
.../InnerUnsequenceCompactionSelector.java | 2 +-
.../estimator/CompactionEstimateUtils.java | 48 +
.../FastCompactionInnerCompactionEstimator.java | 13 +-
.../FastCrossSpaceCompactionEstimator.java | 12 +-
.../ReadChunkInnerCompactionEstimator.java | 15 +-
.../impl/NewSizeTieredCompactionSelector.java | 11 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 19 +-
.../selector/impl/SettleSelectorImpl.java | 16 +-
.../impl/SizeTieredCompactionSelector.java | 33 +-
.../utils/CrossSpaceCompactionCandidate.java | 4 +-
.../selector/utils/TsFileResourceCandidate.java | 4 +-
.../dataregion/memtable/AbstractMemTable.java | 11 +-
.../memtable/AlignedReadOnlyMemChunk.java | 11 +-
.../memtable/AlignedWritableMemChunk.java | 5 +-
.../dataregion/memtable/DeviceIDFactory.java | 16 +-
.../dataregion/memtable/IWritableMemChunk.java | 4 +-
.../dataregion/memtable/TsFileProcessor.java | 47 +-
.../dataregion/memtable/WritableMemChunk.java | 3 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/MemAlignedPageReader.java | 32 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 34 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 10 +-
.../dataregion/snapshot/SnapshotLoader.java | 7 +-
.../dataregion/tsfile/TsFileManager.java | 23 +-
.../dataregion/tsfile/TsFileRepairStatus.java | 16 +-
.../dataregion/tsfile/TsFileResource.java | 21 +-
.../timeindex/FileTimeIndexCacheRecorder.java | 121 +-
.../FileTimeIndexCacheReader.java | 10 +-
.../FileTimeIndexCacheWriter.java | 12 +-
.../storageengine/dataregion/wal/WALManager.java | 18 +-
.../dataregion/wal/buffer/WALEntry.java | 3 +
.../dataregion/wal/io/WALInputStream.java | 1 -
.../storageengine/dataregion/wal/io/WALReader.java | 12 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 7 +-
.../file/UnsealedTsFileRecoverPerformer.java | 3 +
.../dataregion/wal/utils/WALInsertNodeCache.java | 44 +-
.../load/active/ActiveLoadDirScanner.java | 47 +
.../load/active/ActiveLoadTsFileLoader.java | 19 +-
.../load/config/LoadTsFileConfigurator.java | 100 ++
.../load/memory/LoadTsFileAbstractMemoryBlock.java | 4 +
.../memory/LoadTsFileAnalyzeSchemaMemoryBlock.java | 28 +-
.../memory/LoadTsFileDataCacheMemoryBlock.java | 7 +
.../load/memory/LoadTsFileMemoryManager.java | 28 +-
.../load/splitter/TsFileSplitter.java | 13 +-
.../agent/SubscriptionBrokerAgent.java | 10 +
.../broker/SubscriptionBlockingPendingQueue.java | 2 +-
.../db/subscription/broker/SubscriptionBroker.java | 22 +-
.../broker/SubscriptionPrefetchingQueue.java | 21 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 2 +-
.../db/subscription/event/SubscriptionEvent.java | 28 +-
.../event/batch/SubscriptionPipeEventBatches.java | 4 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 31 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 12 +-
.../event/pipe/SubscriptionPipeEmptyEvent.java | 9 +
.../event/pipe/SubscriptionPipeEvents.java | 4 +
.../pipe/SubscriptionPipeTabletBatchEvents.java | 9 +
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 13 +
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 9 +
.../executor/SubscriptionSubtaskExecutor.java | 33 -
.../SubscriptionPrefetchingQueueMetrics.java | 2 +-
.../execution/SubscriptionSubtaskExecutor.java | 33 +
.../task/stage/SubscriptionTaskConnectorStage.java | 6 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 18 +-
.../SubscriptionConnectorSubtaskLifeCycle.java | 10 +-
.../SubscriptionConnectorSubtaskManager.java | 25 +-
.../tools/schema/SchemaRegionSnapshotParser.java | 68 +-
.../db/trigger/executor/TriggerFireVisitor.java | 8 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 9 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 10 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 193 ++-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 4 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 51 +-
.../iotdb/db/utils/constant/SqlConstant.java | 5 +
.../db/utils/datastructure/AlignedTVList.java | 93 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 5 +-
.../SchemaRegionSimpleRecoverTest.java | 3 +-
.../schemaRegion/SchemaRegionTableDeviceTest.java | 8 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 8 +-
.../task/PipeConnectorSubtaskExecutorTest.java | 48 +
.../task/PipeProcessorSubtaskExecutorTest.java | 50 +
.../pipe/agent/task/PipeSubtaskExecutorTest.java | 159 +++
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 2 +-
.../PipeStatementPatternParseVisitorTest.java | 2 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 2 +-
.../event/TsFileInsertionDataContainerTest.java | 22 +-
.../PipeConnectorSubtaskExecutorTest.java | 47 -
.../PipeProcessorSubtaskExecutorTest.java | 49 -
.../db/pipe/execution/PipeSubtaskExecutorTest.java | 159 ---
.../extractor/PipePlanPatternParseVisitorTest.java | 2 +-
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 7 +
.../pattern/CachedSchemaPatternMatcherTest.java | 5 +-
.../db/pipe/pattern/IoTDBPipePatternTest.java | 2 +-
.../db/pipe/pattern/PrefixPipePatternTest.java | 2 +-
.../operator/AggregationMergeSortOperatorTest.java | 177 +++
.../logical/DataQueryLogicalPlannerTest.java | 33 +
...nuousSameSearchIndexSeparatorNodeSerDeTest.java | 56 +
.../node/write/InsertRowsNodeSerdeTest.java | 228 ++--
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 2 +-
.../node/write/InsertTabletNodeSerdeTest.java | 86 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 28 +-
.../plan/relational/analyzer/AggregationTest.java | 685 ++++++++++
.../plan/relational/analyzer/AnalyzerTest.java | 331 ++---
.../plan/relational/analyzer/JoinTest.java | 411 ++++++
.../analyzer/LimitOffsetPushDownTest.java | 82 +-
.../relational/analyzer/MockTSBSDataPartition.java | 173 +++
.../plan/relational/analyzer/SortTest.java | 180 +--
.../plan/relational/analyzer/SubQueryTest.java | 174 ++-
.../plan/relational/analyzer/TSBSMetadata.java | 448 +++++++
.../plan/relational/analyzer/TSBSTest.java | 1343 +++++++++++++++++++
.../plan/relational/analyzer/TestMatadata.java | 80 +-
.../plan/relational/analyzer/TestUtils.java | 56 +-
.../plan/relational/planner/ExampleTest.java | 13 +-
.../plan/relational/planner/PlanTester.java | 38 +-
.../planner/assertions/AggregationFunction.java | 62 +
.../assertions/AggregationFunctionMatcher.java | 72 +
.../assertions/AggregationFunctionProvider.java | 87 ++
.../planner/assertions/AggregationMatcher.java | 145 ++
.../planner/assertions/AggregationStepMatcher.java | 57 +
.../assertions/AggregationTableScanMatcher.java | 189 +++
.../planner/assertions/ColumnReference.java | 10 +-
.../planner/assertions/ExpectedValueProvider.java | 30 +
.../relational/planner/assertions/PlanAssert.java | 3 +-
.../planner/assertions/PlanMatchPattern.java | 179 ++-
.../planner/assertions/PredicateMatcher.java | 46 +
.../planner/assertions/TableScanMatcher.java | 10 +-
.../column/unary/UnaryColumnTransformerTest.java | 15 +
.../TsFileResourceProgressIndexTest.java | 64 +-
.../compaction/AbstractCompactionTest.java | 3 +-
.../CrossSpaceCompactionWithUnusualCasesTest.java | 37 +-
...InconsistentCompressionTypeAndEncodingTest.java | 3 +-
.../FastInnerCompactionPerformerTest.java | 2 +-
.../cross/CrossSpaceCompactionSelectorTest.java | 63 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 10 +-
...eCompactionWithFastPerformerValidationTest.java | 136 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 10 +-
...actionWithReadPointPerformerValidationTest.java | 130 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 13 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 181 ++-
.../cross/InsertionCrossSpaceCompactionTest.java | 15 +-
.../compaction/cross/MergeUpgradeTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 42 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 25 +-
...nkCompactionPerformerWithAlignedSeriesTest.java | 62 +
.../SizeTieredCompactionSelectorTest.java | 7 +-
.../repair/RepairUnsortedFileCompactionTest.java | 116 +-
.../repair/RepairUnsortedFileSchedulerTest.java | 2 +-
.../settle/SettleCompactionSelectorTest.java | 63 +-
.../settle/SettleCompactionTaskTest.java | 35 +-
.../tablemodel/CompactionWithAllNullRowsTest.java | 317 +++++
.../compaction/utils/BatchCompactionUtilsTest.java | 163 ++-
.../compaction/utils/CompactionCheckerUtils.java | 3 +-
.../compaction/utils/CompactionTaskQueueTest.java | 8 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 38 +-
.../dataregion/memtable/TsFileProcessorTest.java | 124 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 6 +-
.../MemAlignedChunkMetadataLoaderTest.java | 2 +-
.../dataregion/wal/io/WALFileTest.java | 40 +-
.../wal/node/ConsensusReqReaderTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 -
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 24 +-
.../conf/iotdb-system.properties.template | 33 +-
.../assembly/resources/sbin/destroy-datanode.bat | 12 +-
.../assembly/resources/sbin/destroy-datanode.sh | 4 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +
.../iotdb/commons/conf/CommonDescriptor.java | 8 +-
.../commons/consensus/index/ProgressIndex.java | 19 +-
.../consensus/index/impl/HybridProgressIndex.java | 30 +-
.../consensus/index/impl/IoTProgressIndex.java | 28 +-
.../consensus/index/impl/MetaProgressIndex.java | 23 +-
.../consensus/index/impl/RecoverProgressIndex.java | 22 +-
.../consensus/index/impl/SimpleProgressIndex.java | 3 +-
.../consensus/index/impl/StateProgressIndex.java | 23 +-
.../index/impl/TimeWindowStateProgressIndex.java | 48 +-
.../PipeRuntimeConnectorCriticalException.java | 2 +-
.../pipe/PipeRuntimeCriticalException.java | 2 +-
.../exception/pipe/PipeRuntimeExceptionType.java | 2 +-
.../pipe/PipeRuntimeNonCriticalException.java | 2 +-
.../PipeRuntimeOutOfMemoryCriticalException.java | 2 +-
.../iotdb/commons/partition/DataPartition.java | 35 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 19 +
.../agent/plugin/PipeConnectorConstructor.java | 53 -
.../agent/plugin/PipeExtractorConstructor.java | 53 -
.../commons/pipe/agent/plugin/PipePluginAgent.java | 5 +-
.../pipe/agent/plugin/PipePluginConstructor.java | 107 --
.../agent/plugin/PipeProcessorConstructor.java | 50 -
.../agent/plugin/builtin/BuiltinPipePlugin.java | 167 +++
.../builtin/connector/PlaceholderConnector.java | 82 ++
.../connector/donothing/DoNothingConnector.java | 72 +
.../iotdb/airgap/IoTDBAirGapConnector.java | 30 +
.../consensus/PipeConsensusAsyncConnector.java | 30 +
.../iotdb/thrift/IoTDBLegacyPipeConnector.java | 30 +
.../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 +
.../extractor/donothing/DoNothingExtractor.java | 55 +
.../builtin/extractor/iotdb/IoTDBExtractor.java | 64 +
.../builtin/processor/PlaceHolderProcessor.java | 68 +
.../processor/aggregate/AggregateProcessor.java | 30 +
.../aggregate/StandardStatisticsProcessor.java | 30 +
.../aggregate/TumblingWindowingProcessor.java | 30 +
.../processor/donothing/DoNothingProcessor.java | 67 +
.../ChangingValueSamplingProcessor.java | 30 +
.../SwingingDoorTrendingSamplingProcessor.java | 30 +
.../TumblingTimeSamplingProcessor.java | 30 +
.../pipeconsensus/PipeConsensusProcessor.java | 30 +
.../throwing/ThrowingExceptionProcessor.java | 99 ++
.../processor/twostage/TwoStageCountProcessor.java | 30 +
.../constructor/PipeConnectorConstructor.java | 53 +
.../constructor/PipeExtractorConstructor.java | 53 +
.../plugin/constructor/PipePluginConstructor.java | 107 ++
.../constructor/PipeProcessorConstructor.java | 50 +
.../meta/ConfigNodePipePluginMetaKeeper.java | 99 ++
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 22 +
.../pipe/agent/plugin/meta/PipePluginMeta.java | 155 +++
.../agent/plugin/meta/PipePluginMetaKeeper.java | 138 ++
.../plugin/service/PipePluginClassLoader.java | 90 ++
.../service/PipePluginClassLoaderManager.java | 115 ++
.../service/PipePluginExecutableManager.java | 137 ++
.../iotdb/commons/pipe/agent/task/PipeTask.java | 31 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 14 +-
.../commons/pipe/agent/task/PipeTaskManager.java | 131 ++
.../task/connection/BlockingPendingQueue.java | 161 +++
.../connection/BoundedBlockingPendingQueue.java | 32 +
.../pipe/agent/task/connection/EventSupplier.java | 34 +
.../connection/UnboundedBlockingPendingQueue.java | 40 +
.../agent/task/execution/PipeSubtaskExecutor.java | 163 +++
.../agent/task/execution/PipeSubtaskScheduler.java | 89 ++
.../commons/pipe/agent/task/meta/PipeMeta.java | 151 +++
.../pipe/agent/task/meta/PipeMetaKeeper.java | 183 +++
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 327 +++++
.../agent/task/meta/PipeRuntimeMetaVersion.java | 77 ++
.../pipe/agent/task/meta/PipeStaticMeta.java | 226 ++++
.../commons/pipe/agent/task/meta/PipeStatus.java | 50 +
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 185 +++
.../pipe/agent/task/meta/PipeTemporaryMeta.java | 93 ++
.../commons/pipe/agent/task/meta/PipeType.java | 42 +
.../pipe/agent/task/progress/CommitterKey.java | 95 ++
.../task/progress/PipeEventCommitManager.java | 194 +++
.../agent/task/progress/PipeEventCommitter.java | 134 ++
.../pipe/agent/task/stage/PipeTaskStage.java | 144 ++
.../task/subtask/PipeAbstractConnectorSubtask.java | 237 ++++
.../agent/task/subtask/PipeReportableSubtask.java | 166 +++
.../pipe/agent/task/subtask/PipeSubtask.java | 202 +++
.../iotdb/commons/pipe/config/PipeConfig.java | 5 +
.../config/constant/PipeExtractorConstant.java | 6 +
.../env/PipeTaskExtractorRuntimeEnvironment.java | 2 +-
.../env/PipeTaskProcessorRuntimeEnvironment.java | 2 +-
.../plugin/env/PipeTaskRuntimeEnvironment.java | 4 +-
.../pipe/connector/PipeReceiverStatusHandler.java | 251 ----
.../pipe/connector/protocol/IoTDBConnector.java | 4 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 35 +-
.../options/PipeInclusionOptions.java | 2 +-
.../datastructure/pattern/IoTDBPipePattern.java | 202 +++
.../pipe/datastructure/pattern/PipePattern.java | 135 ++
.../datastructure/pattern/PrefixPipePattern.java | 125 ++
.../listening/AbstractPipeListeningQueue.java | 2 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 28 +-
.../commons/pipe/event/PipeSnapshotEvent.java | 6 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 4 +-
.../commons/pipe/event/ProgressReportEvent.java | 4 +-
.../execution/executor/PipeSubtaskExecutor.java | 164 ---
.../execution/scheduler/PipeSubtaskScheduler.java | 90 --
.../commons/pipe/extractor/IoTDBExtractor.java | 2 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 4 +-
.../pipe/metric/PipeEventCommitMetrics.java | 2 +-
.../commons/pipe/pattern/IoTDBPipePattern.java | 202 ---
.../iotdb/commons/pipe/pattern/PipePattern.java | 135 --
.../commons/pipe/pattern/PrefixPipePattern.java | 125 --
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 163 ---
.../builtin/connector/PlaceholderConnector.java | 82 --
.../connector/donothing/DoNothingConnector.java | 72 -
.../iotdb/airgap/IoTDBAirGapConnector.java | 30 -
.../consensus/PipeConsensusAsyncConnector.java | 30 -
.../iotdb/thrift/IoTDBLegacyPipeConnector.java | 30 -
.../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 -
.../extractor/donothing/DoNothingExtractor.java | 55 -
.../builtin/extractor/iotdb/IoTDBExtractor.java | 64 -
.../builtin/processor/PlaceHolderProcessor.java | 68 -
.../processor/aggregate/AggregateProcessor.java | 30 -
.../aggregate/StandardStatisticsProcessor.java | 30 -
.../aggregate/TumblingWindowingProcessor.java | 30 -
.../processor/donothing/DoNothingProcessor.java | 67 -
.../ChangingValueSamplingProcessor.java | 30 -
.../SwingingDoorTrendingSamplingProcessor.java | 30 -
.../TumblingTimeSamplingProcessor.java | 30 -
.../pipeconsensus/PipeConsensusProcessor.java | 30 -
.../throwing/ThrowingExceptionProcessor.java | 99 --
.../processor/twostage/TwoStageCountProcessor.java | 30 -
.../meta/ConfigNodePipePluginMetaKeeper.java | 99 --
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 22 -
.../commons/pipe/plugin/meta/PipePluginMeta.java | 155 ---
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 138 --
.../pipe/plugin/service/PipePluginClassLoader.java | 90 --
.../service/PipePluginClassLoaderManager.java | 115 --
.../service/PipePluginExecutableManager.java | 137 --
.../pipe/progress/PipeEventCommitManager.java | 185 ---
.../commons/pipe/progress/PipeEventCommitter.java | 144 --
.../pipe/receiver/PipeReceiverStatusHandler.java | 251 ++++
.../pipe/resource/PipeSnapshotResourceManager.java | 160 ---
.../snapshot/PipeSnapshotResourceManager.java | 160 +++
.../iotdb/commons/pipe/task/EventSupplier.java | 34 -
.../apache/iotdb/commons/pipe/task/PipeTask.java | 31 -
.../iotdb/commons/pipe/task/PipeTaskManager.java | 131 --
.../pipe/task/connection/BlockingPendingQueue.java | 160 ---
.../connection/BoundedBlockingPendingQueue.java | 32 -
.../connection/UnboundedBlockingPendingQueue.java | 40 -
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 151 ---
.../commons/pipe/task/meta/PipeMetaKeeper.java | 183 ---
.../commons/pipe/task/meta/PipeRuntimeMeta.java | 327 -----
.../pipe/task/meta/PipeRuntimeMetaVersion.java | 77 --
.../commons/pipe/task/meta/PipeStaticMeta.java | 226 ----
.../iotdb/commons/pipe/task/meta/PipeStatus.java | 50 -
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 185 ---
.../commons/pipe/task/meta/PipeTemporaryMeta.java | 93 --
.../iotdb/commons/pipe/task/meta/PipeType.java | 42 -
.../commons/pipe/task/stage/PipeTaskStage.java | 144 --
.../task/subtask/PipeAbstractConnectorSubtask.java | 237 ----
.../pipe/task/subtask/PipeReportableSubtask.java | 166 ---
.../commons/pipe/task/subtask/PipeSubtask.java | 202 ---
.../filter/impl/StringValueFilterVisitor.java | 2 +-
.../schema/filter/impl/values/LikeFilter.java | 38 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 4 +-
.../schema/table/TsTableInternalRPCUtil.java | 94 +-
.../viewExpression/unary/LikeViewExpression.java | 72 +-
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 20 +
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 2 +
.../commons/udf/builtin/UDTFChangePoints.java | 6 +
.../commons/udf/builtin/UDTFCommonDerivative.java | 6 +
.../udf/builtin/UDTFCommonValueDifference.java | 6 +
.../udf/builtin/UDTFContinuouslySatisfy.java | 10 +
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 6 +
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 6 +
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 6 +
.../builtin/UDTFEqualSizeBucketRandomSample.java | 6 +
.../iotdb/commons/udf/builtin/UDTFInRange.java | 18 +
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 15 +
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 6 +
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 18 +
.../udf/builtin/UDTFNonNegativeDerivative.java | 6 +
.../builtin/UDTFNonNegativeValueDifference.java | 6 +
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 18 +
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 4 +
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 2 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 6 +
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 6 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 11 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 11 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 24 +
.../apache/iotdb/commons/utils/StatusUtils.java | 9 +-
.../exception/pipe/PipeRuntimeExceptionTest.java | 2 +-
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 10 +-
.../pipe/plugin/meta/PipePluginMetaTest.java | 4 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 153 +++
.../commons/pipe/task/meta/PipeMetaDeSerTest.java | 141 --
.../commons/schema/SchemaFilterSerDeTest.java | 5 +-
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 160 ++-
iotdb-protocol/openapi/pom.xml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
.../src/main/thrift/confignode.thrift | 7 +
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
.../thrift-datanode/src/main/thrift/client.thrift | 1 +
.../src/main/thrift/datanode.thrift | 15 +-
library-udf/pom.xml | 4 +-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 12 +
.../apache/iotdb/library/anomaly/UDTFRange.java | 6 +
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 6 +
.../iotdb/library/dprofile/UDAFPercentile.java | 24 +
.../iotdb/library/dprofile/UDAFQuantile.java | 18 +
.../apache/iotdb/library/dprofile/UDAFSpread.java | 12 +
.../iotdb/library/dprofile/UDTFDistinct.java | 16 +
.../apache/iotdb/library/dprofile/UDTFSample.java | 6 +
.../dprofile/util/ExactOrderStatistics.java | 30 +
.../iotdb/library/drepair/UDTFTimestampRepair.java | 6 +
.../iotdb/library/drepair/UDTFValueFill.java | 6 +
.../iotdb/library/drepair/UDTFValueRepair.java | 7 +
.../library/frequency/UDFEnvelopeAnalysis.java | 6 +
.../java/org/apache/iotdb/library/util/Util.java | 15 +
pom.xml | 99 +-
src/main/groovy/checkDependencies.groovy | 60 +
src/main/xslt/sbom-filter.xsl | 41 +
1188 files changed, 50858 insertions(+), 29380 deletions(-)
create mode 100644 .github/workflows/cluster-it-1c1d1a.yml
create mode 100644 .github/workflows/dependency-check.yml
create mode 100644 dependencies.json
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/AINodeWrapper.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/category/AIClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeBasicIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/orderBy/IoTDBOrderByForDebugIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeReqAutoSliceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/pool/IoTDBInsertTableSessionPoolIT.java
create mode 100644
integration-test/src/test/resources/ainode-example/config.yaml
create mode 100644 integration-test/src/test/resources/ainode-example/model.pt
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/AbstractDataTool.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/AbstractSchemaTool.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/AbstractTsFileTool.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ExportData.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ExportSchema.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ExportTsFile.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ImportData.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ImportSchema.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ImportTsFile.java
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/IoTDBDataBackTool.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/backup/IoTDBDataBackTool.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AbstractDataTool.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ExportData.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportData.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/AbstractSchemaTool.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/ExportSchema.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/ImportSchema.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/AbstractTsFileTool.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ExportTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ImportTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ImportTsFileBase.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ImportTsFileLocally.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ImportTsFileRemotely.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ImportTsFileScanTool.java
create mode 100644 iotdb-client/client-py/TableModelSessionExample.py
create mode 100644 iotdb-client/client-py/TableModelSessionPoolExample.py
create mode 100644 iotdb-client/client-py/iotdb/tsfile/utils/DateUtils.py
create mode 100644
iotdb-client/client-py/tests/integration/test_new_data_types.py
create mode 100644
iotdb-client/client-py/tests/integration/test_relational_session.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/attribute.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/encryption.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/factory.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/inference.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/manager}/__init__.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/manager/cluster_manager.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/manager/inference_manager.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/manager/model_manager.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/model}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/model/built_in_model_factory.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/model/model_factory.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/model/model_storage.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/parser.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/storage.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/util.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/util}/__init__.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/util/decorator.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/util/lock.py
rename iotdb-core/ainode/iotdb/ainode/{ => util}/serde.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/util/status.py
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/auth/AuthorPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/ConfigPhysicalReadPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/auth/AuthorReadPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/FetchTablePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/ShowTablePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/AuthorPlan.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ShowCQPlan.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/ShowPipePlanV1.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/FetchTableResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/ShowTableResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtask.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtaskExecutor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTask.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskBuilder.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskStage.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtask.java
delete 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/resource/PipeConfigNodeSnapshotResourceManager.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/snapshot/PipeConfigNodeSnapshotResourceManager.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTask.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTaskBuilder.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTaskStage.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/agent/PipeConfigNodeSubtaskExecutorTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtaskExecutorTest.java
create mode 100644
iotdb-core/datanode/src/main/codegen/dataModel/MathematicalDataType.tdd
create mode 100644
iotdb-core/datanode/src/main/codegen/dataModel/MathematicalOperator.tdd
create mode 100644
iotdb-core/datanode/src/main/codegen/templates/ArithmeticBinaryColumnTransformer.ftl
create mode 100644
iotdb-core/datanode/src/main/codegen/templates/ArithmeticColumnTransformerApi.ftl
create mode 100644
iotdb-core/datanode/src/main/codegen/templates/ArithmeticUnaryColumnTransformer.ftl
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/SimpleProgressIndexAssigner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/EnrichedDeque.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeConnectorSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeProcessorSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeSubtaskExecutorManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/stage/PipeTaskConnectorStage.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/stage/PipeTaskExtractorStage.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/stage/PipeTaskProcessorStage.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/connector/PipeConnectorSubtask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/connector/PipeConnectorSubtaskLifeCycle.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/connector/PipeConnectorSubtaskManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/connector/PipeRealtimePriorityBlockingQueue.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorkerManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/PipeConnectorSubtaskExecutor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/PipeProcessorSubtaskExecutor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/PipeSubtaskExecutorManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeTimePartitionProgressIndexKeeper.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/matcher/CachedSchemaPatternMatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/matcher/PipeDataRegionMatcher.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/pattern/CachedSchemaPatternMatcher.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/pattern/PipeDataRegionMatcher.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/progress/SimpleProgressIndexAssigner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimator.java
delete 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/builder/PipeDataNodeBuilder.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/builder/PipeDataNodeTaskBuilder.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/EnrichedDeque.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/PipeEventCollector.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskConnectorStage.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskExtractorStage.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskProcessorStage.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtaskLifeCycle.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtaskManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeRealtimePriorityBlockingQueue.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/processor/PipeProcessorSubtask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/processor/PipeProcessorSubtaskWorker.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/processor/PipeProcessorSubtaskWorkerManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/handler/AINodeRPCServiceThriftHandler.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/AINodeRPCServiceImpl.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/IAINodeRPCServiceWithHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InnerJoinOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowAINodesTask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/ShowAINodesTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/ShowAINodesTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/arithmetic/AdditionResolver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/arithmetic/DivisionResolver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/arithmetic/ModulusResolver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/arithmetic/MultiplicationResolver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/arithmetic/SubtractionResolver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableBuiltinAggregationFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/EqualityInference.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/LogicalPlanner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/NodeAndMappings.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationalModelPlanner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/TableLogicalPlanner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/TableModelPlanner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ir/ExpressionNodeInliner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ir/ReplaceSymbolInExpression.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ir/SubExpressionExtractor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/AddTableScanColumnsToTypeProviderOptimizer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneAggregationColumns.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneAggregationSourceColumns.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneJoinChildrenColumns.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneJoinColumns.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/AggregationNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/AggregationTableScanNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/JoinNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/JoinUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PushAggregationIntoTableScan.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/SymbolMapper.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TransformAggregationToStreamable.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/UnaliasSymbolReferences.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipePlugin.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipePlugin.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/PipeStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowAINodes.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipes.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StartPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StopPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/utils/DisjointSet.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/CoalesceColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/LikeColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/transformer/unary/LikeTransformer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCService.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCServiceMBean.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/DataNodeShutdownHook.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/BatchedCompactionAlignedPagePointReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/CompactionAlignedPageLazyLoadPointReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/config/LoadTsFileConfigurator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/execution/executor/SubscriptionSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/SubscriptionSubtaskExecutor.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/PipeConnectorSubtaskExecutorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/PipeProcessorSubtaskExecutorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/PipeSubtaskExecutorTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/execution/PipeConnectorSubtaskExecutorTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/execution/PipeProcessorSubtaskExecutorTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/execution/PipeSubtaskExecutorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/AggregationMergeSortOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/write/ContinuousSameSearchIndexSeparatorNodeSerDeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/AggregationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/JoinTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/MockTSBSDataPartition.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/TSBSMetadata.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/TSBSTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/AggregationFunction.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/AggregationFunctionMatcher.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/AggregationFunctionProvider.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/AggregationMatcher.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/AggregationStepMatcher.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/AggregationTableScanMatcher.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/ExpectedValueProvider.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/PredicateMatcher.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/CompactionWithAllNullRowsTest.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipeConnectorConstructor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipeExtractorConstructor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipePluginConstructor.java
delete 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/plugin/builtin/BuiltinPipePlugin.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/PlaceholderConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/donothing/DoNothingConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/iotdb/airgap/IoTDBAirGapConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/iotdb/consensus/PipeConsensusAsyncConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/iotdb/thrift/IoTDBLegacyPipeConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/iotdb/thrift/IoTDBThriftAsyncConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/iotdb/thrift/IoTDBThriftConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSslConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSyncConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/opcua/OpcUaConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/websocket/WebSocketConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/writeback/WriteBackConnector.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/extractor/donothing/DoNothingExtractor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/extractor/iotdb/IoTDBExtractor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/PlaceHolderProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/aggregate/AggregateProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/aggregate/StandardStatisticsProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/aggregate/TumblingWindowingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/donothing/DoNothingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/downsampling/ChangingValueSamplingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/downsampling/SwingingDoorTrendingSamplingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/downsampling/TumblingTimeSamplingProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/pipeconsensus/PipeConsensusProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/throwing/ThrowingExceptionProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/twostage/TwoStageCountProcessor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/constructor/PipeConnectorConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/constructor/PipeExtractorConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/constructor/PipePluginConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/constructor/PipeProcessorConstructor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/meta/ConfigNodePipePluginMetaKeeper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/meta/DataNodePipePluginMetaKeeper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/meta/PipePluginMeta.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/meta/PipePluginMetaKeeper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/service/PipePluginClassLoader.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/service/PipePluginClassLoaderManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/service/PipePluginExecutableManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTask.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTaskManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/connection/BlockingPendingQueue.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/connection/BoundedBlockingPendingQueue.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/connection/EventSupplier.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/connection/UnboundedBlockingPendingQueue.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/execution/PipeSubtaskExecutor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/execution/PipeSubtaskScheduler.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeMeta.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeMetaKeeper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeRuntimeMeta.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeRuntimeMetaVersion.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeStaticMeta.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeStatus.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTaskMeta.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTemporaryMeta.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeType.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/progress/CommitterKey.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/progress/PipeEventCommitManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/progress/PipeEventCommitter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/stage/PipeTaskStage.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeAbstractConnectorSubtask.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeReportableSubtask.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeSubtask.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/PipeReceiverStatusHandler.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/IoTDBPipePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/PipePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/PrefixPipePattern.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/execution/executor/PipeSubtaskExecutor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/execution/scheduler/PipeSubtaskScheduler.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/pattern/IoTDBPipePattern.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/pattern/PipePattern.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/pattern/PrefixPipePattern.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/BuiltinPipePlugin.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/PlaceholderConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/donothing/DoNothingConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/airgap/IoTDBAirGapConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/consensus/PipeConsensusAsyncConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBLegacyPipeConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftAsyncConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSslConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSyncConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/opcua/OpcUaConnector.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/websocket/WebSocketConnector.java
delete 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/donothing/DoNothingExtractor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/extractor/iotdb/IoTDBExtractor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/PlaceHolderProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/aggregate/AggregateProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/aggregate/StandardStatisticsProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/aggregate/TumblingWindowingProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/donothing/DoNothingProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/ChangingValueSamplingProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/SwingingDoorTrendingSamplingProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/TumblingTimeSamplingProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/pipeconsensus/PipeConsensusProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/throwing/ThrowingExceptionProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/twostage/TwoStageCountProcessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/meta/ConfigNodePipePluginMetaKeeper.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/meta/DataNodePipePluginMetaKeeper.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/meta/PipePluginMeta.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/meta/PipePluginMetaKeeper.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/service/PipePluginClassLoader.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/service/PipePluginClassLoaderManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/service/PipePluginExecutableManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/progress/PipeEventCommitManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/progress/PipeEventCommitter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/PipeReceiverStatusHandler.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/PipeSnapshotResourceManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/snapshot/PipeSnapshotResourceManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/EventSupplier.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/PipeTask.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/PipeTaskManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/connection/BlockingPendingQueue.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/connection/BoundedBlockingPendingQueue.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/connection/UnboundedBlockingPendingQueue.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeMeta.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeMetaKeeper.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeRuntimeMeta.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeRuntimeMetaVersion.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeStaticMeta.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeStatus.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeTaskMeta.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeTemporaryMeta.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeType.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/stage/PipeTaskStage.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/subtask/PipeAbstractConnectorSubtask.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/subtask/PipeReportableSubtask.java
delete 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/test/java/org/apache/iotdb/commons/pipe/task/PipeMetaDeSerTest.java
delete mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/task/meta/PipeMetaDeSerTest.java
create mode 100644 src/main/groovy/checkDependencies.groovy
create mode 100644 src/main/xslt/sbom-filter.xsl
