This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch lwh/frame1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4cbf004c83b Fix appearance of dispatching FI failed because of thrift
frame is oversize (#17536)
add b17a2c9c2e3 [To dev/1.3] Fix aggregation query when device cross
region in TreeModel #16650
add 6e538829900 [To dev/1.3] Pipe: Fixed the potential NPE in receiver
tablet construction (#16648) (#16656)
add 71611a25430 [To dev/1.3] Add HashLedaerBalancer (#16654)
add 2cd887ed408 [To dev/1.3] Made the schemaRegionMap nonnull for
SchemaEngine (#15775) (#15777)
add 33344e5dd93 [To dev/1.3] Pipe: Added log control for pipe receiver
auth exception (#16659) (#16660)
add c3e7e6f91f1 [To dev/1.3] Pipe: Add TsFile parsing with Mods function
(#16540) (#16651)
add dbc0133acc1 [to dev/1.3] Optimize memtable scan
add b46f637b2af [To dev/1.3] Optimize the efficiency of DualKeyCacheImpl's
mayEvict (#16445) (#16669)
add bb96c818048 [To dev/1.3] Pipe: Add metrics for TsFile parsing to
tablets (#16668) (#16673)
add b8e2147696b [To dev/1.3] Fix process logic of empty TsBlock in
InputLayer of TransformOperator (#16678) (#16679)
add 4cdb8e7e7a6 [To dev/1.3] SeriesScanUtil throws exception when using
filters that could not match any time range (#16692)
add 1fa468f39a0 [To dev/1.3] Load: Fixed an issue where premature
persistence of TSFileResource caused incorrect configuration to be not saved
(#16703)
add b1ae6dc5cfb [To dev/1.3][remove datanode] cherry pick related commits
(#16711)
add 90f65189f6a [To dev/1.3] Fixed the null error message of fetch schema
failed when the regions is removing (#16713) (#16718)
add 87dc62ebba8 [To dev/1.3] Pipe: Fixed the NPE of commit interval
(#16714) (#16723)
add 926f1959af1 [To dev/1.3] Active Load: Ignore
java.io.UncheckedIOException exceptions thrown during the file scanning
process. (#16705) (#16726)
add d890918e430 Fixed unprocessed column writes in Last Cache update
(#16728)
add 34e6f28aead [To dev/1.3] Make ErrMsg more readable when the predicate
has too many conjunctions because of too many devices #16716
add 6dca30348ef Pipe: Fix unhandled timeout exceptions in Thrift Client
(#16727) (#16731)
add 7acdb30ee9e chore!: Bind real config address for Thrift and Raft
services (#16717) (#16730)
add 9168f155d72 Fixed the NPE caused by concurrent "check for
createTimeSeries" and deleteTimeSeries (#16742) (#16745)
add 7c01dfb9578 Pipe: Optimized the default behavior in meta sync for
retries to wait for other regions (#16740) (#16746)
add de1649a8e55 Load: Fix the Session exit issue after type conversion
(#16037) (#16743)
add 583f0fa3293 [To dev/1.3] Load: Fixed parameter passing error in
MoveFile function (#16748) (#16749)
add 72a3f45884e [To dev/1.3] Pipe: Trimmed some of the pipe logs (#16747)
(#16754)
add f66794ba229 [To dev/1.3] feat: encode load attributes in active load
directories (#16722) (#16758)
add df136124e6f [To dev/1.3] Active Load: Fixes errors caused by Load
copying resource files. (#16753) (#16757)
add d1270deaf00 setup (#16752)
add 3d79e36bdf7 [To dev/1.3] Pipe: support path exclusion under tree model
(#16632) (#16763)
add a60d00ef8de [to dev/1.3] reduce error log when compaction service is
stopped & fix bugs (#16755)
add f0cdfe0f775 fix (#16702) (#16772)
add 403cf64f911 [To dev/1.3] Pipe: Modify the Pipe configuration item log
name to be consistent with the Properties name. (#16732) (#16759)
add 78630df7186 Set the parameter names from default_storage_group_level
to default_database_level (#16626) (#16646)
add 460a570e7f4 [To dev/1.3] Load: Fixed the bug that mods is not deleted
in load tsFile when there are exceptions & Fixed the potential NPE in air gap
agent close() method #16775 (#16776)
add a719e49e841 [To dev/1.3] Pipe IT: always throw exception with failure
when executing non-queries & Fixed some semantic errors of IT (#16331) (#16771)
add db774554716 [to dev/1.3] Fix slow query threshold & fix a bug for
lastQuery & optimize encodeBatch for multi tvlist scene (#16766)
add 90331aefdc7 [To dev/1.3] Fixed the bugs related to device auto-create
alignment ignorance (#16780) (#16782)
add c7ee924b88a [To dev/1.3] Load: Fixed the issue of TSFile parent
directory being null and TSFile resource being updated during the Load process.
(#16751) (#16790)
add 65ebd7c2922 [To dev/1.3] Load: Remove the getParentFile and exists
checks from Load New File (#16787)
add 1db0bc803e4 [To dev/1.3] Load : Fixed parameter passing error in
MoveFile function (#16748) (#16792)
add 1d267aaf7fd Bump ratis version to 3.2.1 (#16800)
add 752313eb684 Avoid connection reset error log printed (#16797) (#16802)
add beb979edc41 [To dev/1.3] Update ratis-thirdparty-misc.version to
1.0.10 (#16810)
add 05aeab1de56 [To dev/1.3] Cherry pick session connection leak fixes
(#16808)
add 480fc9971f0 Pipe: Adjusted the waiting time of temporary unavailable
exceptions (#16798) (#16805)
add eb063f13b10 Add a judgment in order to avoid occur NPE when one value
of measurementSchemas is null (#15574) (#16813)
add 9ec13a81c2f [To dev/1.3] Pipe: Fixed the check for no permission 2
(#16804) (#16815)
add 50563b6ee79 Pipe: Fixed the bug of missing parallel conflict check and
receiver log (#16814) (#16820)
add be828108388 Fixed the calculation error of schema cache (#16818)
(#16822)
add f0ec9c4a071 [To dev/1.3] Cherry-pick some IoTConsensus related commits
to 1.3 (#16812)
add bab1937f212 [To dev/1.3] Fixed the concurrency issue of region migrate
and load (#16796) (#16823)
add afcf6a78e52 Reduced the auth log when paths are too many (#16825)
(#16830)
add 64fdac183e4 Pipe: Ignore logging when `returnSelf` is called in the
event of an exception in `AsyncClient`. (#16828)
add 6a2178f87d2 [To dev/1.3] Fixed the schema cache calculation 2 & The
potential NPE caused by concurrent invalidate and update (#16834) & The schema
cache is not cleared for "clear schema cache" (#16833)
add 2ef195bb786 [To dev/1.3] Pipe: Fixed the bug that sender tablet may
cause NPE & The temporary exception may be wrongly reported (#16843) (#16848)
add ef4c336018b [to dev/1.3] Fix NPE during compaction when disk space is
insufficient (#16842)
add 302a866fc69 [To dev/1.3] Pipe: Prevent duplicate error logging in
AsyncPipeDataTransferServiceClient (#16856) (#16857)
add f2f9e975e3f [To dev/1.3] Pipe: Fixed the auth judgement NPE & Reduced
the log in InsertTabletStatement (#16859) (#16863)
add 80d5aea545d [To dev/1.3] PipePlugin: Optimized the errorCode && Fixed
the case-sensitive semantic (#16851) (#16852)
add d5c183482da Pipe: Fix NullPointerException in concurrent event access
(#16849) (#16872)
add abb25f4365b Removed the useless first key in schema cache (#16881)
add 9be174b795b [to dev/1.3] Optimize memtable region scan #16891
add d5feeb39316 [To dev/1.3] Load: Fix excessive GC caused by loading too
many TsFiles at once (#16853) (#16867)
add fea527da259 [To dev/1.3] Active Load: Add cleanup for active load
listening directories on DataNode first startup (#16854) (#16866)
add c2c27294f8b [To dev/1.3] Cherry-pick some CVE fixes (#16901)
add d2622f6cce3 [To dev/1.3] Load: Add check for reset memory size to 0 in
LoadTsFileMemoryManager (#16940) #16942
add e020df2aff6 [To dev/1.3] fix: memory to be released is larger than the
memory of memory block in TVList owner transfer case #16943 Open
add 4f979dc21e7 [To dev/1.3] Bump version to 1.3.7-SNAPSHOT (#16947)
add 9f8b4cc438e [To dev/1.3] Pipe: Implemented the
processTabletWithCollect api with tablet collector (#16941)
add bc2063f8882 fix: PR16943 type error (#16948)
add 910a623f91d fix: synchronized method in
ThreadSafeMemoryReservationManager #16950
add b30fd342ec7 [to dev/1.3] fix LastQueryScanNode sort #16956
add 345efb7d6eb Fix memory leak when allocation failure in IoTConsensus
queue (#16966)
add 2fe40b541b8 fix: reserve memory for sorting indices during query
execution (#16959)
add 9eb0272192c [to dev/1.3] fix mem table query bug (#16970)
add ffcc74ee044 Pipe: Fixed the bug that batch memory is not visible to
pipe memory management (#16962) (#16973)
add b48b46e61b1 Disabled the repeatable pipe log when the receiver is down
(#16963) (#16974)
add 013b4093ea3 [to dev/1.3] Further optimize the efficiency of memtable
region scan #16979
add edca502072f [To dev/1.3] Implemented minor fix of pipe IT (#16981)
add f372e51146c [To dev/1.3] Improve DeviceViewIntoOperator's return style
to pipeline (#16980)
add 61788479dd8 [To dev/1.3] Optimized the error log for schema execution
(#16982) (#16986)
add f9631fa058b [to dev/1.3] Fix incorrect overlap unpack when endTime
equals sentinel value #16993
add b681b506c7b Pipe: Refactored the PipeTaskCoordinatorLock (#16988)
(#16997)
add faba6c15989 Pipe: Reduced the log of processor memory control (#16989)
(#16996)
add 538e7caf7da [To dev/1.3] Ignore the pipe plugin failure when starting
a DataNode (#17000)
add 4dddc27f925 [to dev/1.3] Optimize
DeviceViewIntoOperator.findWritten(String device, String measurement) #17007
add e286da15b98 [To dev/1.3] Fix query error after insert an all null
aligned tablet and flush (#17041)
add e20171da2d7 [To dev/1.3] Pipe: Fixed the semantic of reporting
interval && Trimmed the "toString" of InsertMultiTabletsStatement (#17044)
(#17052)
add 9654f8ee90d Pipe: Trimmed the unnecessary device getting for
historical tsFiles (#17036) (#17050)
add b4949fbfc2b [To dev/1.3] Pipe: disable multiple path and path
exclusion (#17051)
add 63a7ae5dae7 [To dev/1.3] Pipe: support pattern pruning and redundancy
removal in TreePattern parsing (#17059)
add ba23a0b133c Change default dn rpc address (#17060) (#17068)
add 86bfeadf64f [to dev/1.3] fix last query bug #17072
add 32e6bc05423 [to dev/1.3] add IT for last query #17075
add 51f9a50c171 [To dev/1.3] Change all query example into iterator style
(#16187)
add 58d23a23fb0 [To dev/1.3] Delete unused and vulnerable rpc interface
(#16603) #17097
add adb620a794d [To dev/1.3] Remove built-in jexl function in tree mode
(#17095)
add 032df7cd8da [to dev/1.3] Fix allValueColDeletedMap index out of bound
caused by stale rowCount after TVList sort #17103
add a55519b9291 [To dev/1.3] Fix timeseries alias display in last for
TreeModel #17117
add 08611626578 [to dev/1.3] TimeFilter.canSkip() use getStatistics()
method (#17120)
add 230e3a857f8 [To dev/1.3][Bug fix] The partition table is cleaned
incorrectly when set only device TTL for tree mode (#17123) (#17126)
add b2a1e4b4f14 [To dev/1.3] Optimized the performance of subscription
(#17115) (#17121) (#17135)
add f7c3153b446 [To dev/1.3]Security fix: Bump Jetty to 9.4.58.v20250814
(CVE-2025-5115) (#17137)
add 784cd091ab3 [To dev/1.3] Fix sort branch release logic of SORT
operator #17149
add 91280d1554b [To dev/1.3] Fixed the potential NPE of schema quota
(#17140) (#17151)
add c7f03dfa9b4 Fix delete NPE after insert failed (#17122) (#17125)
add f6e3a12eab9 [To dev/1.3] Pipe: Banned the illegal names in pipe and
pipe plugins (#17145) (#17156)
add 0ecd0ec9eb8 Fixed the NPE when validating legacy sink (#17153) (#17161)
add 78da8c7ee58 [To dev/1.3] Fixed the bug that the template may create
measurements under timeSeries && Optimized the logger for meta user exceptions
#17158 (#17160)
add c8b11452d66 [To dev/1.3] Pipe: Fixed the legacy sink IT (#17164)
(#17165)
add 8d9e7a8c223 [To dev/1.3] Pipe: Fix IT (#17168)
add 723bdd256f6 Fix data export logic in IoTDB-1.3 to avoid redundant high
frequency query (#17076)
add b8e9a02c3d0 [To dev/1.3] Pipe: Optimized the logger semantic && the
retry logic of memory error at sink subtask (#17166) (#17174)
add 29e3c0af3a4 Ignore non-tsfile when importing tsfile (#17173)
add 42ca2f37a74 Pipe: Changed the separator check semantic for pipes /
pipe plugins (#17175) (#17183)
add 359787d929f Pipe: Fixed the idempotent semantic for MULTIPLE_ERROR
(#17177) (#17185)
add 250cba0ad4b [To dev/1.3] Pipe: Reduced the downgraded epochs'
downgrading limit to reduce the latency (#17184) (#17189)
add 2ff116b55ca [To dev/1.3] Pipe: Enabled locally retry for
PipeConnectionException (#17182) (#17190)
add 21421eca4b4 [To dev/1.3] Retry dispatch failed local write FI remotely
(#17187)
add ea49c8ff755 Pipe: Enabled retry locally for air gap receiver &
temporary unavailable exception (#17188) (#17199)
add c60c1f5d8c4 [To dev/1.3] Fix ddl overflow bug
add 4f456a3a00f [To dev/1.3] Fix race condition in SharedTsBlockQueue
async listener causing NPE in MemoryPool.free() (#17196) (#17204)
add eaaf53fbe6d [To dev/1.3] Pipe: Optimized the error code of illegal
pipe / pipe plugin name string (#17206)
add cfad276cdf9 Pipe: Configured the air gap timeout to avoid packet loss
(#17231) (#17253)
add f5142feff77 [To dev/1.3] Pipe: Fixed the bug that the default
"enable-send-tsfile-limit" is set to false for historical pipes split by full
sync (#17264) (#17265)
add a2991890a6d Fixed that InsertionCompactionSelection may skip a file
deleted by another compaction (#17254) (#17259)
add 6040fe30dce [to dev/1.3] Fix incorrect early termination in descending
scan of unpackOneFakeMemChunkMetaData
add cdde8cfc8b0 [To dev/1.3] Pipe: Fixed the crashed VM for ITs & Added
watcher thread for dataNode start (#17281) (#17282)
add 72d4d2b3918 [To dev/1.3] Pipe: Optimized the OPC UA logic to avoid
potential bugs (#17310)
add 69fb8a78d84 [To dev/1.3] Deleted the useless device flush map & Pipe:
Made the assigner cache to full cache & Use precise match in assigner device &
Print periodical log when assigner has exceeded half of the capacity (#17313)
add 729b95fcd47 [To dev/1.3] Subscription: refactor payload APIs to use
ResultSet and tsfile readers (#17307)
add 762ca728672 [To dev/1.3] Pipe: Use async launch to avoid blocking
datanode start (#17316)
add eacd93b0675 feat(subscription): support consumer timeout and idle
disconnect (#17300)
add 944002abbdc Remove extra user caching for REST services and migrate to
the unified user check cache. (#17324)
add 0f12dc5ab59 [To dev/1.3] Pipe: Added robustness to OPC UA measurement
logic (#17325)
add 038e7d8746d [To dev/1.3] Subscription: split client and example
modules (#17326)
add 82ed55fc122 Remove IoTDBOrderByForDebugIT. #17351
add d243a109492 [To dev/1.3] Fixed the REST partial insert & Pipe: Added
partial insert IT (#17339)
add 0b67cb824eb [To dev/1.3] Add extra client_ip and timeout columns for
show queries
add 044620e7f0b [To dev/1.3] Pipe: Fixed the log of disruptor queue &
deleted the useless binary buffer (#17341) (#17359)
add 7475bd4c556 [To dev/1.3] Fixed the default string charset in CI
(#17357)
add 81397b2156c [To dev/1.3] Pipe: Fixed the on committed hook square bug
& Trimmed the raw tablet hook & Fixed the premature report for source event &
Skipped the parsing of time-covered tsFile (#17360) (#17362)
add 4903f3c7e75 [To dev/1.3] Fix kill query doesn't take effect bug
(#17358)
add 58f94e2fbb8 Pipe: Implemented OPC Sink for outer server & Set
configuration and changed the default value of the server security policies &
Made the default quality configurable and does not throw when non-value/quality
measurement is encountered (#16944) (#17367)
add 064ba9e031c [To dev/1.3] Clean up tmp dirs of udf and sort while
starting up (#17377)
add e1095fd999b [To dev/1.3] Add result size limit and time slice control
for TransformOperator (#17402)
add b2a2462c9c4 [To dev/1.3] cpp session query timeout (#17403)
add 4b946d40ff3 [To dev/1.3] Remove OpenID authorizer and related
dependencies (#17406)
add 747811016a8 [To dev/1.3] Pipe: Fixed some potential OPC UA problems
(#17393) & Added IT for `` in opc (#17394)
add 6309e693871 [To dev/1.3] Pipe: Cleaned multiple potential problems in
pipe module (#17396) (#17417)
add 33fa6fa604e Subscription: Fixed multiple problems (#17418) (#17422)
add 03cc1bdfa35 Load: Fixed multiple bugs (#17413) (#17421)
add 28c4e020bc2 [To dev/1.3] Fix the deadlock at ConfigNode
PipeTaskCoordinatorLock (#17233) (#17424)
add 230cd633172 [to dev/1.3] fix: prevent NPE when isFinished() is called
before DataDriver init (#17441)
add 1f1d2c182c2 [To dev/1.3] Pipe: Fixed the OOM bug of tablet memory
calculation & Optimized the tablet size by memory estimation (#17451)
add 8ccd7c67600 [To dev/1.3] Subscription: Fixed the retry bug of
procedures & Pipe: Deleted some useless codes (#17455) (#17484)
add d34bd8d5aec [To dev/1.3] Pipe: Optimized the memory occupation of pipe
realtime source (#17450)(#17474) (#17486)
add c72b9675443 [To dev/1.3] Subscription: add removeUserData for messages
(#17479)
add 751c5c5829b Pipe: Refactor AirGap receiver with configurable payload
size control (#17443) (#17503)
add 8bf164037e7 [To dev/1.3] Improve state type validation in
CombineRequest deserialization. (#17449) (#17502)
add b8f33a6735c [To dev/1.3] Pipe: check file receiver write path (#17442)
(#17501)
add d6b0680dfd2 [To dev/1.3] Enhance the last query permission && Fixed
the rollback version of alter view / table plans && Deleted the unnecessary
mods in Tree view deletion (#17465) (#17494)
add 413b074e78c Pipe: Downgraded and reduced the log of
PipePushMetaRPCHandler (#17492) (#17519)
add c1556669dc3 Pipe: Fixed the OPC UA bug that drop pipe may not erase
the client (#17510) (#17522)
add 8d1ad63e955 [To dev/1.3] enhance cppclient tsblock deserialize
validation (#17464) (#17518)
add 9cadc71a819 [To dev/1.3] Load balance patch (#17463) (#17493) (#17527)
add ecef8f7cf83 [To dev/1.3] Pipe: Rewrote the OPC UA subscription logic
to avoid the bug of third-party subscription model (#17524)
add 4588b8d27a4 [To dev/1.3] Pipe: Upgraded bouncy castle && Added logs
for pipe tsFile parser (#17504) (#17523)
add 63ea91a83f8 [To dev/1.3] Enable show queries to be executed
immediately when the available memory in the memoryPool is insufficient (#17529)
add 57c012620c9 [to dev/1.3] fix AbstractEnv.ensureNodeStatus & Fix: send
set configuration only to target nodes and harden compaction schedule
interruption handling (#17447)
add 5c4853bdae8 fix (#17533)
add 9fff324b023 fix: catch exception during TVList ownership transfer to
avoid memory leak
add 037edfca49f Merge branch 'dev/1.3' of github.com:apache/iotdb into
fixdev/1.3
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 6 +-
.gitignore | 6 +
LICENSE-binary | 63 +-
NOTICE | 2 +-
NOTICE-binary | 2 +-
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 12 +-
docker/src/main/Dockerfile-1c1d | 4 +-
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 | 3 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 108 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 23 -
example/{mqtt-customize => subscription}/pom.xml | 9 +-
.../apache/iotdb/SubscriptionSessionExample.java | 18 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
integration-test/pom.xml | 38 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 7 +-
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../env/cluster/config/MppSharedCommonConfig.java | 6 -
.../iotdb/it/env/cluster/env/AbstractEnv.java | 84 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 6 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 4 +
.../it/env/remote/config/RemoteCommonConfig.java | 4 -
.../env/remote/config/RemoteConfigNodeConfig.java | 5 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 5 +
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 -
.../apache/iotdb/itbase/constant/TestConstant.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 6 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 -
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../itbase/runtime/ClusterTestConnection.java | 10 +-
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 14 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 11 +-
.../itbase/runtime/ParallelRequestDelegate.java | 9 +-
.../partition/IoTDBPartitionShuffleStrategyIT.java | 4 +-
.../partition/IoTDBPartitionTableAutoCleanIT.java | 57 +-
...IoTDBRegionOperationReliabilityITFramework.java | 23 +-
.../iotdb/db/it/IoTDBCustomizedClusterIT.java | 148 ++
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 25 +
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 14 +
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 105 ++
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 186 +++
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 269 +++-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 10 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 15 +
.../db/it/alignbydevice/IoTDBAlignByDevice2IT.java | 8 +-
.../db/it/alignbydevice/IoTDBAlignByDevice3IT.java | 8 +-
.../IoTDBAlignByDevice4IT.java} | 25 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 34 +-
.../IoTDBAlignByDeviceWithTemplate2IT.java | 8 +-
.../IoTDBAlignByDeviceWithTemplate3IT.java} | 24 +-
...DBAlignByDeviceWithTemplateAggregation2IT.java} | 25 +-
...oTDBAlignByDeviceWithTemplateAggregationIT.java | 4 +-
.../IoTDBAlignByDeviceWithTemplateIT.java | 11 +-
.../IoTDBOrderByLimitOffsetAlignByDevice2IT.java | 8 +-
...> IoTDBOrderByLimitOffsetAlignByDevice3IT.java} | 17 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 4 +-
.../IoTDBOrderByWithAlignByDevice2IT.java | 8 +-
.../IoTDBOrderByWithAlignByDevice3IT.java | 8 +-
.../IoTDBOrderByWithAlignByDevice4IT.java} | 25 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 4 +-
.../db/it/alignbydevice/IoTDBShuffleSink1IT.java | 8 +-
.../IoTDBShuffleSink1_2IT.java} | 28 +-
.../db/it/alignbydevice/IoTDBShuffleSink2IT.java | 10 +-
.../IoTDBShuffleSink2_2IT.java} | 28 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 128 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 16 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 16 +-
...stCache2IT.java => IoTDBLastQueryAlias2IT.java} | 2 +-
.../iotdb/db/it/last/IoTDBLastQueryAliasIT.java | 164 +++
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 52 +-
.../db/it/orderBy/IoTDBOrderByForDebugIT.java | 1410 --------------------
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 22 +
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 8 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 17 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 50 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 235 ----
.../org/apache/iotdb/db/it/utils/TestUtils.java | 80 ++
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 32 +-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 111 +-
.../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 12 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 128 +-
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 202 +--
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 226 ++--
.../pipe/it/autocreate/IoTDBPipeNullValueIT.java | 34 +-
.../it/autocreate/IoTDBPipePatternFormatIT.java | 658 +++++----
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 27 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 57 +-
.../it/autocreate/IoTDBPipeSinkCompressionIT.java | 47 +-
.../it/autocreate/IoTDBPipeSinkParallelIT.java | 15 +-
.../pipe/it/autocreate/IoTDBPipeSourceIT.java | 202 ++-
.../it/autocreate/IoTDBPipeSwitchStatusIT.java | 9 +-
.../pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 125 ++
.../pipe/it/autocreate/IoTDBPipeWithLoadIT.java | 15 +-
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 138 +-
.../pipe/it/manual/IoTDBPipeManualConflictIT.java | 28 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 33 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 17 +-
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 24 +-
.../it/manual/IoTDBPipeMultiSchemaRegionIT.java | 14 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 15 +-
.../pipe/it/manual/IoTDBPipeReqAutoSliceIT.java | 4 +-
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 660 +++++++++
.../manual/IoTDBPipeTypeConversionISessionIT.java | 4 +-
.../pipe/it/manual/IoTDBPipeTypeConversionIT.java | 30 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 49 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 268 +++-
.../iotdb/pipe/it/triple/IoTDBPipeForwardIT.java | 5 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 96 ++
.../iotdb/session/it/IoTDBSessionQueryIT.java | 79 ++
.../it/cluster/IoTDBSubscriptionRestartIT.java | 25 +-
.../it/dual/AbstractSubscriptionDualIT.java | 4 -
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 130 +-
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 5 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 39 +-
.../it/local/AbstractSubscriptionLocalIT.java | 1 -
.../it/local/IoTDBSubscriptionBasicIT.java | 31 +-
.../it/local/IoTDBSubscriptionDataTypeIT.java | 34 +-
.../it/local/IoTDBSubscriptionIdempotentIT.java | 4 +
.../it/local/IoTDBSubscriptionMessageIT.java | 184 +++
.../it/local/IoTDBSubscriptionTopicIT.java | 5 +
.../it/triple/AbstractSubscriptionTripleIT.java | 5 -
.../it/triple/IoTDBSubscriptionSharingIT.java | 50 +-
.../AbstractSubscriptionRegressionIT.java | 12 +-
.../IoTDBDefaultPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultTsfilePushConsumerIT.java | 4 +-
.../IoTDBRootDatasetPushConsumerIT.java | 8 +-
.../IoTDBRootPullConsumeTsfileIT.java | 2 +
...merPullConsumerWith1TopicShareProcessMixIT.java | 8 +-
.../param/IoTDBTestParamPullConsumerIT.java | 30 +-
.../param/IoTDBTestParamPushConsumerIT.java | 29 +-
.../param/IoTDBTestParamSubscriptionSessionIT.java | 6 +
.../regression/param/IoTDBTestParamTopicIT.java | 20 +
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 5 +-
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 5 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 20 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDBPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 2 +
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 2 +
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBTSPatternPullConsumerDataSetIT.java | 2 +
.../time/IoTDBAllPullConsumerDataSetIT.java | 2 +
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 2 +
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 2 +
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 2 +
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 2 +
.../format/IoTDBTestPushConsumeDataSetIT.java | 8 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 4 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 4 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 8 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 8 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 8 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 8 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 8 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 4 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 8 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 8 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 4 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 12 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 6 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 50 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 8 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 14 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 4 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 8 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 8 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 8 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 8 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 8 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 4 +-
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 8 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 4 +-
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 8 +-
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 8 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 4 +-
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 2 +
.../regression/topic/IoTDBTestTopicNameIT.java | 2 +
.../regression/user/IoTDBOtherUserConsumerIT.java | 8 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 3 +-
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
.../{RowCollector.java => DataCollector.java} | 17 +-
.../{RowCollector.java => TabletCollector.java} | 14 +-
.../api/customizer/parameter/PipeParameters.java | 51 +-
.../event/dml/insertion/TabletInsertionEvent.java | 11 +
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
iotdb-client/cli/pom.xml | 22 +-
.../org/apache/iotdb/tool/data/ExportData.java | 268 ++--
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 9 +-
.../iotdb/tool/tsfile/ImportTsFileScanTool.java | 3 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-cpp/src/main/ColumnDecoder.cpp | 3 +
iotdb-client/client-cpp/src/main/Common.cpp | 46 +-
iotdb-client/client-cpp/src/main/Common.h | 8 +
.../client-cpp/src/main/IoTDBRpcDataSet.cpp | 1 +
.../client-cpp/src/main/SessionConnection.cpp | 2 +-
iotdb-client/client-cpp/src/main/TsBlock.cpp | 12 +
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 67 +
.../client-py/iotdb/utils/IoTDBRpcDataSet.py | 12 +-
iotdb-client/client-py/pom.xml | 6 +-
.../client-py/tests/integration/test_todf.py | 2 +-
iotdb-client/isession/pom.xml | 8 +-
iotdb-client/jdbc/pom.xml | 8 +-
iotdb-client/pom.xml | 3 +-
iotdb-client/service-rpc/pom.xml | 11 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 57 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
iotdb-client/session/pom.xml | 10 +-
.../apache/iotdb/session/SessionConnection.java | 16 +-
.../payload/SubscriptionSessionDataSet.java | 188 ---
.../SubscriptionSessionDataSetsHandler.java | 69 -
.../src/test/resources/iotdb-common.properties | 9 -
iotdb-client/{isession => subscription}/pom.xml | 43 +-
.../rpc/subscription/config/ConsumerConfig.java | 12 +
.../rpc/subscription/config/ConsumerConstant.java | 3 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 10 +-
.../rpc/subscription/config/TopicConstant.java | 11 +-
.../exception/SubscriptionConnectionException.java | 0
.../exception/SubscriptionException.java | 0
.../SubscriptionIdentifierSemanticException.java | 0
.../SubscriptionIncompatibleHandlerException.java | 0
.../SubscriptionParameterNotValidException.java | 0
.../SubscriptionPayloadExceedException.java | 0
.../SubscriptionPipeTimeoutException.java | 0
.../SubscriptionPollTimeoutException.java | 0
.../SubscriptionRuntimeCriticalException.java | 0
.../exception/SubscriptionRuntimeException.java | 0
.../SubscriptionRuntimeNonCriticalException.java | 0
.../exception/SubscriptionTimeoutException.java | 0
.../subscription/payload/poll/ErrorPayload.java | 0
.../subscription/payload/poll/FileInitPayload.java | 0
.../payload/poll/FilePiecePayload.java | 0
.../subscription/payload/poll/FileSealPayload.java | 0
.../subscription/payload/poll/PollFilePayload.java | 0
.../rpc/subscription/payload/poll/PollPayload.java | 0
.../payload/poll/PollTabletsPayload.java | 0
.../payload/poll/SubscriptionCommitContext.java | 0
.../payload/poll/SubscriptionPollPayload.java | 0
.../payload/poll/SubscriptionPollRequest.java | 0
.../payload/poll/SubscriptionPollRequestType.java | 0
.../payload/poll/SubscriptionPollResponse.java | 0
.../payload/poll/SubscriptionPollResponseType.java | 0
.../subscription/payload/poll/TabletsPayload.java | 0
.../payload/poll/TerminationPayload.java | 0
.../payload/request/PipeSubscribeCloseReq.java | 0
.../payload/request/PipeSubscribeCommitReq.java | 0
.../payload/request/PipeSubscribeHandshakeReq.java | 0
.../payload/request/PipeSubscribeHeartbeatReq.java | 0
.../payload/request/PipeSubscribePollReq.java | 0
.../payload/request/PipeSubscribeRequestType.java | 0
.../request/PipeSubscribeRequestVersion.java | 0
.../payload/request/PipeSubscribeSubscribeReq.java | 0
.../request/PipeSubscribeUnsubscribeReq.java | 0
.../payload/response/PipeSubscribeCloseResp.java | 0
.../payload/response/PipeSubscribeCommitResp.java | 0
.../response/PipeSubscribeHandshakeResp.java | 0
.../response/PipeSubscribeHeartbeatResp.java | 0
.../payload/response/PipeSubscribePollResp.java | 0
.../response/PipeSubscribeResponseType.java | 0
.../response/PipeSubscribeResponseVersion.java | 0
.../response/PipeSubscribeSubscribeResp.java | 0
.../response/PipeSubscribeUnsubscribeResp.java | 0
.../session/subscription/SubscriptionSession.java | 0
.../SubscriptionSessionConnection.java | 0
.../session/subscription/consumer/AckStrategy.java | 0
.../subscription/consumer/AsyncCommitCallback.java | 0
.../subscription/consumer/ConsumeListener.java | 0
.../subscription/consumer/ConsumeResult.java | 0
.../consumer/SubscriptionConsumer.java | 74 +-
.../SubscriptionExecutorServiceManager.java | 0
.../consumer/SubscriptionProvider.java | 15 +-
.../consumer/SubscriptionProviders.java | 0
.../consumer/SubscriptionPullConsumer.java | 35 +-
.../consumer/SubscriptionPushConsumer.java | 6 +
.../session/subscription/model/Subscription.java | 0
.../iotdb/session/subscription/model/Topic.java | 0
.../payload/SubscriptionFileHandler.java | 7 -
.../subscription/payload/SubscriptionMessage.java | 64 +-
.../payload/SubscriptionMessageHandler.java | 4 +-
.../payload/SubscriptionMessageType.java | 4 +-
.../payload/SubscriptionRecordHandler.java | 245 ++++
.../payload/SubscriptionTsFileHandler.java | 5 -
.../session/subscription/util/CollectionUtils.java | 0
.../session/subscription/util/IdentifierUtils.java | 0
.../iotdb/session/subscription/util/PollTimer.java | 0
.../subscription/util/RandomStringGenerator.java | 0
.../session/subscription/util/SetPartitioner.java | 0
iotdb-core/ainode/pom.xml | 10 +-
iotdb-core/ainode/pyproject.toml | 2 +-
iotdb-core/antlr/pom.xml | 2 +-
iotdb-core/confignode/pom.xml | 31 +-
.../async/handlers/rpc/PipePushMetaRPCHandler.java | 6 +-
.../confignode/conf/ConfigNodeDescriptor.java | 3 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 3 +-
.../confignode/manager/ClusterQuotaManager.java | 5 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../iotdb/confignode/manager/TTLManager.java | 14 +
.../manager/load/balancer/RouteBalancer.java | 4 +
.../region/GreedyCopySetRegionGroupAllocator.java | 361 ++++-
.../region/GreedyRegionGroupAllocator.java | 13 +
.../balancer/region/IRegionGroupAllocator.java | 21 +
...artiteGraphReplicationRegionGroupAllocator.java | 13 +
.../router/leader/AbstractLeaderBalancer.java | 1 +
...LeaderBalancer.java => HashLeaderBalancer.java} | 55 +-
.../manager/load/service/EventService.java | 5 +
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../agent/plugin/PipeConfigNodePluginAgent.java | 4 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 30 +-
.../runtime/heartbeat/PipeHeartbeat.java | 2 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 30 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 59 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 9 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 6 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 10 +-
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 44 +-
.../subscription/SubscriptionCoordinator.java | 10 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 10 +-
.../iotdb/confignode/persistence/TTLInfo.java | 17 +
.../persistence/pipe/PipePluginInfo.java | 2 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../confignode/persistence/quota/QuotaInfo.java | 4 +-
.../persistence/subscription/SubscriptionInfo.java | 51 +-
.../procedure/PartitionTableAutoCleaner.java | 7 +-
.../procedure/env/RemoveDataNodeHandler.java | 186 +++
.../impl/node/RemoveDataNodesProcedure.java | 6 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../impl/schema/AlterLogicalViewProcedure.java | 10 +-
.../impl/schema/DataNodeRegionTaskExecutor.java | 19 +-
.../impl/schema/DataNodeTSStatusTaskExecutor.java | 113 ++
.../impl/schema/DeactivateTemplateProcedure.java | 58 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 64 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 63 +-
.../procedure/impl/schema/SchemaUtils.java | 12 +-
.../impl/schema/SetTemplateProcedure.java | 12 +-
.../AbstractOperateSubscriptionProcedure.java | 1 +
.../GreedyCopySetRemoveNodeReplicaSelectTest.java | 370 +++++
...eConfigPhysicalPlanPatternParseVisitorTest.java | 7 +-
.../schema/DataNodeRegionTaskExecutorTest.java | 81 ++
iotdb-core/consensus/pom.xml | 14 +-
.../DeserializedBatchIndexedConsensusRequest.java | 7 +
.../common/request/IndexedConsensusRequest.java | 10 +
.../consensus/iot/client/DispatchLogHandler.java | 5 +
.../iotdb/consensus/iot/logdispatcher/Batch.java | 25 +-
.../logdispatcher/IoTConsensusMemoryManager.java | 137 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 38 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 23 +-
.../service/IoTConsensusRPCServiceProcessor.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 1 +
.../IoTConsensusMemoryManagerTest.java | 207 +++
iotdb-core/datanode/pom.xml | 84 +-
.../assembly/resources/conf/logback-datanode.xml | 15 -
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 9 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 90 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 40 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 10 -
.../db/consensus/DataRegionConsensusImpl.java | 6 +
.../dataregion/DataRegionStateMachine.java | 15 +-
.../schemaregion/SchemaExecutionVisitor.java | 110 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 13 +-
.../dataregion/PipeDataRegionPluginAgent.java | 4 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 4 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 7 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 12 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 5 +-
.../agent/task/connection/PipeEventCollector.java | 7 +-
.../pipe/agent/task/stage/PipeTaskSinkStage.java | 12 +-
.../pipe/agent/task/stage/PipeTaskSourceStage.java | 4 +-
.../subtask/processor/PipeProcessorSubtask.java | 37 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 11 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 41 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 6 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 49 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 20 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 48 +-
.../common/tablet/PipeRawTabletEventConverter.java | 50 +
.../common/tablet/PipeRawTabletInsertionEvent.java | 44 +-
.../common/tablet/PipeTabletCollector.java} | 35 +-
.../tablet/TabletInsertionDataContainer.java | 8 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 13 +-
.../container/TsFileInsertionDataContainer.java | 104 +-
.../TsFileInsertionDataContainerProvider.java | 51 +-
.../query/TsFileInsertionQueryDataContainer.java | 104 +-
.../TsFileInsertionQueryDataTabletIterator.java | 33 +-
.../scan/TsFileInsertionScanDataContainer.java | 403 ++++--
.../tsfile/parser/util/ModsOperationUtil.java | 315 +++++
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 10 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 2 +-
.../overview/PipeTsFileToTabletsMetrics.java | 67 +
.../receiver/PipeDataNodeReceiverMetrics.java | 4 +-
.../processor/aggregate/AggregateProcessor.java | 4 +-
.../twostage/exchange/payload/CombineRequest.java | 10 +-
.../exchange/sender/TwoStageAggregateSender.java | 5 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 87 +-
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 7 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 7 +-
.../protocol/legacy/loader/DeletionLoader.java | 2 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 29 +-
...peStatementDataTypeConvertExecutionVisitor.java | 16 +-
.../visitor/PipeStatementExceptionVisitor.java | 8 +-
.../visitor/PipeStatementPatternParseVisitor.java | 22 +-
.../visitor/PipeStatementTSStatusVisitor.java | 206 ++-
.../resource/memory/InsertNodeMemoryEstimator.java | 4 +
.../resource/memory/PipeDynamicMemoryBlock.java | 4 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 92 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 8 +-
.../evolvable/batch/PipeTabletEventBatch.java | 6 +
.../evolvable/batch/PipeTabletEventPlainBatch.java | 31 +-
.../batch/PipeTabletEventTsFileBatch.java | 9 +-
.../request/PipeTransferTabletBatchReq.java | 54 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 3 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 16 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 3 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 13 +-
.../pipe/sink/protocol/opcua/OpcUaNameSpace.java | 390 ------
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 339 ++++-
.../sink/protocol/opcua/client/ClientRunner.java | 159 +++
.../opcua/client}/IoTDBKeyStoreLoaderClient.java | 35 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 370 +++++
.../opcua/{ => server}/OpcUaKeyStoreLoader.java | 16 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 615 +++++++++
.../opcua/{ => server}/OpcUaServerBuilder.java | 110 +-
.../pipeconsensus/PipeConsensusAsyncSink.java | 13 +-
.../pipeconsensus/PipeConsensusSyncSink.java | 22 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 2 +-
.../PipeConsensusTransferBatchReqBuilder.java | 16 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 63 +-
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../handler/PipeTransferTrackableHandler.java | 16 +-
.../async/handler/PipeTransferTsFileHandler.java | 28 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 3 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 7 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 3 +-
.../websocket/WebSocketConnectorServer.java | 23 +-
.../sink/protocol/writeback/WriteBackSink.java | 23 +-
.../db/pipe/sink/util/PipeTabletEventSorter.java | 5 +
.../source/dataregion/IoTDBDataRegionSource.java | 6 +-
.../PipeHistoricalDataRegionTsFileSource.java | 8 +-
.../PipeRealtimeDataRegionHybridSource.java | 51 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 42 +-
.../realtime/PipeRealtimeDataRegionSource.java | 46 +-
.../PipeRealtimeDataRegionTsFileSource.java | 18 +-
.../realtime/assigner/DisruptorQueue.java | 30 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 6 +-
.../matcher/CachedSchemaPatternMatcher.java | 22 +-
.../schemaregion/PipePlanPatternParseVisitor.java | 39 +-
.../protocol/rest/filter/AuthorizationFilter.java | 11 +-
.../iotdb/db/protocol/rest/filter/UserCache.java | 57 -
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 51 +-
.../iotdb/db/protocol/session/SessionManager.java | 6 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 367 ++---
.../impl/DataNodeInternalRPCServiceImpl.java | 11 +-
.../db/queryengine/common/MPPQueryContext.java | 38 +-
.../iotdb/db/queryengine/common/SessionInfo.java | 16 +-
.../common/header/ColumnHeaderConstant.java | 8 +-
.../queryengine/execution/QueryStateMachine.java | 6 +-
.../queryengine/execution/driver/DataDriver.java | 5 +
.../db/queryengine/execution/driver/Driver.java | 4 +-
.../queryengine/execution/driver/SchemaDriver.java | 5 +
.../execution/exchange/MPPDataExchangeManager.java | 56 +-
.../execution/exchange/SharedTsBlockQueue.java | 91 +-
.../execution/exchange/sink/SinkChannel.java | 62 +-
.../execution/exchange/source/SourceHandle.java | 90 +-
.../execution/executor/RegionReadExecutor.java | 14 +-
.../execution/executor/RegionWriteExecutor.java | 4 +-
.../fragment/FragmentInstanceContext.java | 92 +-
.../fragment/FragmentInstanceExecution.java | 2 +-
.../fragment/FragmentInstanceManager.java | 4 +
.../queryengine/execution/memory/MemoryPool.java | 56 +-
.../operator/process/AbstractIntoOperator.java | 19 +-
.../operator/process/DeviceViewIntoOperator.java | 112 +-
.../execution/operator/process/IntoOperator.java | 37 +-
.../execution/operator/process/SortOperator.java | 4 +-
.../operator/process/TransformOperator.java | 18 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 25 +-
.../operator/process/last/LastQueryOperator.java | 6 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../last/UpdateViewPathLastCacheOperator.java | 2 +-
.../execution/operator/source/SeriesScanUtil.java | 248 +++-
.../operator/source/ShowQueriesOperator.java | 3 +
.../execution/schedule/AbstractDriverThread.java | 4 +-
.../execution/schedule/task/DriverTask.java | 10 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 35 +-
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 26 +-
.../plan/analyze/ClusterPartitionFetcher.java | 30 +-
.../queryengine/plan/analyze/PredicateUtils.java | 16 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 42 +-
.../db/queryengine/plan/analyze/TemplatedInfo.java | 6 +-
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../analyze/cache/schema/DataNodeSchemaCache.java | 7 -
.../analyze/cache/schema/DeviceCacheEntry.java | 6 +-
.../plan/analyze/cache/schema/DeviceLastCache.java | 47 +-
.../analyze/cache/schema/DeviceNormalSchema.java | 6 +-
.../analyze/cache/schema/DeviceSchemaCache.java | 127 +-
.../{IDualKeyCache.java => ICache.java} | 42 +-
.../{IDualKeyCacheStats.java => ICacheStats.java} | 2 +-
.../dualkeycache/IDualKeyCacheComputation.java | 43 -
...{DualKeyCacheBuilder.java => CacheBuilder.java} | 30 +-
.../cache/schema/dualkeycache/impl/CacheEntry.java | 86 ++
.../dualkeycache/impl/CacheEntryGroupImpl.java | 52 +-
.../cache/schema/dualkeycache/impl/CacheImpl.java | 203 +++
.../schema/dualkeycache/impl/CacheLinkedList.java | 63 +
.../{DualKeyCachePolicy.java => CachePolicy.java} | 2 +-
.../dualkeycache/impl/CacheSizeComputerImpl.java | 14 +-
.../cache/schema/dualkeycache/impl/CacheStats.java | 4 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 417 ------
.../dualkeycache/impl/FIFOCacheEntryManager.java | 176 +--
.../schema/dualkeycache/impl/ICacheEntry.java | 41 -
.../schema/dualkeycache/impl/ICacheEntryGroup.java | 16 +-
.../dualkeycache/impl/ICacheEntryManager.java | 28 +-
.../dualkeycache/impl/ICacheSizeComputer.java | 4 +-
.../dualkeycache/impl/LRUCacheEntryManager.java | 143 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 24 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 52 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 50 +-
.../plan/execution/IQueryExecution.java | 30 +-
.../queryengine/plan/execution/QueryExecution.java | 115 +-
.../plan/execution/config/ConfigExecution.java | 37 +-
.../config/executor/ClusterConfigTaskExecutor.java | 252 ++--
.../execution/config/sys/pipe/CreatePipeTask.java | 2 +-
.../visitor/ConcatDeviceVisitor.java} | 17 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 12 +-
.../plan/parser/StatementGenerator.java | 2 +-
.../db/queryengine/plan/planner/IPlanner.java | 4 +-
.../plan/planner/LocalExecutionPlanner.java | 8 +
.../plan/planner/LogicalPlanBuilder.java | 55 +-
.../plan/planner/LogicalPlanVisitor.java | 11 +-
.../plan/planner/OperatorTreeGenerator.java | 69 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 5 +-
.../plan/planner/distribution/SourceRewriter.java | 81 +-
.../memory/FakedMemoryReservationManager.java | 11 +
.../planner/memory/MemoryReservationManager.java | 29 +
.../NotThreadSafeMemoryReservationManager.java | 23 +
.../memory/ThreadSafeMemoryReservationManager.java | 13 +
.../plan/planner/plan/FragmentInstance.java | 2 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 7 +-
.../metedata/read/SeriesSchemaFetchScanNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedInsertNode.java | 4 +-
.../planner/plan/node/process/AggregationNode.java | 2 +-
.../plan/node/process/RawDataAggregationNode.java | 2 +-
.../plan/node/process/last/LastQueryNode.java | 11 +-
.../plan/node/source/LastQueryScanNode.java | 103 +-
.../node/source/SeriesAggregationSourceNode.java | 4 +-
.../planner/plan/node/source/ShowQueriesNode.java | 12 +-
.../planner/plan/node/write/DeleteDataNode.java | 9 +-
.../plan/node/write/InsertMultiTabletsNode.java | 3 +-
.../planner/plan/node/write/InsertRowsNode.java | 3 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 3 +-
.../planner/plan/node/write/InsertTabletNode.java | 2 +-
.../plan/planner/plan/node/write/SearchNode.java | 3 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 5 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 5 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 97 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 12 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 11 +-
.../db/queryengine/plan/statement/Statement.java | 27 +
.../crud/InsertMultiTabletsStatement.java | 12 +
.../plan/statement/crud/InsertRowStatement.java | 25 +
.../plan/statement/crud/InsertRowsStatement.java | 5 +
.../plan/statement/crud/InsertTabletStatement.java | 54 +-
.../plan/statement/crud/LoadTsFileStatement.java | 60 +-
.../metadata/pipe/CreatePipeStatement.java | 20 +-
.../dag/input/QueryDataSetInputLayer.java | 10 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 27 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 8 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 21 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 19 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 103 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 81 +-
.../schemaengine/schemaregion/utils/MetaUtils.java | 6 +-
.../schemaregion/utils/ResourceByPathUtils.java | 4 +-
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 10 +
.../write/req/impl/CreateTimeSeriesPlanImpl.java | 10 +
.../java/org/apache/iotdb/db/service/DataNode.java | 43 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 31 +-
.../db/service/TemporaryQueryDataFileService.java | 20 +-
.../metrics/IoTDBInternalLocalReporter.java | 2 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 3 +-
.../iotdb/db/storageengine/StorageEngine.java | 9 +-
.../db/storageengine/dataregion/DataRegion.java | 169 ++-
.../dataregion/HashLastFlushTimeMap.java | 44 -
.../dataregion/IDataRegionForQuery.java | 2 +-
.../dataregion/ILastFlushTimeMap.java | 6 -
.../dataregion/VirtualDataRegion.java | 2 +-
.../execute/task/AbstractCompactionTask.java | 3 +-
.../execute/task/InnerSpaceCompactionTask.java | 17 +-
.../compaction/repair/RepairTimePartition.java | 2 +-
.../schedule/CompactionScheduleTaskManager.java | 9 +
.../schedule/CompactionScheduleTaskWorker.java | 21 +-
.../compaction/schedule/TTLScheduleTask.java | 17 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +
.../dataregion/flush/MemTableFlushTask.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 90 +-
.../memtable/AbstractWritableMemChunk.java | 4 +-
.../memtable/AlignedReadOnlyMemChunk.java | 47 +-
.../memtable/AlignedWritableMemChunk.java | 181 ++-
.../memtable/AlignedWritableMemChunkGroup.java | 5 +
.../dataregion/memtable/IMemTable.java | 6 +-
.../memtable/IWritableMemChunkGroup.java | 2 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 33 +-
.../dataregion/memtable/TsFileProcessor.java | 43 +-
.../dataregion/memtable/WritableMemChunk.java | 86 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 5 +
.../dataregion/read/QueryDataSource.java | 5 +
.../read/reader/common/NoDataPointReader.java} | 37 +-
.../dataregion/snapshot/SnapshotTaker.java | 12 +-
.../dataregion/tsfile/TsFileResource.java | 66 +-
.../storageengine/dataregion/wal/WALManager.java | 14 +-
.../db/storageengine/load/LoadTsFileManager.java | 26 +-
.../storageengine/load/active/ActiveLoadAgent.java | 90 ++
.../load/active/ActiveLoadDirScanner.java | 20 +-
.../active/ActiveLoadFailedMessageHandler.java | 45 +-
.../load/active/ActiveLoadPathHelper.java | 256 ++++
.../load/active/ActiveLoadPendingQueue.java | 49 +-
.../load/active/ActiveLoadTsFileLoader.java | 156 ++-
.../storageengine/load/active/ActiveLoadUtil.java | 39 +-
.../load/config/LoadTsFileConfigurator.java | 24 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 8 +-
.../converter/LoadTsFileDataTypeConverter.java | 49 +-
.../db/storageengine/load/disk/MinIOSelector.java | 10 +-
.../load/memory/LoadTsFileMemoryManager.java | 9 +-
.../load/metrics/LoadTsFileCostMetricsSet.java | 2 +-
.../agent/SubscriptionBrokerAgent.java | 2 +-
.../agent/SubscriptionConsumerAgent.java | 1 -
.../agent/SubscriptionReceiverAgent.java | 26 +-
.../subscription/agent/SubscriptionTopicAgent.java | 21 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 2 +-
.../receiver/SubscriptionReceiver.java | 2 +
.../receiver/SubscriptionReceiverV1.java | 144 +-
.../task/stage/SubscriptionTaskSinkStage.java | 16 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 37 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 11 +-
.../db/utils/datastructure/AlignedTVList.java | 114 +-
.../db/utils/datastructure/BackAlignedTVList.java | 3 +-
.../db/utils/datastructure/BackBinaryTVList.java | 3 +-
.../db/utils/datastructure/BackBooleanTVList.java | 3 +-
.../db/utils/datastructure/BackDoubleTVList.java | 3 +-
.../db/utils/datastructure/BackFloatTVList.java | 3 +-
.../db/utils/datastructure/BackIntTVList.java | 3 +-
.../db/utils/datastructure/BackLongTVList.java | 3 +-
.../iotdb/db/utils/datastructure/LazyBitMap.java | 93 ++
.../db/utils/datastructure/MemPointIterator.java | 3 +
.../MergeSortMultiAlignedTVListIterator.java | 22 +
.../MergeSortMultiTVListIterator.java | 22 +
.../OrderedMultiAlignedTVListIterator.java | 24 +
.../datastructure/OrderedMultiTVListIterator.java | 24 +
.../db/utils/datastructure/QuickAlignedTVList.java | 3 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 3 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 3 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 3 +-
.../db/utils/datastructure/QuickFloatTVList.java | 3 +-
.../db/utils/datastructure/QuickIntTVList.java | 3 +-
.../db/utils/datastructure/QuickLongTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TVList.java | 256 +++-
.../db/utils/datastructure/TimAlignedTVList.java | 3 +-
.../db/utils/datastructure/TimBinaryTVList.java | 3 +-
.../db/utils/datastructure/TimBooleanTVList.java | 3 +-
.../db/utils/datastructure/TimDoubleTVList.java | 3 +-
.../db/utils/datastructure/TimFloatTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 3 +-
.../db/utils/datastructure/TimLongTVList.java | 3 +-
.../iotdb/db/utils/sort/FileSpillerReader.java | 5 +
.../apache/iotdb/db/utils/sort/MemoryReader.java | 5 +
.../org/apache/iotdb/db/utils/sort/SortReader.java | 3 +
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 51 +
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 112 --
.../db/auth/role/LocalFileRoleManagerTest.java | 15 +-
.../schemaregion/SchemaExecutionVisitorTest.java | 277 ++++
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 13 +
.../db/metadata/path/MeasurementPathTest.java | 4 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 4 +-
.../event/TsFileInsertionDataContainerTest.java | 49 +-
.../tsfile/parser/util/ModsOperationUtilTest.java | 406 ++++++
.../db/pipe/pattern/IoTDBPipePatternTest.java | 5 +
.../db/pipe/pattern/PipePatternCoverageTest.java | 133 ++
.../db/pipe/pattern/PipePatternPruningTest.java | 156 +++
.../receiver/PipeStatementTsStatusVisitorTest.java | 65 +
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 72 +
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 61 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 89 ++
.../sink/PipeStatementPatternParseVisitorTest.java | 207 ++-
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 2 +
.../source/PipePlanPatternParseVisitorTest.java | 7 +-
.../db/queryengine/execution/DataDriverTest.java | 127 +-
.../execution/exchange/LocalSinkChannelTest.java | 10 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 83 +-
.../execution/exchange/ShuffleSinkHandleTest.java | 5 +-
.../execution/exchange/SourceHandleTest.java | 5 +-
.../db/queryengine/execution/exchange/Utils.java | 26 +-
.../fragment/FragmentInstanceExecutionTest.java | 243 +++-
.../execution/memory/MemoryPoolTest.java | 116 +-
.../execution/operator/MergeSortOperatorTest.java | 21 +-
.../operator/SortOperatorSortBranchTest.java | 206 +++
.../execution/operator/TransformOperatorTest.java | 277 ++++
.../db/queryengine/plan/analyze/AnalyzeTest.java | 2 +-
.../execution/ClusterConfigTaskExecutorTest.java | 83 ++
.../plan/optimization/LimitOffsetPushDownTest.java | 2 +-
.../plan/planner/FragmentInstanceSerdeTest.java | 3 +-
.../plan/planner/distribution/LastQueryTest.java | 59 +-
.../logical/DataQueryLogicalPlannerTest.java | 11 +-
.../planner/logical/LogicalPlannerTestUtil.java | 2 +-
.../node/source/LastQueryScanNodeSerdeTest.java | 2 +
.../statement/sys/pipe/PipeStatementTest.java | 8 +-
.../DataNodeInternalRPCServiceImplTest.java | 59 +-
.../iotdb/db/storageengine/StorageEngineTest.java | 4 +-
.../storageengine/dataregion/DataRegionTest.java | 4 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 16 +
.../repair/RepairUnsortedFileSchedulerTest.java | 10 +-
.../compaction/utils/CompactionTestFileWriter.java | 6 +-
.../memtable/AlignedTVListIteratorTest.java | 145 ++
.../memtable/NonAlignedTVListIteratorTest.java | 87 ++
.../dataregion/memtable/PrimitiveMemTableTest.java | 54 +
.../memtable/WritableMemChunkRegionScanTest.java | 375 ++++++
.../dataregion/snapshot/IoTDBSnapshotTest.java | 2 +-
.../receiver/SubscriptionReceiverV1Test.java | 114 ++
.../src/test/resources/iotdb-common.properties | 9 -
.../src/test/resources/iotdb-system.properties | 9 -
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 9 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 49 +-
.../resources/conf/iotdb-system.properties | 2 +-
.../conf/iotdb-system.properties.template | 24 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 266 ----
.../apache/iotdb/commons/client/ClientManager.java | 25 +
.../iotdb/commons/client/ClientPoolFactory.java | 21 +-
.../apache/iotdb/commons/client/ThriftClient.java | 3 +-
.../async/AsyncPipeDataTransferServiceClient.java | 21 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 458 +++++--
.../iotdb/commons/conf/CommonDescriptor.java | 13 +-
.../exception/pipe/PipeNonReportException.java | 27 -
.../pipe/PipeRuntimeSinkCriticalException.java | 2 +-
...imeSinkNonReportTimeConfigurableException.java} | 42 +-
...RuntimeSinkRetryTimesConfigurableException.java | 31 +
.../commons/executable/ExecutableManager.java | 4 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 26 -
.../org/apache/iotdb/commons/path/PartialPath.java | 26 +
.../apache/iotdb/commons/path/PathPatternTree.java | 49 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 66 +-
.../runtime/AbstractPipePeriodicalJobExecutor.java | 4 +
.../task/connection/BlockingPendingQueue.java | 21 +-
.../connection/UnboundedBlockingPendingQueue.java | 4 +
.../task/progress/interval/PipeCommitInterval.java | 7 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 94 +-
.../agent/task/subtask/PipeReportableSubtask.java | 27 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 189 ++-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 116 +-
.../pipe/config/constant/PipeSinkConstant.java | 65 +
.../pipe/config/constant/PipeSourceConstant.java | 4 +
.../pipe/config/constant/SystemConstant.java | 2 +-
.../datastructure/pattern/IoTDBPipePattern.java | 79 +-
.../pattern/IoTDBPipePatternOperations.java} | 36 +-
.../pipe/datastructure/pattern/PipePattern.java | 649 ++++++++-
.../datastructure/pattern/PrefixPipePattern.java | 77 +-
.../datastructure/pattern/SinglePipePattern.java | 53 -
.../pattern/UnionIoTDBPipePattern.java | 129 +-
.../datastructure/pattern/UnionPipePattern.java | 27 +-
.../pattern/WithExclusionIoTDBPipePattern.java | 209 +++
.../pattern/WithExclusionPipePattern.java | 121 ++
.../commons/pipe/receiver/IoTDBFileReceiver.java | 37 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 183 +--
.../pipe/sink/client/IoTDBClientManager.java | 2 +-
.../commons/pipe/sink/client/IoTDBSyncClient.java | 2 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 6 +-
.../pipe/sink/limiter/GlobalRPCRateLimiter.java | 2 +-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 4 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 12 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 2 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 10 +-
.../commons/schema/cache/CacheClearOptions.java | 2 +-
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 29 +
.../service/AbstractThriftServiceThread.java | 8 +
.../iotdb/commons/service/metric/enums/Metric.java | 3 +
.../subscription/config/SubscriptionConfig.java | 4 +-
.../meta/consumer/ConsumerGroupMeta.java | 9 +-
.../BuiltinTimeSeriesGeneratingFunction.java | 1 -
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 365 -----
.../commons/utils/ErrorHandlingCommonUtils.java} | 14 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 104 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 7 +-
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 64 +
.../pipe/datastructure/PipeCommitQueueTest.java | 2 +
.../PipeReceiverStatusHandlerTest.java | 302 +++++
.../pipe/receiver/IoTDBFileReceiverTest.java | 128 ++
.../commons/pipe/task/PipeSleepIntervalTest.java | 83 ++
.../apache/iotdb/commons/utils/FileUtilsTest.java | 80 ++
iotdb-core/pom.xml | 2 +-
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 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
.../src/main/thrift/iotconsensus.thrift | 2 +
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
.../thrift-datanode/src/main/thrift/client.thrift | 18 -
library-udf/pom.xml | 4 +-
pom.xml | 87 +-
852 files changed, 22793 insertions(+), 10697 deletions(-)
copy example/{mqtt-customize => subscription}/pom.xml (86%)
rename example/{session =>
subscription}/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java
(97%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBCustomizedClusterIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{selectinto/IoTDBSelectInto3IT.java
=> alignbydevice/IoTDBAlignByDevice4IT.java} (67%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{selectinto/IoTDBSelectInto3IT.java
=> alignbydevice/IoTDBAlignByDeviceWithTemplate3IT.java} (67%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{selectinto/IoTDBSelectInto3IT.java
=> alignbydevice/IoTDBAlignByDeviceWithTemplateAggregation2IT.java} (67%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBOrderByLimitOffsetAlignByDevice3IT.java} (64%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{selectinto/IoTDBSelectInto3IT.java
=> alignbydevice/IoTDBOrderByWithAlignByDevice4IT.java} (67%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{aggregation/IoTDBCountIf2IT.java
=> alignbydevice/IoTDBShuffleSink1_2IT.java} (62%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{aggregation/IoTDBCountIf3IT.java
=> alignbydevice/IoTDBShuffleSink2_2IT.java} (61%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/last/{IoTDBLastQueryLastCache2IT.java
=> IoTDBLastQueryAlias2IT.java} (96%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryAliasIT.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/IoTDBPipeTsFileDecompositionWithModsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionMessageIT.java
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> DataCollector.java} (71%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> TabletCollector.java} (78%)
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionSessionDataSet.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionSessionDataSetsHandler.java
copy iotdb-client/{isession => subscription}/pom.xml (69%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/ConsumerConfig.java
(87%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/ConsumerConstant.java
(95%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicConfig.java
(93%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicConstant.java
(83%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionConnectionException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionIdentifierSemanticException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionIncompatibleHandlerException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionParameterNotValidException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPayloadExceedException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPipeTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPollTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeCriticalException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeNonCriticalException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/ErrorPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileInitPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FilePiecePayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileSealPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollFilePayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollTabletsPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionCommitContext.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequest.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequestType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponse.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponseType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TabletsPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TerminationPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeCloseReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeCommitReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeHandshakeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeHeartbeatReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribePollReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestVersion.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSubscribeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeUnsubscribeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeCloseResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeCommitResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeHandshakeResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeHeartbeatResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribePollResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseVersion.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeSubscribeResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeUnsubscribeResp.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSession.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionConnection.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/AckStrategy.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/AsyncCommitCallback.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ConsumeListener.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ConsumeResult.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumer.java
(96%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionExecutorServiceManager.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionProvider.java
(96%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionProviders.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionPullConsumer.java
(91%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionPushConsumer.java
(98%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/model/Subscription.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/model/Topic.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionFileHandler.java
(91%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessage.java
(56%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageHandler.java
(88%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageType.java
(95%)
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionRecordHandler.java
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionTsFileHandler.java
(93%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/CollectionUtils.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/IdentifierUtils.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/PollTimer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/RandomStringGenerator.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/SetPartitioner.java
(100%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/{GreedyLeaderBalancer.java
=> HashLeaderBalancer.java} (54%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeTSStatusTaskExecutor.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRemoveNodeReplicaSelectTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionTaskExecutorTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/IoTConsensusMemoryManagerTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletEventConverter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{sink/protocol/pipeconsensus/payload/builder/PipeConsensusSyncBatchReqBuilder.java
=> event/common/tablet/PipeTabletCollector.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/util/ModsOperationUtil.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/ClientRunner.java
copy {example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client}/IoTDBKeyStoreLoaderClient.java
(78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClient.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaKeyStoreLoader.java (88%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/server/OpcUaNameSpace.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaServerBuilder.java (80%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/UserCache.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/{IDualKeyCache.java
=> ICache.java} (65%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/{IDualKeyCacheStats.java
=> ICacheStats.java} (97%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/IDualKeyCacheComputation.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/{DualKeyCacheBuilder.java
=> CacheBuilder.java} (68%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/CacheEntry.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/CacheImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/CacheLinkedList.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/{DualKeyCachePolicy.java
=> CachePolicy.java} (96%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/DualKeyCacheImpl.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/ICacheEntry.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/source/SeriesSourceNode.java
=> expression/visitor/ConcatDeviceVisitor.java} (68%)
copy
iotdb-core/{consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/NoDataPointReader.java}
(56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadPathHelper.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/LazyBitMap.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/AuthorityCheckerTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/schemaregion/SchemaExecutionVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/util/ModsOperationUtilTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/PipePatternCoverageTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/PipePatternPruningTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTsStatusVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiverTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/SortOperatorSortBranchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/TransformOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/ClusterConfigTaskExecutorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/WritableMemChunkRegionScanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1Test.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/authorizer/OpenIdAuthorizer.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeNonReportException.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/trigger/GetTriggerJarPlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkNonReportTimeConfigurableException.java}
(54%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/req/IShowSchemaPlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/IoTDBPipePatternOperations.java}
(51%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/SinglePipePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionIoTDBPipePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionPipePattern.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFJexl.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/runtime/MemoryLeakException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/ErrorHandlingCommonUtils.java}
(74%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/WindowsOSUtils.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/PipeReceiverStatusHandlerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiverTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/task/PipeSleepIntervalTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/FileUtilsTest.java
