This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch
reduceDuplicatedDeviceIdInCompactionSelection
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e9c4cefd916 fix ut
add 4e4a215f57a Add sql to show configurations
add f8875c01213 Fix NodeSupplier connection leaky while encountering
exception
add aaf5139029e refine tsfileWriter reset logic (#16309)
add 5339c4a0990 fixup! Pipe: split full-sync pipe into history and
realtime pipes (#16250) (#16316)
add 64c69006964 reduce log (#16298)
add 182a78ae2df [AINode] Refactor thrift integration (#16323)
add 01d88b7d120 Fix some bugs in AlignedTVListIterator
add ded266441d8 Pipe: Further reduce the pipe logs & Added configurations
for tsFile segment lock (#16315)
add 7dee0574ad4 Fix occasional failure of DistinctTagIT caused by read of
old attribute #16326
add f76e96d103c Fix the issue where string filtering cannot be used in the
DEFINE clause
add 23105765868 Fix deleting wrong compression ratio file after flush &
delete compression ratio file after region removal (#16335)
add a5d33b20c21 fix deletion file handler leak (#16332)
add b2a3caeba9e Enhanced device cross region it
add 41cbcfeda67 fix: avoid return null ListenableFuture when checking if
operator is blocked (#16337)
add 68da097d2fb Use global sink executor pool for IoTV2 (#16163)
add 1504f9c6a7d Page time range set in TVListIterator is not processed
(#16338)
add 0e0b1545ad3 Try to make CI more stable (#16340)
add f26f13d2da5 Support SSL in cluster internal connections (#15994)
add d29e45cad29 Pipe: Fix unnecessary client shutdown logic and reduce
handshake waiting time (#16341)
add 6fb776cae12 Pipe: Restore RPC thread name after Pipe receiver exit
(#16344)
add cfb244b877d Add comments in docker-compose for startup hang (#16342)
add a1cf26093e1 Fix show regions compressionRatio issue (#16343)
add 164b58140a2 Pipe IT: Moved rate-limiter in zstd-test to non-tested
pipe to avoid blocking potential failure (#16347)
add 7466e2ce1f0 Concurrently querying and writing to the memtable may
cause the query results out of order (#16328)
add 0b74d2b923b Pipe: Checked the enable_auto_create_schema in database
auto creation (#16354)
add 62f65d1c655 [AINode] Fix log file compressing name (#16358)
add d9075a6b1be Fix potential NPE in Unseq List (#16359)
add f5c0e8af466 Try to make IoTDBTableAggregationNonStream2IT more stable
(#16361)
add 31fa71e2e02 Upgrade netty and reactor (#16362)
add 5b0800920e2 Changed the default MQTT handler size to 1/2 number of
processors & Fixed some default parameters when core number is 1 (#16363)
add a2bbb5104b8 Fix that compression ratio is not transferred during
region migration (#16352)
add 51da71f73bd Pipe: Fix epoch status metric (#16355)
add 2ff8310ca2e Avoided "table not exist" related NPEs (#16357)
add 47e02c889e7 Pipe: Fix lost transfer time metric & Support transfer
time tracking for RawTablet events converted from InsertNode/TsFile events
(#16364)
add b918b3b7caf Update RetryUtils.java (#16368)
add 333986442bc [AINode] Refactor the dependencies to IoTDB (#16369)
add 7377aaa4360 [AINode] Fix maven verify bug (#16373)
add 9765ec84892 Pipe: Show "CONFIG_REGION" string instead of MIN_VALUE in
PipeTableResp (#16372)
add dd18e71678c Optimize ttl deletion in fast compaction performer (#16367)
add db0c69a8715 Fixed the potential NPE in clear all cache on local
(#16378)
add 2bec9c70eca Disable the last cache for some last-related tests
temporarily
add b422e9a5c59 Fix CN pipe procedures restore dead lock (#16324)
add 8106d97db49 Revert "Fix CN pipe procedures restore dead lock (#16324)"
(#16384)
add ff20bbf315d Metric connection security enhanced (#16379)
add 71603e5fd4d Fix read lock not release when unexpected exception
occurred. (#16385)
add 32bb39ae308 [AINode] Renew python dependencies (#16380)
add 699c90eff9d Load: add the function of transferring too many time
partitions of files to tablets and fixed the problem that the data written to
tablets is more than expected. (#16320)
add 87bd830fc28 Pipe: Set placeholder for required pipeMetaList &
Prevented the empty progress report when shutdown (#16388)
add e9994aa6511 Update LICENSE and remove useless code (#16389)
add 3d8522a0cb2 Add dropwizard related modification to LICENSE
add ba2c3a853aa Add some classes modified from trino to LICENSE file
(#16393)
add 1d7e82dfff8 Fixed the potential problem in DataNodeDevicePathCache &
Pipe: Reduced the logs in "PipeReceiverStatusHandler" (#16397)
add a1fe2418260 Pipe: Avoided the OOM risks by replacing the progressive
cheating factor with policy change (#16398)
add 44291877b93 [AINode] Revert transformer and tokenizer dependencies
update (#16394)
add a63a23ee1e8 [AINode] Fix pom.xml of ainode (#16375)
add 1bc2c7f0f61 Pipe: Avoid throwing null pointer during Close process
(#16391)
add 7b9ec7ea83d [AINode] Implement concurrent inference framework (#16311)
add 08708d1c5fc Avoid create region group NPE when concurrent use and
delete database (#16407)
add 40b2b33964e [AINode] Fix bugs for SHOW LOADED MODELS (#16410)
add 03e8e51b5a0 Pipe: Removed the MQTT source (#16405)
add a36cf151cfc Pipe: Avoided timeIndexes' memory occupation for deleted
tsFiles && Removed useless stale logic && Improved the memory calculation of
tsFileResource && Avoided the potential failure for permission check when the
source file is deleted (#16399)
add d12a9b33940 Pipe: Implemented better permission check for showing pipe
(#16403)
add 048a108ec17 Pipe: Further reduced the repeating exception log &
Changed the default log reducer size to 16M & Did some minor fixes in Device
Schema Cache (#16417)
add 77ff8f91730 Fix that oldPassword is not recorded during user creation
& delete password history after user removal (#16416)
add 33f1e360787 Using Visitor design pattern to refactor the access
control logical
add 773433176dc [AINode] Add a batcher for inference (#16411)
add 14ade2b8778 Avoid using tree model device cache to cache table names
(#16413)
add e60408ce67c Fix last cache bugs because init the time last cache but
not updated in later process
add ff98e834bcd Pipe: Add Thrift callback processing logic for
ClosedChannelException (#16421)
add 9f699e15762 Implement DataNode cache TableSchema function to prevent
OOM (#16412)
add 89ef1337744 Revert: cannot reuse time and column array in
InsertTabletStatementGenerator (#16424)
add eb0d3cb9ce0 some tools use getColumnDisplaySize, No exceptions should
be thrown. (#16429)
add 84ac94d1d0c Fix ConfigNodeClient thread leak at DataRegion.java
(#16427)
add c7b459c43d0 move TabletDecoder to org.apache.iotdb.db.utils (#16433)
add 9e0316fe21e Fix concurrent last cache query bug because of one device
in multi regions
add dd6f958ee98 Optimize FetchSchema requests (#16434)
add 9cbb7738ce6 fix cpp session mem leak (#16443)
add 5e7a8c763a9 Avoid NPE for show variables task (#16444)
add c49c06878e1 Subscription: Prevent IllegalArgumentException in
SubscriptionLogStatus by validating bounds for nextLong (#16447)
add d39e9a354e9 Pipe IT: always throw exception with failure when
executing non-queries & Fixed some semantic errors of IT (#16331)
add 993ec2f07ac AuditLogger Implementation (#16428)
add 0e2f911b22f Auth refactor
add 4ebfe9eab86 Append user index field for User (#16432)
add 21c1893db08 Append some interfaces for Nodes startup (#16452)
add 205e373a013 Refactored the schema cache (#16446)
add 25427da164a Insert SQL authentication audit logs for table model
(#16450)
add 05072035af8 Fix vulnerability check (#16455)
add 13afc0348e1 Add IAuthorPlanExecutor
add 5d6609c6e17 Add auth check for show related
add 7cd568c5ded remove org.reflections:reflections, only test use it
add f431f050d7d Add UserId in IClientSession (#16459)
add 7972dd8a884 Fix authentication related CI
add 2b641fdc952 Fix CreateTraining IT
add db819be0db6 Fix some metric bugs
add 19834e45cd8 Pipe: Fixed the concurrency bug of stop / start (#16461)
add 33be57566cf Implement IAuditEntity interface for
TreeAccessCheckContext (#16469)
add 4da1c88a415 Connection limit function. (#16462)
add c9b441a212c Refactor TreeAccessCheckVisitor
add f2fb4a8ff1a Feature/client hide password (#16468)
add 877c1c0d857 Fix compatibility issues for userid (#16473)
add 19de5b10f38 Fix some sonar smell
add 5be7be25d14 Unify access control to AccessControl
add c7515420f12 fix jdbc-srouce.jar include an abs path on feature.xml
(#16484)
add 6de15db3b37 fix client win-cmd exec issue (#16480)
add 078301bec02 Fix jdbc feature.xml error (#16487)
add 4b65b8de02f Added some common interfaces for compatibility
add 7ad8778ea5f Load: Re-enabled the is aligned exception check
add c73e0c0de3b Fix more sonar
add 5ea679f3af3 Implement audit log for tree model (#16475)
add 4b2913050c7 Move password history under __audit (#16496)
add 2ed021362c7 Audit log patch for both tree and table models (#16497)
add 326850435b6 Revert recent updates about audit log (#16498)
add 4bdba5c953d Pipe: Reduced the conversion logger & Fixed the illegal
formats of PipeLogger (#16503)
add 8160a18727a reformat procedure
add 49e857287a6 spotless procedure
add 2d9afef27d2 Throw exception when client with ssl try to connect with
server without ssl (#16504)
add 26a0534b0fa Fix the issue of incorrect %IOTDB_HOME% setting when
running start-cli.bat with parameters in other directories (#16508)
add 755cf0149b4 Audit log big patch (#16501)
add 254f016b75c Fix that TableSchema written in TsFile can be stale after
drop/alter table (#16495)
add a6c5650d2d0 set executedByUserID for AuthorRelationalPlan (#16506)
add 2d44ef034e9 Support user rename (#16512)
add e03560fa653 Fix ratis TLS not working (#16510)
add b4dde12d4cf [AINode][Bug fix] Concurrent inference (#16518)
add e7fb8c38fe5 No need to retry when meets SSL Handshake error between DN
and CN (#16513)
add 5c39de0ccd4 Improve string array class name constant implementation​
(#16514)
add 8ec5aace9c8 Ignore device alignment in timeSeries auto-creation
(#16516)
add 91c51321f3b [To dev/1.3] Load: Optimized the exception error message
of convertion to tablet (#16499)
add 5e00ed5e815 update readme links (#16523)
add 677f9b8e164 Load: Added "skipFailedTableSchemaCheck" parameter (#16522)
add b2175ffa672 Added some common interfaces for compatibility
add dbdc4b43cd2 fix confignode start (#16527)
add 764cedcbfed Pipe: Fixed the potentially missing database auto-create
in receiver (#16529)
add 781a3c98dce Feature/login lock manager (#16494)
add d583362ab98 Optimized the value type check for update device (#16448)
add b86ea430b69 Create Multi Time Series: Modify logger level & Pipe:
Adjusted the show pipe privilege (#16439)
add 7235ec91305 Adjust encrypt config file. (#16528)
add c2696b33ae4 Add audit logic for login and logout event (#16520)
add 6d610816259 Revert "Adjust encrypt config file. (#16528)" (#16534)
add 32c80280eba Patch for rename user and audit log (#16535)
add e4081b90a2c [AINode] Fix: reduce package size (#16511)
add 451024279b8 [AINode] Fix compile bug (#16536)
add 080a810b4e8 Modify script to use local environment variable changes
and avoid pol… (#16541)
add c4fc2e9c7bf Use userId to record password history (#16542)
add f39cf38d570 Ignore data of deprecated table in compaction (#16543)
add 73a0cd8d399 No filtering audit DBs in some procdure & update idle time
after logging in
add 72c3e915f70 Fixed the failure of IoTDBDistinctTagIT
add e188287645f fix: Handle NaN results in approx_percentile evaluation
add 9a25d725313 fix login locked error message (#16550)
add 76852612417 User userId to check whether the user is admin in
ConfigNode (#16554)
add db28f95e901 Add method to convert author type
add 26aa85378f5 Fix NPE for audit func. (#16556)
add a7e042fae03 fix: count device operation
add a3116f46591 Fix initial old password not encrypted & bump TsFile
Version (#16557)
add d6c2719f95a Fix that quotes cannot be passed to start-cli-table.bat
(#16558)
add 36f98a99910 encrypt audit log (#16551)
add 4256d38070d Add keystore truststore expire check and avoid unnecessary
error log printed (#16552)
add 38793052091 Fix UserLockInfo concurrency (#16559)
add 7110f166d64 Update keystore truststore for tests (#16561)
add 558839f3d59 Fix audit log for list user, role and privilege (#16562)
add 18964f41cda Patch for AUDIT privilege authentication on table model
(#16563)
add 2df8710feef Pipe: Cleaned some questionable parameters & Fixed
unstable testPipeAfterDataRegionLeaderStop (#16555)
add ea7e2a68b92 Fix cast of TimeColumn after deserialize
add d65fa92f563 Fix author type conversion (#16560)
add 5621279d5e2 Audit SQL 'COUNT DATABASE' (#16569)
add 629860ade15 fix: Updated TSFile version to fix Load failure in
creating aligned time series (#16502)
add e22a54f44b2 Pipe: Fixed the potential memory shortage may lead to
forever blocking (#16570)
add 006b6fc57d4 enable_grant_option first start take effect (#16572)
add c983221c6a7 Hide keystore truststore file name in logs (#16573)
add 41fd7b8cf4f [AINode] Modify timer_xl and sundial for
transformersv4.56.2 (#16568)
add be172fb23ea add encrypt param when constructing CompactionTsFileReader
(#16578)
add 32f287a400a Fix compatibility issues when loading snapshot in pipe.
(#16580)
add d289944750f Fixed lock error messages and default values in
LoginLockManager. Corrected table model unlock syntax. Resolved errors in
security administrator unlock functionality. (#16579)
add 2c6e5b83120 Fix rename user ConfigNode physical plan
serialize/deserialize NPE (#16582)
add 4c037e7df03 Pipe: Fixed the bug that mark-as-pipe-request may not be
of use in configNode events (#16581)
add a29bf52950e Pipe: Fixed the NPE bug in historical user parsing (#16584)
add b098e34d9c6 Pipe: Fixed the bug that the schema may be sent twice when
split-enabled & database may be null for non-first schema pipes (#16586)
add 867a457d8be Pipe: Stablized the table model IoTDBPipeSyntaxIT (#16585)
add d719d4651d8 Fix some data types are not supported in Mode
AggregationFunction
add a1c34887c3b [AINode] Code format
add 1d852bf406e [AINode] Reformat codebase
add 2a120776bce Don't print warn msg while meeting 400 (#16597)
add 2a591bd267b Pipe: Added parameter check to handshake of legacy
receiver (#16596)
add c72f67e80bf Pipe: Banned the audit / system DB from configNode sync
(#16592)
add 7db498025f0 Fix that ConcurrentLinkedDeque.removeIf is not actually
thread-safe (#16598)
add d49baf77096 Fix IoTDBClusterNodeShutdownHookIT (#16601)
add 8d933843dec Delete unused and vulnerable rpc interface (#16603)
add 46a0c6ac0b1 [AINode] Concurrent inference bug fix (#16595)
add 0d0b7d1e926 Fix aggregation query when device cross region in TreeModel
add fe96a5573dd Perfect implicit time process in first, last, first_by,
last_by of TableModel
add 2ae06e811bd Optimize memtable scan
add b20558f3158 Avoid NPE in the Procedure framework #16607
add 4e2b3b935a3 Set ExternalRPCService server connection with ssl no
timeout (#16617)
add dd4a21c76b2 Fix Cannot invoke
jdk.internal.platform.CgroupInfo.getMountPoint() issue in CI (#16621)
add 332ba5b56ed Pipe: support multiple path patterns under tree model
(#16575)
add 01ae4dcc481 Load: Deleted the unnecessary auto-creation (#16624)
add 09da138a93f Resolve the problem that it will execute endFile() twice
and generate an invalid wal file that… (#16627)
add 1ba2bb79c92 Resolve the situation where the field value contains
commas in line formatter. (#16609)
add aa560e7ddc5 No need to include http client in distribution (#16634)
add 07d457e36df Fix union when cross region or need mapping from child
input
add 9daaaa8687d fix/loginlockmgr-constructor (#16636)
add fd98737405c Delete concurrent-206 and checker-qual directly dependency
add 2c9064ff67c [AINode] Adjust the maximum inference input length (#16640)
add dbf55834d67 Refactored some dependencies
add 656b4fc1a85 Pipe: Fixed the semantics for new regions & realtime /
history only pipes (#16622)
add 9b0e48f2f42 Pipe: Fixed the shouldMarkAsPipeRequest for CreateTable
and AlterLogicalView Sync (#16619)
add a429dfcb3b6 Pipe: Implementing DisruptorQueue (#16639)
add bbe7882f297 Made the schemaRegionMap nonnull for SchemaEngine (#15775)
add ca85e803ecd Pipe: Add TsFile parsing with Mods function (#16540)
add e15fb6aa227 Refactored IoTDB codes (#16644)
add 8867ab60185 Revert "Refactored IoTDB codes (#16644)" (#16645)
add a527b929822 Set the parameter names from default_storage_group_level
to default_database_level (#16626)
add 70b964386f9 Push the aggregation node down the union node
add 25c86c26a69 reject grant/revoke author statement on audit database
add 7131dab25fd feat: Add 36 new built-in scalar functions about BLOB type
add 18cd382b186 Pipe: Fixed the potential NPE in receiver tablet
construction (#16648)
add c1580924bca Support built-in forecast function through UDTF for tree
model (#15682)
add 1e4238f6e32 Pipe: Deleted the reflection code of AtomicUpdater (#16663)
add 23b1313bad3 Fix group by time in tree model bug
add aa899ccf8f5 Pipe: Added log control for pipe receiver auth exception
(#16659)
add 74fe8e69c06 Fix some dependencies version fallback (#16664)
add 57fe5734dd3 Optimize the efficiency of DualKeyCacheImpl's mayEvict
(#16445)
add b5949d2c36b Merge branch 'master' into
reduceDuplicatedDeviceIdInCompactionSelection
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 31 +-
.github/workflows/cluster-it-1c1d1a.yml | 4 +-
.github/workflows/cluster-it-1c3d.yml | 28 +-
.github/workflows/compile-check.yml | 24 +-
.github/workflows/daily-it.yml | 208 +-
.github/workflows/daily-ut.yml | 14 +-
.github/workflows/dependency-check.yml | 20 +-
.github/workflows/pipe-it.yml | 214 +-
.github/workflows/sonar-codecov.yml | 10 +-
.github/workflows/table-cluster-it-1c1d.yml | 33 +-
.github/workflows/table-cluster-it-1c3d.yml | 28 +-
.github/workflows/unit-test.yml | 22 +-
.github/workflows/vulnerability-check.yml | 12 +-
CONTRIBUTING.md | 2 +-
LICENSE | 57 +-
LICENSE-binary | 26 +-
README.md | 18 +-
README_ZH.md | 17 +-
dependencies.json | 335 +--
docker/ReadMe.md | 2 +-
.../main/DockerCompose/docker-compose-ainode.yml | 9 +-
.../docker-compose-cluster-1c1d1a.yml | 15 +-
.../DockerCompose/docker-compose-cluster-1c2d.yml | 21 +
.../DockerCompose/docker-compose-host-3c3d.yml | 14 +
.../DockerCompose/docker-compose-standalone.yml | 9 +-
.../src/TableModelSessionExample.cpp | 4 +-
example/jdbc/pom.xml | 8 +
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 13 +-
integration-test/import-control.xml | 2 +-
integration-test/pom.xml | 23 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 56 +-
.../env/cluster/config/MppSharedCommonConfig.java | 64 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 4 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 8 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 10 +-
.../it/env/remote/config/RemoteCommonConfig.java | 45 +
.../constant/BuiltinAggregationFunctionEnum.java | 7 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 18 +
.../itbase/runtime/ClusterTestConnection.java | 12 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 4 +-
.../iotdb/itbase/runtime/NodeConnection.java | 12 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 247 ++
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 118 +-
.../ainode/it/AINodeInstanceManagementIT.java | 212 ++
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 35 +
.../iotdb/auth/it/IoTDBLoginLockManagerIT.java | 181 ++
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 2 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 2 +-
...oTDBMultiDBRegionGroupLeaderDistributionIT.java | 3 +-
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 15 +
.../IoTDBAutoRegionGroupExtension2IT.java | 2 +
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 5 +-
.../it/partition/IoTDBPartitionCreationIT.java | 6 +
.../it/partition/IoTDBPartitionDurableIT.java | 12 +
.../it/partition/IoTDBPartitionGetterIT.java | 2 +-
.../partition/IoTDBPartitionShuffleStrategyIT.java | 4 +-
...IoTDBRegionOperationReliabilityITFramework.java | 10 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 4 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 2 +-
.../IoTDBRegionMigrateWithCompressionRatioIT.java | 130 ++
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 9 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 116 +
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 6 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 10 +-
.../iotdb/db/it/aggregation/IoTDBModeIT.java | 24 +-
.../db/it/alignbydevice/IoTDBAlignByDevice2IT.java | 8 +-
.../db/it/alignbydevice/IoTDBAlignByDevice3IT.java | 8 +-
...ByDevice3IT.java => IoTDBAlignByDevice4IT.java} | 20 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 34 +-
.../IoTDBAlignByDeviceWithTemplate2IT.java | 8 +-
...java => IoTDBAlignByDeviceWithTemplate3IT.java} | 21 +-
...DBAlignByDeviceWithTemplateAggregation2IT.java} | 23 +-
...oTDBAlignByDeviceWithTemplateAggregationIT.java | 4 +-
.../IoTDBAlignByDeviceWithTemplateIT.java | 11 +-
.../IoTDBOrderByLimitOffsetAlignByDevice2IT.java | 8 +-
...> IoTDBOrderByLimitOffsetAlignByDevice3IT.java} | 17 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 4 +-
.../IoTDBOrderByWithAlignByDevice2IT.java | 8 +-
.../IoTDBOrderByWithAlignByDevice3IT.java | 8 +-
....java => IoTDBOrderByWithAlignByDevice4IT.java} | 19 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 4 +-
.../db/it/alignbydevice/IoTDBShuffleSink1IT.java | 8 +-
...ByDevice2IT.java => IoTDBShuffleSink1_2IT.java} | 27 +-
.../db/it/alignbydevice/IoTDBShuffleSink2IT.java | 10 +-
...ByDevice2IT.java => IoTDBShuffleSink2_2IT.java} | 29 +-
.../db/it/aligned/IoTDBAlignedMemQueryIT.java | 97 +
.../org/apache/iotdb/db/it/audit/AuditLogSet.java | 87 +
.../iotdb/db/it/audit/IoTDBAuditLogBasicIT.java | 2427 ++++++++++++++++++++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 424 ++--
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 98 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 61 +-
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 191 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 64 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 197 +-
.../it/auth/IoTDBSystemPermissionRelationalIT.java | 144 ++
.../iotdb/db/it/auth/IoTDBTemplateAuthIT.java | 568 +++++
.../db/it/auth/IoTDBTemplatePermissionIT.java | 36 +-
.../apache/iotdb/db/it/auth/IoTDBUserRenameIT.java | 132 ++
.../iotdb/db/it/schema/IoTDBCountDeviceIT.java | 268 +++
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 12 +
.../iotdb/db/it/schema/IoTDBDeleteDatabaseIT.java | 3 +-
.../it/udf/IoTDBUDFIntermediateBlockSerdeIT.java | 74 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 148 +-
.../iotdb/it/framework/IoTDBTestListener.java | 2 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 3 +
.../pipe/it/dual/tablemodel/TableModelUtils.java | 58 +-
.../manual/AbstractPipeTableModelDualManualIT.java | 1 -
.../tablemodel/manual/basic/IoTDBPipeAlterIT.java | 59 +-
.../manual/basic/IoTDBPipeDataSinkIT.java | 217 +-
.../manual/basic/IoTDBPipeLifeCycleIT.java | 220 +-
.../manual/basic/IoTDBPipePermissionIT.java | 125 +-
.../manual/basic/IoTDBPipeProtocolIT.java | 59 +-
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 265 +--
.../manual/basic/IoTDBPipeSwitchStatusIT.java | 62 +-
.../tablemodel/manual/basic/IoTDBPipeSyntaxIT.java | 48 +-
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 192 ++
.../manual/basic/IoTDBPipeWithLoadIT.java | 8 +-
.../manual/basic/IoTDBTablePatternFormatIT.java | 287 +--
.../manual/enhanced/IoTDBPipeAutoConflictIT.java | 1 -
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 13 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 494 ++--
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 88 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 32 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 72 +-
.../enhanced/IoTDBPipeSinkCompressionIT.java | 28 +-
.../manual/enhanced/IoTDBPipeSinkParallelIT.java | 6 +-
.../IoTDBPipeTypeConversionISessionIT.java | 118 +-
.../manual/enhanced/IoTDBPipeTypeConversionIT.java | 14 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java | 5 +-
.../treemodel/auto/basic/IoTDBPipeAlterIT.java | 57 +-
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 4 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 79 +-
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 218 +-
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 13 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 53 +-
.../auto/basic/IoTDBPipeSinkParallelIT.java | 6 +-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 99 +-
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 64 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 25 +-
.../auto/basic/IoTDBTreePatternFormatIT.java | 344 ++-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 105 +-
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 12 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 143 +-
.../enhanced/IoTDBPipeConditionalOperationsIT.java | 16 +-
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 16 +-
.../auto/enhanced/IoTDBPipeNullValueIT.java | 28 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 22 +-
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 13 +-
.../treemodel/auto/enhanced/PipeNowFunctionIT.java | 13 +-
.../manual/AbstractPipeDualTreeModelManualIT.java | 5 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 163 +-
.../manual/IoTDBPipeManualConflictIT.java | 24 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 44 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 28 +-
.../treemodel/manual/IoTDBPipeMetaRestartIT.java | 23 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 12 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 92 +-
.../treemodel/manual/IoTDBPipeReqAutoSliceIT.java | 4 +-
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 660 ++++++
.../manual/IoTDBPipeTypeConversionISessionIT.java | 107 +-
.../manual/IoTDBPipeTypeConversionIT.java | 15 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 18 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 15 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 86 +-
.../AbstractPipeTripleManualIT.java} | 57 +-
.../iotdb/pipe/it/triple/IoTDBPipeForwardIT.java | 117 +
.../it/db/it/IoTDBAuthenticationTableIT.java | 8 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 6 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 56 +
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 39 +-
.../it/IoTDBPatternAggregation2IT.java} | 26 +-
.../it/db/it/IoTDBPatternAggregationIT.java | 96 +-
.../it/IoTDBPatternRecognition2IT.java} | 27 +-
.../it/db/it/IoTDBPatternRecognitionIT.java | 17 +-
.../it/db/it/IoTDBSetConfigurationTableIT.java | 78 +-
.../it/db/it/IoTDBWindowFunction2IT.java} | 24 +-
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 14 +-
.../it/db/it/IoTDBWindowTVF2IT.java} | 22 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 38 +-
.../it/insertquery/IoTDBInsertQueryIT.java | 4 +-
.../IoTDBInsertQueryWithInternalSSLIT.java | 90 +
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 85 +-
.../scalar/IoTDBBitwiseFunctionTableIT.java | 36 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 2 +-
.../it/query/recent/IoTDBDistinctTagIT.java | 11 +
...tionNonStreamIT.java => IoTDBFillTable2IT.java} | 21 +-
.../it/query/recent/IoTDBFillTableIT.java | 6 +-
...nNonStreamIT.java => IoTDBGapFillTable2IT.java} | 20 +-
.../it/query/recent/IoTDBGapFillTableIT.java | 6 +-
.../it/query/recent/IoTDBMaintainAuthIT.java | 40 +-
...StreamIT.java => IoTDBTableAggregation2IT.java} | 18 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 76 +-
...java => IoTDBTableAggregationNonStream2IT.java} | 12 +-
.../recent/IoTDBTableAggregationNonStreamIT.java | 7 +-
...ionNonStreamIT.java => IoTDBUnionTable2IT.java} | 19 +-
.../it/query/recent/IoTDBUnionTableIT.java | 18 +
.../query/recent/scalar/IoTDBCRC32FunctionIT.java | 149 ++
.../scalar/IoTDBFromBase32ColumnFunctionIT.java | 197 ++
.../scalar/IoTDBFromBase64ColumnFunctionIT.java | 117 +
.../scalar/IoTDBFromBase64UrlColumnFunctionIT.java | 186 ++
.../scalar/IoTDBFromBigEndian32FunctionIT.java | 170 ++
.../scalar/IoTDBFromBigEndian64FunctionIT.java | 169 ++
.../scalar/IoTDBFromHexColumnFunctionIT.java | 133 ++
.../scalar/IoTDBFromIEEE754_32FunctionIT.java | 154 ++
.../scalar/IoTDBFromIEEE754_64FunctionIT.java | 154 ++
.../scalar/IoTDBFromLittleEndian32FunctionIT.java | 173 ++
.../scalar/IoTDBFromLittleEndian64FunctionIT.java | 173 ++
.../recent/scalar/IoTDBHmacMd5FunctionIT.java | 211 ++
.../recent/scalar/IoTDBHmacSha1FunctionIT.java | 211 ++
.../recent/scalar/IoTDBHmacSha256FunctionIT.java | 217 ++
.../recent/scalar/IoTDBHmacSha512FunctionIT.java | 221 ++
.../query/recent/scalar/IoTDBLpadFunctionIT.java | 230 ++
.../recent/scalar/IoTDBMd5ColumnFunctionIT.java | 132 ++
.../scalar/IoTDBMurmur3ColumnFunctionIT.java | 132 ++
.../recent/scalar/IoTDBReverseFunctionIT.java | 136 ++
.../query/recent/scalar/IoTDBRpadFunctionIT.java | 230 ++
.../recent/scalar/IoTDBSha1ColumnFunctionIT.java | 132 ++
.../recent/scalar/IoTDBSha256ColumnFunctionIT.java | 134 ++
.../recent/scalar/IoTDBSha512ColumnFunctionIT.java | 132 ++
.../scalar/IoTDBSpookyHashV2_32FunctionIT.java | 156 ++
.../scalar/IoTDBSpookyHashV2_64FunctionIT.java | 156 ++
.../scalar/IoTDBToBase32ColumnFunctionIT.java | 141 ++
.../scalar/IoTDBToBase64ColumnFunctionIT.java | 149 ++
.../scalar/IoTDBToBase64UrlColumnFunctionIT.java | 126 +
.../scalar/IoTDBToBigEndian32FunctionIT.java | 143 ++
.../scalar/IoTDBToBigEndian64FunctionIT.java | 139 ++
.../recent/scalar/IoTDBToHexColumnFunctionIT.java | 149 ++
.../recent/scalar/IoTDBToIEEE754_32FunctionIT.java | 118 +
.../recent/scalar/IoTDBToIEEE754_64FunctionIT.java | 119 +
.../scalar/IoTDBToLittleEndian32FunctionIT.java | 140 ++
.../scalar/IoTDBToLittleEndian64FunctionIT.java | 140 ++
.../scalar/IoTDBXXHash64ColumnFunctionIT.java | 132 ++
.../view/old/orderby/IoTDBOrderByTableViewIT.java | 2 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 19 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 4 +-
.../it/session/IoTDBSessionRelationalIT.java | 126 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 15 +-
.../iotdb/session/it/IoTDBSessionCompressedIT.java | 10 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 -
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 +-
.../it/SkipOnSetUpAndTearDownFailure.java | 3 +-
.../IoTDBSubscriptionConsumerGroupIT.java | 58 +-
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 20 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 2 +-
integration-test/src/test/resources/test-keystore | Bin 0 -> 2710 bytes
.../src/test/resources/test-truststore | Bin 0 -> 1238 bytes
.../relational/table/argument/ScalarArgument.java | 22 +-
iotdb-client/cli/pom.xml | 8 -
.../java/org/apache/iotdb/cli/AbstractCli.java | 12 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 6 +-
.../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 80 -
.../org/apache/iotdb/cli/utils/IoTPrinter.java | 2 +-
.../iotdb/tool/backup/IoTDBDataBackTool.java | 4 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 4 +-
.../org/apache/iotdb/tool/data/ExportData.java | 4 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 6 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 9 +-
.../org/apache/iotdb/tool/data/ImportData.java | 4 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 8 +-
.../iotdb/tool/schema/AbstractSchemaTool.java | 2 +-
.../org/apache/iotdb/tool/schema/ExportSchema.java | 2 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 6 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 2 +
.../org/apache/iotdb/tool/schema/ImportSchema.java | 2 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 4 +-
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 11 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 2 +-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 2 +
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 12 +
.../subscription/SubscriptionTableTsFile.java | 2 +-
.../subscription/SubscriptionTreeTsFile.java | 2 +-
iotdb-client/client-cpp/README.md | 2 +-
iotdb-client/client-cpp/src/main/SessionBuilder.h | 6 +-
iotdb-client/client-cpp/src/main/TableSession.h | 12 +-
.../client-cpp/src/main/TableSessionBuilder.h | 6 +-
iotdb-client/client-py/pom.xml | 3 +
.../tests/integration/sqlalchemy/test_dialect.py | 2 +-
iotdb-client/jdbc/pom.xml | 8 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 1763 +++++++-------
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 16 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 574 +++--
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 2 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 -
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 4 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +-
iotdb-client/service-rpc/pom.xml | 16 +
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 25 +
.../iotdb/rpc/NettyTNonblockingTransport.java | 623 +++++
.../apache/iotdb/rpc/TElasticFramedTransport.java | 44 +-
...pper.java => TNonblockingTransportWrapper.java} | 28 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 37 +
.../java/org/apache/iotdb/session/Session.java | 10 +-
.../apache/iotdb/session/TableSessionBuilder.java | 12 +-
.../org/apache/iotdb/session/ThriftConnection.java | 1 +
.../org/apache/iotdb/session/pool/SessionPool.java | 8 +-
.../session/pool/TableSessionPoolBuilder.java | 12 +-
iotdb-core/ainode/.gitignore | 16 +-
.../core/inference/inference_request_pool.py | 206 --
.../ainode/core/inference/pool_controller.py | 188 --
.../pool_scheduler/basic_pool_scheduler.py | 59 -
iotdb-core/ainode/ainode/core/rpc/handler.py | 76 -
iotdb-core/ainode/{ainode => iotdb}/__init__.py | 0
.../{ainode/core => iotdb/ainode}/__init__.py | 0
.../inference => iotdb/ainode/core}/__init__.py | 0
.../ainode/{ => iotdb}/ainode/core/ai_node.py | 18 +-
.../ainode/{ => iotdb}/ainode/core/config.py | 57 +-
.../ainode/{ => iotdb}/ainode/core/constant.py | 9 +-
.../ainode/{ => iotdb}/ainode/core/exception.py | 9 +-
.../ainode/core/inference}/__init__.py | 0
.../ainode/core/inference/batcher}/__init__.py | 0
.../core/inference/batcher/abstract_batcher.py} | 19 +-
.../ainode/core/inference/batcher/basic_batcher.py | 63 +
.../ainode/core/inference/dispatcher}/__init__.py | 0
.../inference/dispatcher/abstract_dispatcher.py | 4 +-
.../core/inference/dispatcher/basic_dispatcher.py | 12 +-
.../ainode/core/inference/inference_request.py | 16 +-
.../core/inference/inference_request_pool.py | 223 ++
.../iotdb/ainode/core/inference/pool_controller.py | 518 +++++
.../ainode/core/inference/pool_group.py | 62 +-
.../core/inference/pool_scheduler}/__init__.py | 0
.../pool_scheduler/abstract_pool_scheduler.py | 36 +-
.../pool_scheduler/basic_pool_scheduler.py | 194 ++
.../core/inference/request_scheduler}/__init__.py | 0
.../abstract_request_scheduler.py | 0
.../request_scheduler/basic_request_scheduler.py | 4 +-
.../ainode/core/inference/strategy}/__init__.py | 0
.../strategy/abstract_inference_pipeline.py | 0
.../strategy/timer_sundial_inference_pipeline.py | 6 +-
.../strategy/timerxl_inference_pipeline.py | 12 +-
.../{ => iotdb}/ainode/core/inference/utils.py | 0
.../ainode/core/ingress}/__init__.py | 0
.../{ => iotdb}/ainode/core/ingress/dataset.py | 0
.../{ => iotdb}/ainode/core/ingress/iotdb.py | 22 +-
iotdb-core/ainode/{ => iotdb}/ainode/core/log.py | 5 +-
.../ainode/core/manager}/__init__.py | 0
.../ainode/core/manager/cluster_manager.py | 4 +-
.../ainode/core/manager/inference_manager.py | 165 +-
.../ainode/core/manager/model_manager.py | 38 +-
.../{ => iotdb}/ainode/core/manager/utils.py | 27 +-
.../ainode/core/model}/__init__.py | 0
.../ainode/core/model/built_in_model_factory.py | 16 +-
.../{ => iotdb}/ainode/core/model/model_enums.py | 0
.../{ => iotdb}/ainode/core/model/model_factory.py | 14 +-
.../{ => iotdb}/ainode/core/model/model_info.py | 4 +-
.../{ => iotdb}/ainode/core/model/model_storage.py | 37 +-
.../ainode/core/model/sundial}/__init__.py | 0
.../core/model/sundial/configuration_sundial.py | 0
.../ainode/core/model/sundial/flow_loss.py | 0
.../ainode/core/model/sundial/modeling_sundial.py | 88 +-
.../core/model/sundial/ts_generation_mixin.py | 14 +-
.../ainode/core/model/timerxl}/__init__.py | 0
.../core/model/timerxl/configuration_timer.py | 0
.../ainode/core/model/timerxl/modeling_timer.py | 83 +-
.../core/model/timerxl/ts_generation_mixin.py | 12 +-
.../{ => iotdb}/ainode/core/model/uri_utils.py | 10 +-
.../ainode/iotdb/ainode/core/rpc}/__init__.py | 0
.../ainode/{ => iotdb}/ainode/core/rpc/client.py | 46 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 135 ++
.../ainode/{ => iotdb}/ainode/core/rpc/service.py | 41 +-
.../ainode/{ => iotdb}/ainode/core/rpc/status.py | 6 +-
.../ainode/{ => iotdb}/ainode/core/script.py | 17 +-
.../ainode/iotdb/ainode/core/util}/__init__.py | 0
.../{ => iotdb}/ainode/core/util/activation.py | 0
.../ainode/iotdb/ainode/core/util/atmoic_int.py | 66 +
.../iotdb/ainode/core/util/batch_executor.py | 133 ++
.../ainode/{ => iotdb}/ainode/core/util/cache.py | 4 +-
.../{ => iotdb}/ainode/core/util/decorator.py | 0
.../ainode/iotdb/ainode/core/util/gpu_mapping.py | 93 +
.../ainode/core/util/huggingface_cache.py | 0
.../ainode/{ => iotdb}/ainode/core/util/lock.py | 0
.../ainode/{ => iotdb}/ainode/core/util/masking.py | 0
.../ainode/{ => iotdb}/ainode/core/util/serde.py | 2 +-
.../ainode/core/util/thread_name.py} | 5 +
iotdb-core/ainode/poetry.lock | 2387 +++++++++----------
iotdb-core/ainode/pom.xml | 44 +-
iotdb-core/ainode/pyproject.toml | 110 +-
.../ainode/resources/conf/iotdb-ainode.properties | 20 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 5 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 49 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 25 +
iotdb-core/confignode/pom.xml | 27 +-
.../iotdb/confignode/audit/CNAuditLogger.java | 94 +
.../confignode/client/CnToCnNodeRequestType.java | 1 +
.../async/AsyncDataNodeHeartbeatClientPool.java | 11 +
.../client/async/CnToDnAsyncRequestType.java | 3 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 8 +-
.../audit/DataNodeWriteAuditLogHandler.java} | 29 +-
.../client/sync/CnToDnSyncRequestType.java | 1 +
.../client/sync/SyncConfigNodeClientPool.java | 2 +
.../client/sync/SyncDataNodeClientPool.java | 6 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 9 +-
.../confignode/conf/ConfigNodeDescriptor.java | 3 +
.../confignode/conf/ConfigNodeRemoveCheck.java | 155 --
.../conf/ConfigNodeSystemPropertiesHandler.java | 23 +-
.../consensus/request/ConfigPhysicalPlan.java | 6 +
.../consensus/request/ConfigPhysicalPlanType.java | 20 +
.../request/ConfigPhysicalPlanVisitor.java | 4 +
.../request/read/database/CountDatabasePlan.java | 13 +-
.../request/read/database/GetDatabasePlan.java | 10 +-
.../read/partition/GetNodePathsPartitionPlan.java | 9 +
.../consensus/request/write/auth/AuthorPlan.java | 48 +-
.../request/write/auth/AuthorRelationalPlan.java | 85 +-
.../request/write/auth/AuthorTreePlan.java | 92 +-
.../consensus/request/write/cq/ActiveCQPlan.java | 2 +-
.../consensus/request/write/cq/AddCQPlan.java | 2 +-
.../consensus/request/write/cq/DropCQPlan.java | 2 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 2 +-
.../response/auth/PermissionInfoResp.java | 11 +
.../consensus/response/model/GetModelInfoResp.java | 8 -
.../response/pipe/task/PipeTableResp.java | 91 +-
.../exception/NoAvailableAINodeException.java} | 13 +-
.../iotdb/confignode/manager/ConfigManager.java | 163 +-
.../apache/iotdb/confignode/manager/IManager.java | 39 +-
.../iotdb/confignode/manager/ModelManager.java | 134 +-
.../confignode/manager/PermissionManager.java | 21 +-
.../iotdb/confignode/manager/ProcedureManager.java | 10 +-
.../manager/consensus/ConsensusManager.java | 5 +
.../manager/load/balancer/PartitionBalancer.java | 4 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 4 +-
.../region/GreedyRegionGroupAllocator.java | 4 +-
.../load/cache/detector/PhiAccrualDetector.java | 14 +-
.../manager/load/service/HeartbeatService.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 82 +-
.../manager/partition/PartitionManager.java | 8 +-
.../runtime/PipeLeaderChangeHandler.java | 4 +-
.../runtime/PipeRuntimeCoordinator.java | 2 +-
.../runtime/heartbeat/PipeHeartbeat.java | 4 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 3 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 2 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 45 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 10 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 122 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 5 +-
.../payload/PipeTransferConfigSnapshotSealReq.java | 8 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 5 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 8 +-
.../pipe/source/ConfigRegionListeningFilter.java | 31 +-
.../pipe/source/ConfigRegionListeningQueue.java | 31 +-
.../pipe/source/IoTDBConfigRegionSource.java | 9 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 60 +-
.../manager/schema/ClusterSchemaManager.java | 14 +-
.../iotdb/confignode/persistence/ModelInfo.java | 2 -
.../confignode/persistence/auth/AuthorInfo.java | 224 ++
.../AuthorPlanExecutor.java} | 294 +--
.../persistence/auth/IAuthorPlanExecutor.java | 62 +
.../persistence/executor/ConfigPlanExecutor.java | 17 +-
.../persistence/partition/PartitionInfo.java | 13 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 16 +-
.../schema/CNPhysicalPlanGenerator.java | 53 +-
.../persistence/schema/ClusterSchemaInfo.java | 20 +-
.../confignode/persistence/schema/ConfigMTree.java | 15 +-
.../schema/ConfigNodeSnapshotParser.java | 5 +-
.../persistence/schema/TemplateTable.java | 10 +-
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 31 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 18 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 47 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 46 +-
.../impl/schema/AlterLogicalViewProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 17 +-
.../scheduler/AbstractProcedureScheduler.java | 2 +-
.../confignode/procedure/store/ProcedureType.java | 2 +
.../iotdb/confignode/service/ConfigNode.java | 27 +
.../service/thrift/ConfigNodeRPCService.java | 38 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 90 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 35 +-
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 3 +-
...figPhysicalPlanTreePatternParseVisitorTest.java | 79 +-
.../confignode/persistence/AuthorInfoTest.java | 7 +-
.../persistence/CNPhysicalPlanGeneratorTest.java | 43 +-
.../iotdb/confignode/persistence/CQInfoTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../confignode/persistence/QuotaInfoTest.java | 2 +-
.../iotdb/confignode/persistence/TTLInfoTest.java | 2 +-
.../confignode/persistence/TriggerInfoTest.java | 2 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 2 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 3 +-
.../persistence/schema/ConfigMTreeTest.java | 22 +-
.../schema/TemplatePreSetTableTest.java | 2 +-
.../persistence/schema/TemplateTableTest.java | 2 +-
.../pipe/annotation/PipePluginAnnotationTest.java | 11 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedureTest.java | 2 +-
iotdb-core/consensus/pom.xml | 9 -
.../apache/iotdb/consensus/ConsensusFactory.java | 2 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 76 +-
.../consensus/config/PipeConsensusConfig.java | 76 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 74 +-
.../consensus/iot/IoTConsensusServerImpl.java | 2 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 20 +-
.../consensus/iot/client/DispatchLogHandler.java | 2 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 24 +-
.../iot/logdispatcher/IndexController.java | 2 +-
.../iot/service/IoTConsensusRPCService.java | 38 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 7 +-
.../pipe/service/PipeConsensusRPCService.java | 38 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 13 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 15 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../utils/NoHostnameVerificationTrustManager.java | 88 +
.../apache/iotdb/consensus/ratis/utils/Utils.java | 62 +-
iotdb-core/datanode/pom.xml | 39 +-
.../src/main/codegen/templates/ModeAccumulator.ftl | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 271 ---
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 461 ++++
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 150 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 3 +
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 97 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 6 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 405 ++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 252 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 132 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 18 +
.../db/consensus/SchemaRegionConsensusImpl.java | 11 +-
.../dataregion/DataExecutionVisitor.java | 4 +-
.../runtime/TableNotExistsRuntimeException.java | 36 -
.../PipeDataRegionSourceConstructor.java | 4 -
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 28 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 46 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 100 +-
.../agent/task/connection/PipeEventCollector.java | 20 +-
.../task/execution/PipeSubtaskExecutorManager.java | 15 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 3 +
.../task/subtask/sink/PipeSinkSubtaskManager.java | 3 +-
.../consensus/PipeConsensusSubtaskExecutor.java | 39 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 24 +-
.../consensus/deletion/recover/DeletionReader.java | 2 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 6 +
.../db/pipe/event/common/PipeInsertionEvent.java | 16 +-
.../common/deletion/PipeDeleteDataNodeEvent.java | 19 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 10 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 10 +
.../schema/PipeSchemaRegionWritePlanEvent.java | 10 +-
.../statement/PipeStatementInsertionEvent.java | 6 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 24 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 43 +-
.../tablet/parser/TabletInsertionEventParser.java | 11 +-
.../event/common/terminate/PipeTerminateEvent.java | 4 +
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 8 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 91 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 16 +
.../parser/TsFileInsertionEventParserProvider.java | 26 +-
.../query/TsFileInsertionEventQueryParser.java | 79 +-
...ileInsertionEventQueryParserTabletIterator.java | 33 +-
.../scan/TsFileInsertionEventScanParser.java | 359 ++-
.../table/TsFileInsertionEventTableParser.java | 41 +-
...ileInsertionEventTableParserTabletIterator.java | 78 +-
.../tsfile/parser/util/ModsOperationUtil.java | 314 +++
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 25 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 34 +
.../metric/processor/PipeProcessorMetrics.java | 3 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 4 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 3 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 3 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 3 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 3 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 3 +-
.../downsampling/PartialPathLastObjectCache.java | 60 +-
.../schemachange/RenameDatabaseProcessor.java | 2 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 20 +-
.../protocol/legacy/loader/DeletionLoader.java | 9 +-
.../protocol/legacy/loader/TsFileLoader.java | 9 +-
.../pipeconsensus/PipeConsensusReceiver.java | 306 +--
.../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 98 +-
.../transform/converter/ValueConverter.java | 2 +-
.../statement/PipeConvertedInsertRowStatement.java | 13 +-
.../visitor/PipeStatementTSStatusVisitor.java | 8 +-
.../PipeStatementTreePatternParseVisitor.java | 30 +-
...leStatementDataTypeConvertExecutionVisitor.java | 5 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 4 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 6 -
.../tsfile/PipeTsFileResourceSegmentLock.java | 63 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 32 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 78 +-
.../client/IoTDBDataNodeSyncClientManager.java | 7 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncSink.java | 2 +-
.../pipeconsensus/PipeConsensusSyncSink.java | 2 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 14 +-
.../handler/PipeTransferTrackableHandler.java | 5 +
.../async/handler/PipeTransferTsFileHandler.java | 2 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 5 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 2 +-
.../websocket/WebSocketConnectorServer.java | 4 +-
.../sink/protocol/writeback/WriteBackSink.java | 30 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 2 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 2 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 2 +-
.../source/dataregion/IoTDBDataRegionSource.java | 78 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 143 +-
.../realtime/PipeRealtimeDataRegionSource.java | 26 +-
.../realtime/assigner/DisruptorQueue.java | 16 +-
.../assigner/DisruptorQueueExceptionHandler.java | 3 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 4 +-
.../realtime/disruptor/BatchEventProcessor.java | 120 +
.../dataregion/realtime/disruptor/Disruptor.java | 135 ++
.../realtime/disruptor/EventFactory.java} | 29 +-
.../realtime/disruptor/EventHandler.java} | 34 +-
.../realtime/disruptor/ExceptionHandler.java} | 41 +-
.../realtime/disruptor/MultiProducerSequencer.java | 270 +++
.../dataregion/realtime/disruptor/RingBuffer.java | 295 +++
.../dataregion/realtime/disruptor/Sequence.java | 122 +
.../realtime/disruptor/SequenceBarrier.java | 78 +
.../realtime/disruptor/SequenceGroups.java | 65 +
.../dataregion/realtime/epoch/TsFileEpoch.java | 13 +-
.../listener/PipeTimePartitionListener.java | 3 +-
.../matcher/CachedSchemaPatternMatcher.java | 32 +-
.../db/pipe/source/mqtt/MQTTPublishHandler.java | 320 ---
.../iotdb/db/pipe/source/mqtt/MQTTSource.java | 264 ---
.../schemaregion/IoTDBSchemaRegionSource.java | 16 +-
.../PipePlanTablePrivilegeParseVisitor.java | 36 +-
.../PipePlanTreePatternParseVisitor.java | 53 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 93 +-
.../db/protocol/client/DataNodeInternalClient.java | 13 +-
.../db/protocol/mqtt/BrokerAuthenticator.java | 2 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 2 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 15 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 49 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 6 +-
.../protocol/rest/filter/AuthorizationFilter.java | 2 +
.../apache/iotdb/db/protocol/rest/filter/User.java | 9 +
.../rest/handler/AuthorizationHandler.java | 5 +-
.../table/v1/handler/ExecuteStatementHandler.java | 4 +
.../table/v1/handler/RequestValidationHandler.java | 2 +-
.../v1/handler/StatementConstructionHandler.java | 7 +-
.../rest/v1/handler/ExecuteStatementHandler.java | 4 +
.../rest/v1/handler/QueryDataSetHandler.java | 4 +
.../rest/v1/handler/RequestValidationHandler.java | 2 +-
.../rest/v1/impl/GrafanaApiServiceImpl.java | 2 +-
.../rest/v2/handler/ExecuteStatementHandler.java | 4 +
.../rest/v2/handler/QueryDataSetHandler.java | 4 +
.../rest/v2/handler/RequestValidationHandler.java | 2 +-
.../rest/v2/impl/GrafanaApiServiceImpl.java | 2 +-
.../iotdb/db/protocol/session/IClientSession.java | 10 +
.../iotdb/db/protocol/session/SessionManager.java | 212 +-
.../iotdb/db/protocol/thrift/OperationType.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 431 ++--
.../impl/DataNodeInternalRPCServiceImpl.java | 77 +-
.../db/queryengine/common/MPPQueryContext.java | 116 +-
.../iotdb/db/queryengine/common/SessionInfo.java | 75 +-
.../common/header/DatasetHeaderFactory.java | 8 +
.../common/schematree/DeviceSchemaInfo.java | 12 +-
.../execution/aggregation/AccumulatorFactory.java | 8 +-
.../execution/exchange/MPPDataExchangeManager.java | 2 +-
.../execution/exchange/MPPDataExchangeService.java | 44 +-
.../execution/exchange/SharedTsBlockQueue.java | 2 +-
.../execution/exchange/sink/LocalSinkChannel.java | 2 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 2 +-
.../execution/exchange/sink/SinkChannel.java | 2 +-
.../exchange/source/LocalSourceHandle.java | 2 +-
.../execution/exchange/source/SourceHandle.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 14 +-
.../execution/fragment/DataNodeQueryContext.java | 68 +-
.../fragment/FragmentInstanceContext.java | 27 +-
.../queryengine/execution/memory/MemoryPool.java | 2 +-
.../execution/operator/AggregationUtil.java | 2 +-
.../operator/process/AbstractIntoOperator.java | 5 +-
.../operator/process/CollectOperator.java | 6 +-
.../process/InsertTabletStatementGenerator.java | 39 +-
.../operator/process/MappingCollectOperator.java | 79 +
.../TableInsertTabletStatementGenerator.java | 2 +-
.../operator/process/TagAggregationOperator.java | 2 +-
.../TreeInsertTabletStatementGenerator.java | 2 +-
.../operator/process/ai/InferenceOperator.java | 5 +-
.../process/join/merge/MergeSortComparator.java | 2 +-
.../rowpattern/expression/CastComputation.java | 82 +
.../rowpattern/expression/ComparisonOperator.java | 20 +
.../process/rowpattern/expression/Computation.java | 29 +
.../expression/PatternExpressionComputation.java | 14 +-
.../operator/schema/SchemaCountOperator.java | 54 +-
.../operator/schema/source/DeviceSchemaSource.java | 8 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../execution/operator/source/SeriesScanUtil.java | 65 +-
.../operator/source/ShowQueriesOperator.java | 10 +-
.../InformationSchemaContentSupplierFactory.java | 127 +-
.../relational/LastQueryAggTableScanOperator.java | 99 +-
.../AbstractApproxPercentileAccumulator.java | 13 +-
.../relational/aggregation/AccumulatorFactory.java | 40 +-
.../relational/aggregation/FirstAccumulator.java | 56 +-
.../relational/aggregation/FirstByAccumulator.java | 70 +-
.../aggregation/FirstByDescAccumulator.java | 7 +-
.../aggregation/FirstDescAccumulator.java | 7 +-
.../aggregation/LastByDescAccumulator.java | 58 +-
.../aggregation/LastDescAccumulator.java | 12 +-
.../aggregation/approximate/HyperLogLog.java | 11 +-
...AbstractGroupedApproxPercentileAccumulator.java | 13 +-
.../execution/operator/window/SessionWindow.java | 13 +-
.../execution/operator/window/TimeWindow.java | 9 +-
.../relational/ColumnTransformerBuilder.java | 328 +++
.../queue/IndexedBlockingReserveQueue.java | 3 +-
.../metric/DriverSchedulerMetricSet.java | 20 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 28 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 3 -
.../queryengine/plan/analyze/AnalyzeVisitor.java | 170 +-
.../plan/analyze/ClusterPartitionFetcher.java | 76 +-
.../plan/analyze/ExpressionAnalyzer.java | 4 +-
.../plan/analyze/IPartitionFetcher.java | 13 +-
.../db/queryengine/plan/analyze/ModelFetcher.java | 23 +-
.../db/queryengine/plan/analyze/TemplatedInfo.java | 6 +-
.../analyze/cache/partition/PartitionCache.java | 51 +-
.../cache/schema/DataNodeDevicePathCache.java | 2 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 2 +-
.../schema/dualkeycache/IDualKeyCacheUpdating.java | 45 -
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 8 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 11 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 106 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 51 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 36 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 27 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 42 +-
.../plan/analyze/schema/ISchemaFetcher.java | 20 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 47 +-
.../plan/analyze/schema/SchemaValidator.java | 4 +-
.../execution/config/TableConfigTaskVisitor.java | 287 ++-
.../execution/config/TreeConfigTaskVisitor.java | 101 +-
.../config/executor/ClusterConfigTaskExecutor.java | 265 ++-
.../config/executor/IConfigTaskExecutor.java | 18 +-
.../config/metadata/ShowFunctionsTask.java | 6 +-
.../execution/config/metadata/ShowRegionTask.java | 6 +-
.../ai/LoadModelTask.java} | 20 +-
.../ShowAIDevicesTask.java} | 43 +-
.../ShowLoadedModelsTask.java} | 49 +-
.../ai/UnloadModelTask.java} | 20 +-
.../template/ShowNodesInSchemaTemplateTask.java | 47 +-
.../metadata/template/ShowPathSetTemplateTask.java | 20 +-
.../plan/execution/config/sys/KillQueryTask.java | 3 +-
.../config/sys/ShowConfigurationTask.java | 107 +
.../execution/config/sys/pipe/ShowPipeTask.java | 6 +-
.../plan/execution/memory/MemorySourceHandle.java | 2 +-
.../plan/expression/ExpressionFactory.java | 2 +-
.../plan/expression/multi/FunctionExpression.java | 4 +-
.../expression/other/CaseWhenThenExpression.java | 2 +-
.../plan/expression/unary/RegularExpression.java | 2 +-
.../expression/visitor/ConcatDeviceVisitor.java} | 16 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 2 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 2 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 2 +-
...ncatDeviceAndBindSchemaForPredicateVisitor.java | 2 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 2 +-
.../plan/optimization/AggregationPushDown.java | 6 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 122 +-
.../plan/parser/StatementGenerator.java | 6 +-
.../plan/planner/LogicalPlanBuilder.java | 15 +-
.../plan/planner/LogicalPlanVisitor.java | 3 +-
.../plan/planner/OperatorTreeGenerator.java | 60 +-
.../plan/planner/TableOperatorGenerator.java | 207 +-
.../plan/planner/TemplatedLogicalPlan.java | 2 +-
.../distribution/DistributionPlanContext.java | 2 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 107 +-
.../plan/AbstractFragmentParallelPlanner.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 4 +-
.../metadata/write/view/AlterLogicalViewNode.java | 44 +-
.../planner/plan/node/process/AggregationNode.java | 2 +-
.../planner/plan/node/process/GroupByTagNode.java | 2 +-
.../plan/node/process/RawDataAggregationNode.java | 2 +-
.../plan/node/source/LastQueryScanNode.java | 2 +-
.../node/source/SeriesAggregationSourceNode.java | 4 +-
.../planner/plan/node/source/ShowQueriesNode.java | 18 +-
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 2 +-
.../parameter/model/ModelInferenceDescriptor.java | 5 +-
.../relational/analyzer/StatementAnalyzer.java | 58 +-
.../function/tvf/ForecastTableFunction.java | 14 +-
.../relational/metadata/TableMetadataImpl.java | 473 +++-
.../plan/relational/metadata/TableSchema.java | 12 +-
.../metadata/cache/DeviceSchemaRequestCache.java | 88 +
.../metadata/fetcher/SchemaPredicateUtil.java | 28 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 17 +-
.../fetcher/TableHeaderSchemaValidator.java | 49 +-
.../fetcher/cache/TableDeviceLastCache.java | 4 +
.../fetcher/cache/TableDeviceSchemaCache.java | 4 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 2 +-
.../cache/TreeDeviceSchemaCacheManager.java | 157 +-
.../plan/relational/planner/LiteralEncoder.java | 3 +-
.../plan/relational/planner/TranslationMap.java | 2 +-
.../planner/distribute/SubPlanGenerator.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 137 +-
.../distribute/TableModelQueryFragmentPlanner.java | 42 +
.../planner/node/AggregationTableScanNode.java | 62 +
.../relational/planner/node/SetOperationNode.java | 4 +-
.../plan/relational/planner/node/UnionNode.java | 31 +-
.../planner/optimizations/SortElimination.java | 13 +-
.../plan/relational/security/AccessControl.java | 106 +-
.../relational/security/AccessControlImpl.java | 471 ++--
.../relational/security/AllowAllAccessControl.java | 120 +-
.../relational/security/ITableAuthChecker.java | 51 +-
.../relational/security/ITableAuthCheckerImpl.java | 376 ++-
.../relational/security/TableModelPrivilege.java | 41 +
.../security/TreeAccessCheckContext.java | 140 ++
.../security/TreeAccessCheckVisitor.java | 1923 ++++++++++++++++
.../sql/ast/AbstractQueryDeviceWithCache.java | 3 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 2 +-
.../plan/relational/sql/ast/AstVisitor.java | 20 +
.../plan/relational/sql/ast/DeleteDevice.java | 5 +-
.../sql/ast/{ShowTopics.java => LoadModel.java} | 49 +-
.../plan/relational/sql/ast/LoadTsFile.java | 2 +-
.../sql/ast/RelationalAuthorStatement.java | 169 +-
.../relational/sql/ast/SearchedCaseExpression.java | 2 +-
.../ast/{ShowTopics.java => ShowAIDevices.java} | 33 +-
.../relational/sql/ast/ShowConfiguration.java} | 17 +-
.../ast/{ShowTopics.java => ShowLoadedModels.java} | 44 +-
.../plan/relational/sql/ast/ShowSubscriptions.java | 4 +-
.../plan/relational/sql/ast/ShowTopics.java | 4 +-
.../relational/sql/ast/SimpleCaseExpression.java | 2 +-
.../sql/ast/{ShowTopics.java => UnloadModel.java} | 48 +-
.../relational/sql/ast/WrappedInsertStatement.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 190 +-
.../plan/relational/type/AuthorRType.java | 10 +-
.../plan/relational/type/CompatibleResolver.java | 5 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../db/queryengine/plan/statement/AuthorType.java | 100 +-
.../statement/AuthorityInformationStatement.java | 30 +-
.../db/queryengine/plan/statement/Statement.java | 12 +-
.../queryengine/plan/statement/StatementType.java | 5 +-
.../plan/statement/StatementVisitor.java | 45 +-
.../statement/component/GroupByTagComponent.java | 2 +-
.../plan/statement/component/IntoItem.java | 2 +-
.../plan/statement/crud/DeleteDataStatement.java | 17 -
.../plan/statement/crud/InsertBaseStatement.java | 21 +-
.../crud/InsertMultiTabletsStatement.java | 9 +
.../plan/statement/crud/InsertRowStatement.java | 24 +
.../plan/statement/crud/InsertRowsStatement.java | 6 +
.../plan/statement/crud/InsertStatement.java | 17 -
.../plan/statement/crud/InsertTabletStatement.java | 75 +-
.../plan/statement/crud/LoadTsFileStatement.java | 12 +-
.../plan/statement/crud/QueryStatement.java | 18 -
.../internal/DeviceSchemaFetchStatement.java | 9 +-
.../InternalBatchActivateTemplateStatement.java | 17 -
.../InternalCreateMultiTimeSeriesStatement.java | 17 -
.../InternalCreateTimeSeriesStatement.java | 17 -
.../internal/SeriesSchemaFetchStatement.java | 9 +-
.../metadata/AlterTimeSeriesStatement.java | 15 -
.../statement/metadata/CountDevicesStatement.java | 25 -
.../metadata/CountTimeSeriesStatement.java | 25 -
.../metadata/CountTimeSlotListStatement.java | 7 -
.../metadata/CreateAlignedTimeSeriesStatement.java | 17 -
.../metadata/CreateContinuousQueryStatement.java | 14 -
.../metadata/CreateFunctionStatement.java | 14 -
.../metadata/CreateMultiTimeSeriesStatement.java | 17 -
.../metadata/CreateTimeSeriesStatement.java | 15 -
.../statement/metadata/CreateTriggerStatement.java | 14 -
.../metadata/DatabaseSchemaStatement.java | 14 -
.../metadata/DeleteDatabaseStatement.java | 14 -
.../metadata/DeleteTimeSeriesStatement.java | 26 +-
.../metadata/DropContinuousQueryStatement.java | 14 -
.../statement/metadata/DropFunctionStatement.java | 14 -
.../statement/metadata/DropTriggerStatement.java | 14 -
.../statement/metadata/GetRegionIdStatement.java | 7 -
.../metadata/GetSeriesSlotListStatement.java | 7 -
.../metadata/GetTimeSlotListStatement.java | 7 -
.../statement/metadata/RemoveAINodeStatement.java | 7 -
.../metadata/RemoveConfigNodeStatement.java | 7 -
.../metadata/RemoveDataNodeStatement.java | 7 -
.../plan/statement/metadata/SetTTLStatement.java | 17 -
.../statement/metadata/ShowClusterIdStatement.java | 7 -
.../statement/metadata/ShowClusterStatement.java | 7 -
.../metadata/ShowConfigNodesStatement.java | 7 -
.../metadata/ShowContinuousQueriesStatement.java | 14 -
.../statement/metadata/ShowDataNodesStatement.java | 7 -
.../statement/metadata/ShowDevicesStatement.java | 25 -
.../statement/metadata/ShowFunctionsStatement.java | 14 -
.../statement/metadata/ShowRegionStatement.java | 7 -
.../plan/statement/metadata/ShowTTLStatement.java | 9 +
.../metadata/ShowTimeSeriesStatement.java | 25 -
.../statement/metadata/ShowTriggersStatement.java | 14 -
.../statement/metadata/ShowVariablesStatement.java | 7 -
.../metadata/model/CreateModelStatement.java | 14 -
.../metadata/model/DropModelStatement.java | 14 -
...ModelStatement.java => LoadModelStatement.java} | 52 +-
.../ShowAIDevicesStatement.java} | 22 +-
.../metadata/model/ShowAINodesStatement.java | 7 -
.../model/ShowLoadedModelsStatement.java} | 45 +-
.../metadata/model/ShowModelsStatement.java | 14 -
...delStatement.java => UnloadModelStatement.java} | 62 +-
.../metadata/pipe/AlterPipeStatement.java | 14 -
.../metadata/pipe/CreatePipePluginStatement.java | 14 -
.../metadata/pipe/CreatePipeStatement.java | 14 -
.../metadata/pipe/DropPipePluginStatement.java | 14 -
.../statement/metadata/pipe/DropPipeStatement.java | 14 -
.../metadata/pipe/ShowPipePluginsStatement.java | 14 -
.../metadata/pipe/ShowPipesStatement.java | 14 -
.../metadata/pipe/StartPipeStatement.java | 14 -
.../statement/metadata/pipe/StopPipeStatement.java | 14 -
.../metadata/region/ExtendRegionStatement.java | 7 -
.../metadata/region/MigrateRegionStatement.java | 7 -
.../region/ReconstructRegionStatement.java | 7 -
.../metadata/region/RemoveRegionStatement.java | 7 -
.../subscription/CreateTopicStatement.java | 14 -
.../subscription/DropSubscriptionStatement.java | 14 -
.../metadata/subscription/DropTopicStatement.java | 14 -
.../subscription/ShowSubscriptionsStatement.java | 14 -
.../metadata/subscription/ShowTopicsStatement.java | 14 -
.../template/AbstractShowExactTemplate.java} | 24 +-
.../template/ActivateTemplateStatement.java | 17 -
.../template/BatchActivateTemplateStatement.java | 17 -
.../template/DeactivateTemplateStatement.java | 24 +-
.../ShowNodesInSchemaTemplateStatement.java | 33 +-
.../template/ShowPathSetTemplateStatement.java | 33 +-
.../template/ShowSchemaTemplateStatement.java | 20 +-
.../metadata/view/AlterLogicalViewStatement.java | 48 +-
.../metadata/view/CreateLogicalViewStatement.java | 61 +-
.../metadata/view/DeleteLogicalViewStatement.java | 17 -
.../metadata/view/RenameLogicalViewStatement.java | 19 -
.../plan/statement/sys/AuthorStatement.java | 243 +-
.../statement/sys/ExplainAnalyzeStatement.java | 6 -
.../plan/statement/sys/KillQueryStatement.java | 17 +-
.../statement/sys/SetConfigurationStatement.java | 39 +
.../plan/statement/sys/SetSqlDialectStatement.java | 8 -
...tement.java => ShowConfigurationStatement.java} | 41 +-
.../sys/ShowCurrentSqlDialectStatement.java | 8 -
.../statement/sys/ShowCurrentUserStatement.java | 8 -
.../plan/statement/sys/ShowQueriesStatement.java | 16 +-
.../plan/statement/sys/ShowVersionStatement.java | 8 -
.../statement/sys/TestConnectionStatement.java | 7 -
.../plan/udf}/BuiltinAggregationFunction.java | 2 +-
.../plan/udf}/BuiltinScalarFunction.java | 2 +-
.../udf}/BuiltinTimeSeriesGeneratingFunction.java | 51 +-
.../queryengine/plan/udf/UDFManagementService.java | 3 -
.../db/queryengine/plan/udf/UDTFForecast.java | 273 +++
.../AbstractCaseWhenThenColumnTransformer.java | 2 +-
.../dag/column/binary/HmacColumnTransformer.java | 108 +
.../binary/factory/HmacStrategiesFactory.java | 93 +
.../column/binary/strategies/HmacStrategy.java} | 13 +-
.../dag/column/ternary/LpadColumnTransformer.java | 92 +
.../dag/column/ternary/RpadColumnTransformer.java | 92 +
.../column/ternary/TernaryColumnTransformer.java | 2 +-
.../dag/column/ternary/utils/BytePaddingUtils.java | 87 +
.../scalar/BytesToDoubleColumnTransformer.java | 78 +
.../scalar/BytesToFloatColumnTransformer.java | 79 +
.../unary/scalar/BytesToIntColumnTransformer.java | 81 +
.../unary/scalar/BytesToLongColumnTransformer.java | 80 +
.../dag/column/unary/scalar/CRC32Transformer.java | 61 +
.../scalar/DoubleToBytesColumnTransformer.java | 61 +
.../scalar/FloatToBytesColumnTransformer.java | 61 +
.../scalar/GenericCodecColumnTransformer.java | 92 +
.../scalar/HmacConstantKeyColumnTransformer.java | 68 +
.../unary/scalar/IntToBytesColumnTransformer.java | 62 +
.../unary/scalar/LongToBytesColumnTransformer.java | 60 +
.../scalar/factory/CodecStrategiesFactory.java | 133 ++
.../factory/NumericCodecStrategiesFactory.java | 169 ++
.../unary/scalar/inteface/CodecStrategy.java} | 13 +-
.../dag/column/unary/scalar/util/HexUtils.java | 86 +
.../unary/scalar/util/SpookyHashV2Utils.java | 603 +++++
.../unary/scalar/util/TransformerDebugUtils.java | 62 +
.../dag/intermediate/MultiInputLayer.java | 35 +-
.../SingleInputMultiReferenceLayer.java | 27 +-
.../SingleInputSingleReferenceLayer.java | 27 +-
.../transformation/dag/udf/UDTFExecutor.java | 2 +-
.../transformation/dag/util/LayerCacheUtils.java | 5 +-
.../transformation/datastructure/TVColumns.java | 7 +-
.../tv/ElasticSerializableBinaryTVList.java | 3 +-
.../datastructure/tv/SerializableTVList.java | 6 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 27 +-
.../schemaregion/SchemaRegionLoader.java | 18 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 3 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 5 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 17 -
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 6 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 17 -
.../mtree/loader/MNodeFactoryLoader.java | 25 +-
.../mtree/traverser/counter/DatabaseCounter.java | 13 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 2 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 2 +-
.../schemaengine/schemaregion/tag/TagManager.java | 2 +-
.../schemaregion/utils/MetaFormatUtils.java | 2 +-
.../db/schemaengine/table/DataNodeTableCache.java | 15 +-
.../template/ClusterTemplateManager.java | 24 +-
.../db/schemaengine/template/ITemplateManager.java | 2 +
.../iotdb/db/schemaengine/template/Template.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 71 +-
.../db/service/DataNodeInternalRPCService.java | 65 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 19 +
.../iotdb/db/service/ExternalRPCService.java | 70 +-
.../org/apache/iotdb/db/service/RestService.java | 2 +-
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../metrics/IoTDBInternalLocalReporter.java | 15 +-
.../iotdb/db/storageengine/StorageEngine.java | 6 +-
.../db/storageengine/dataregion/DataRegion.java | 77 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../constant/CrossCompactionPerformer.java | 16 +
.../constant/InnerSeqCompactionPerformer.java | 16 +
.../constant/InnerUnseqCompactionPerformer.java | 16 +
.../performer/impl/FastCompactionPerformer.java | 60 +-
.../impl/ReadChunkCompactionPerformer.java | 53 +-
.../impl/ReadPointCompactionPerformer.java | 59 +-
.../RepairUnsortedFileCompactionPerformer.java | 14 +-
.../execute/recover/CompactionRecoverTask.java | 2 +-
.../task/RepairUnsortedFileCompactionTask.java | 7 +-
.../task/subtask/ReadPointPerformerSubTask.java | 8 +-
.../execute/utils/CompactionPathUtils.java | 9 +-
.../execute/utils/CompactionTableSchema.java | 11 +-
.../utils/CompactionTableSchemaCollector.java | 33 +-
.../compaction/execute/utils/CompactionUtils.java | 16 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 49 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 8 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 9 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 51 +-
...FollowingBatchCompactionAlignedChunkWriter.java | 16 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 6 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 8 +-
.../executor/fast/SeriesCompactionExecutor.java | 6 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 5 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 4 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 9 +-
.../utils/writer/AbstractCompactionWriter.java | 16 +
.../writer/AbstractCrossCompactionWriter.java | 23 +-
.../writer/AbstractInnerCompactionWriter.java | 30 +-
.../utils/writer/FastCrossCompactionWriter.java | 16 +-
.../utils/writer/FastInnerCompactionWriter.java | 20 +-
.../writer/ReadPointCrossCompactionWriter.java | 14 +-
.../writer/ReadPointInnerCompactionWriter.java | 20 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 12 +-
.../compaction/io/CompactionTsFileReader.java | 17 +-
.../compaction/io/CompactionTsFileWriter.java | 19 +-
.../compaction/repair/RepairDataFileScanUtil.java | 4 +-
.../schedule/CompactionScheduleContext.java | 23 +-
.../compaction/schedule/CompactionScheduler.java | 7 +-
.../estimator/AbstractCompactionEstimator.java | 6 +-
.../estimator/AbstractCrossSpaceEstimator.java | 6 +-
.../estimator/AbstractInnerSpaceEstimator.java | 11 +-
.../estimator/CompactionEstimateUtils.java | 6 +-
.../RepairUnsortedFileCompactionEstimator.java | 5 +
.../impl/NewSizeTieredCompactionSelector.java | 2 +-
.../selector/impl/SettleSelectorImpl.java | 2 +-
.../utils/CrossSpaceCompactionCandidate.java | 1 +
.../compaction/settle/SettleRequestHandler.java | 13 +-
.../compaction/tool/SingleSequenceFileTask.java | 11 +-
.../compaction/tool/TimePartitionProcessTask.java | 9 +-
.../compaction/tool/TsFileStatisticReader.java | 6 +-
.../dataregion/flush/CompressionRatio.java | 47 +-
.../dataregion/memtable/AbstractMemTable.java | 10 +-
.../memtable/AbstractWritableMemChunk.java | 4 +
.../memtable/AlignedReadOnlyMemChunk.java | 32 +-
.../memtable/AlignedWritableMemChunk.java | 36 +-
.../memtable/AlignedWritableMemChunkGroup.java | 9 +
.../dataregion/memtable/IWritableMemChunk.java | 3 +
.../memtable/IWritableMemChunkGroup.java | 3 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 20 +-
.../dataregion/memtable/TsFileProcessor.java | 12 +-
.../dataregion/memtable/WritableMemChunk.java | 25 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 19 +-
.../dataregion/modification/ModificationFile.java | 2 -
.../dataregion/read/control/FileReaderManager.java | 13 +-
.../read/reader/chunk/MemAlignedPageReader.java | 3 +
.../read/reader/chunk/MemPageReader.java | 3 +
.../read/reader/common/NoDataPointReader.java} | 41 +-
.../dataregion/snapshot/SnapshotLoader.java | 44 +-
.../dataregion/snapshot/SnapshotTaker.java | 27 +
.../dataregion/tsfile/TsFileResource.java | 25 +-
.../dataregion/utils/TsFileResourceUtils.java | 6 +-
.../dataregion/wal/io/CheckpointReader.java | 6 +
.../dataregion/wal/io/WALInputStream.java | 14 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 4 +
.../file/AbstractTsFileRecoverPerformer.java | 21 +-
.../db/storageengine/load/LoadTsFileManager.java | 2 +-
.../load/active/ActiveLoadDirScanner.java | 2 +-
.../load/active/ActiveLoadTsFileLoader.java | 2 +-
.../load/config/LoadTsFileConfigurator.java | 4 +-
...vertedInsertTabletStatementTSStatusVisitor.java | 3 +-
...rtedInsertTabletStatementExceptionVisitor.java} | 18 +-
...leStatementDataTypeConvertExecutionVisitor.java | 28 +-
...rtedInsertTabletStatementExceptionVisitor.java} | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 29 +-
.../converter/LoadTsFileDataTypeConverter.java | 19 +-
.../load/splitter/TsFileSplitter.java | 21 +
.../rescon/disk/DirectoryChecker.java | 2 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../agent/SubscriptionAgentLauncher.java | 4 +-
.../broker/SubscriptionPrefetchingQueue.java | 7 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 3 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 3 +-
.../event/batch/SubscriptionPipeEventBatch.java | 4 +-
.../event/batch/SubscriptionPipeEventBatches.java | 4 +-
.../event/cache/SubscriptionPollResponseCache.java | 54 +-
.../response/SubscriptionEventTsFileResponse.java | 3 +-
.../SubscriptionPrefetchingQueueMetrics.java | 3 +-
.../resource/log/SubscriptionLogStatus.java | 2 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 2 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 25 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 16 +-
.../db/tools/schema/SRStatementGenerator.java | 4 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 5 +-
.../iotdb/db/tools/utils/TsFileSequenceScan.java | 7 +-
.../iotdb/db/tools/utils/TsFileStatisticScan.java | 6 +-
.../db/trigger/executor/TriggerFireVisitor.java | 6 +
.../trigger/service/TriggerManagementService.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 2 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 204 +-
.../org/apache/iotdb/db/utils/EncryptDBUtils.java | 86 +
.../iotdb/{util => db/utils}/TabletDecoder.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 163 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 3 +
.../iotdb/db/utils/datastructure/LazyBitMap.java | 93 +
.../db/utils/datastructure/MemPointIterator.java | 3 +
.../datastructure/MemPointIteratorFactory.java | 91 +-
.../MergeSortMultiAlignedTVListIterator.java | 47 +-
.../MergeSortMultiTVListIterator.java | 24 +
.../datastructure/MultiAlignedTVListIterator.java | 6 +-
.../utils/datastructure/MultiTVListIterator.java | 22 +-
.../OrderedMultiAlignedTVListIterator.java | 26 +
.../datastructure/OrderedMultiTVListIterator.java | 26 +
.../iotdb/db/utils/datastructure/TVList.java | 256 ++-
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 558 +++++
.../auth/authorizer/LocalFileAuthorizerTest.java | 6 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 16 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 2 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 2 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 21 +-
.../db/auth/user/LocalFileUserManagerTest.java | 2 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 19 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 2 +-
.../schemaRegion/SchemaRegionBasicTest.java | 2 +-
.../db/pipe/consensus/DeletionResourceTest.java | 2 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 5 +-
.../tsfile/parser/util/ModsOperationUtilTest.java | 408 ++++
.../annotation/PipePluginAnnotationTest.java | 11 +-
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 22 +-
.../PipeStatementTreePatternParseVisitorTest.java | 46 +-
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 2 +
.../PipePlanTreePatternParseVisitorTest.java | 256 ++-
.../source/SchemaRegionListeningQueueTest.java | 2 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 2 +-
.../operator/MergeTreeSortOperatorTest.java | 4 +-
.../process/rowpattern/PatternExpressionTest.java | 9 +
.../process/window/function/FunctionTestUtils.java | 3 +-
.../plan/analyze/ExpressionAnalyzerTest.java | 2 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 7 +-
.../plan/analyze/FakeSchemaFetcherImpl.java | 22 +-
.../load/TimeseriesMetadataIteratorTest.java | 173 ++
.../plan/parser/StatementGeneratorTest.java | 13 +-
.../plan/planner/distribution/Util.java | 30 +-
.../plan/planner/distribution/Util2.java | 30 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 3 +
.../plan/relational/analyzer/AuthTest.java | 36 +-
.../analyzer/PushAggregationThroughUnionTest.java | 148 ++
.../plan/relational/analyzer/TSBSMetadata.java | 12 +-
.../relational/analyzer/TableFunctionTest.java | 4 +-
.../plan/relational/analyzer/TestMetadata.java | 12 +-
.../relational/sql/parser/AuthorStatementTest.java | 27 +-
.../binary/hmac/HmacMd5ColumnTransformerTest.java | 420 ++++
.../binary/hmac/HmacSha1ColumnTransformerTest.java | 420 ++++
.../hmac/HmacSha256ColumnTransformerTest.java | 420 ++++
.../hmac/HmacSha512ColumnTransformerTest.java | 356 +++
.../column/ternary/LpadColumnTransformerTest.java | 303 +++
.../column/ternary/RpadColumnTransformerTest.java | 303 +++
.../FromBigEndian32ColumnTransformerTest.java | 220 ++
.../FromBigEndian64ColumnTransformerTest.java | 242 ++
...omIEEE754_32BigEndianColumnTransformerTest.java | 231 ++
...omIEEE754_64BigEndianColumnTransformerTest.java | 231 ++
.../FromLittleEndian32ColumnTransformerTest.java | 221 ++
.../FromLittleEndian64ColumnTransformerTest.java | 243 ++
.../ToBigEndian32ColumnTransformerTest.java | 188 ++
.../ToBigEndian64ColumnTransformerTest.java | 188 ++
...ToIEEE754_32BigEndianColumnTransformerTest.java | 179 ++
...ToIEEE754_64BigEndianColumnTransformerTest.java | 159 ++
.../ToLittleEndian32ColumnTransformerTest.java | 189 ++
.../ToLittleEndian64ColumnTransformerTest.java | 189 ++
.../unary/scalar/ReverseColumnTransformerTest.java | 216 ++
.../FromBase32ColumnTransformerTest.java | 268 +++
.../FromBase64ColumnTransformerTest.java | 271 +++
.../FromBase64UrlColumnTransformerTest.java | 328 +++
.../ToBase32ColumnTransformerTest.java | 196 ++
.../ToBase64ColumnTransformerTest.java | 190 ++
.../ToBase64UrlColumnTransformerTest.java | 235 ++
.../scalar/hashing/Crc32ColumnTransformerTest.java | 200 ++
.../scalar/hashing/Md5ColumnTransformerTest.java | 225 ++
.../hashing/Murmur3ColumnTransformerTest.java | 224 ++
.../scalar/hashing/Sha1ColumnTransformerTest.java | 225 ++
.../hashing/Sha256ColumnTransformerTest.java | 229 ++
.../hashing/Sha512ColumnTransformerTest.java | 224 ++
.../SpookyHashV2_32ColumnTransformerTest.java | 183 ++
.../SpookyHashV2_64ColumnTransformerTest.java | 183 ++
.../hashing/XxHash64ColumnTransformerTest.java | 238 ++
.../hexEncoding/FromHexColumnTransformerTest.java | 239 ++
.../hexEncoding/ToHexColumnTransformerTest.java | 222 ++
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../storageengine/buffer/BloomFilterCacheTest.java | 2 +-
.../dataregion/TsFileManagerTest.java | 2 +-
.../TsFileResourceProgressIndexTest.java | 2 +-
.../compaction/AbstractCompactionTest.java | 6 +-
.../compaction/CompactionTaskManagerTest.java | 2 +-
.../compaction/CompactionValidationTest.java | 2 +-
.../TsFileValidationCorrectnessTests.java | 2 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 2 +-
.../inner/FastCompactionPerformerAlignedTest.java | 2 +-
.../FastCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 2 +-
.../compaction/inner/InnerCompactionLogTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 2 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../recover/SizeTieredCompactionRecoverTest.java | 2 +-
.../CompactionTableSchemaCollectorTest.java | 8 +-
.../TableModelFastCompactionPerformerTest.java | 125 +-
...TableModelReadChunkCompactionPerformerTest.java | 94 +-
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../dataregion/flush/CompressionRatioTest.java | 2 +-
.../memtable/AlignedTVListIteratorTest.java | 153 +-
.../memtable/NonAlignedTVListIteratorTest.java | 106 +-
.../dataregion/memtable/TsFileProcessorTest.java | 2 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 8 +
.../dataregion/tsfile/TsFileResourceTest.java | 2 +-
.../wal/compression/WALCompressionTest.java | 2 +-
.../dataregion/wal/io/WALFileTest.java | 22 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 2 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 2 +-
.../iotdb/db/utils/ConfigurationFileUtilsTest.java | 15 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../apache/iotdb/db/utils/OpenFileNumUtilTest.java | 2 +-
.../db/utils/SchemaRegionSnapshotParserTest.java | 2 +-
.../db/utils/datastructure/AlignedTVListTest.java | 2 +-
.../db/utils/datastructure/BinaryTVListTest.java | 2 +-
.../db/utils/datastructure/BooleanTVListTest.java | 2 +-
.../db/utils/datastructure/DoubleTVListTest.java | 2 +-
.../db/utils/datastructure/FloatTVListTest.java | 2 +-
.../db/utils/datastructure/IntTVListTest.java | 2 +-
.../db/utils/datastructure/LongTVListTest.java | 2 +-
iotdb-core/metrics/ReadMe.md | 4 +-
iotdb-core/metrics/interface/pom.xml | 4 +
.../apache/iotdb/metrics/config/MetricConfig.java | 54 +-
.../metrics/config/MetricConfigDescriptor.java | 13 +
.../reporter/iotdb/IoTDBSessionReporter.java | 22 +-
.../reporter/prometheus/PrometheusReporter.java | 63 +-
.../java/org/apache/iotdb/metrics/type/Timer.java | 16 +-
iotdb-core/node-commons/pom.xml | 17 +-
.../conf/iotdb-system.properties.template | 52 +-
.../iotdb/commons/audit/AbstractAuditLogger.java | 125 +
.../iotdb/commons/audit/AuditEventType.java} | 34 +-
.../apache/iotdb/commons/audit/AuditLogFields.java | 182 ++
.../iotdb/commons}/audit/AuditLogOperation.java | 4 +-
.../apache/iotdb/commons/audit/IAuditEntity.java | 61 +
.../iotdb/commons/audit/PrivilegeLevel.java} | 8 +-
.../org/apache/iotdb/commons/audit/UserEntity.java | 154 ++
.../commons/auth/authorizer/BasicAuthorizer.java | 50 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 26 +
.../auth/authorizer/LocalFileAuthorizer.java | 5 -
.../commons/auth/authorizer/OpenIdAuthorizer.java | 6 +-
.../iotdb/commons/auth/entity/IEntityAccessor.java | 15 +
.../iotdb/commons/auth/entity/PrivilegeType.java | 131 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 21 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 43 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 22 +
.../iotdb/commons/auth/role/IEntityManager.java | 9 +
.../commons/auth/role/LocalFileRoleAccessor.java | 86 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 163 +-
.../commons/auth/user/LocalFileUserAccessor.java | 61 +-
.../commons/auth/user/LocalFileUserManager.java | 1 +
.../apache/iotdb/commons/auth/utils/AuthUtils.java | 49 +
.../apache/iotdb/commons/client/ThriftClient.java | 6 +-
.../iotdb/commons/client/ainode/AINodeClient.java | 89 +-
.../client/ainode/AsyncAINodeServiceClient.java | 19 +-
.../AsyncConfigNodeInternalServiceClient.java | 20 +-
.../async/AsyncDataNodeExternalServiceClient.java | 20 +-
.../async/AsyncDataNodeInternalServiceClient.java | 20 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 20 +-
.../async/AsyncPipeConsensusServiceClient.java | 20 +-
.../async/AsyncPipeDataTransferServiceClient.java | 6 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 24 +-
.../sync/SyncDataNodeInternalServiceClient.java | 24 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 24 +-
.../sync/SyncPipeConsensusServiceClient.java | 24 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 235 +-
.../iotdb/commons/conf/CommonDescriptor.java | 45 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 263 ++-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
.../container/IoTV2GlobalComponentContainer.java | 23 +-
.../exception/pipe/PipeNonReportException.java} | 11 +-
.../pipe/PipeRuntimeSinkCriticalException.java | 2 +-
...RuntimeSinkRetryTimesConfigurableException.java | 6 +
.../commons/executable/ExecutableManager.java | 17 +-
.../commons/external/collections4/BidiMap.java | 138 ++
.../external/collections4/IterableSortedMap.java} | 31 +-
.../external/collections4/OrderedBidiMap.java | 51 +
.../collections4/ResettableListIterator.java} | 34 +-
.../external/collections4/SortedBidiMap.java | 59 +
.../collections4/bidimap/AbstractDualBidiMap.java | 798 +++++++
.../collections4/bidimap/DualTreeBidiMap.java | 414 ++++
.../collection/AbstractCollectionDecorator.java | 182 ++
.../iterators/AbstractIteratorDecorator.java} | 39 +-
.../AbstractUntypedIteratorDecorator.java | 66 +
.../iterators/ListIteratorWrapper.java | 274 +++
.../keyvalue/AbstractMapEntryDecorator.java | 92 +
.../collections4/map/AbstractIterableMap.java} | 33 +-
.../collections4/map/AbstractMapDecorator.java | 153 ++
.../map/AbstractSortedMapDecorator.java | 166 ++
.../map/EntrySetToMapIteratorAdapter.java | 110 +
.../iotdb/commons/file/SystemFileFactory.java | 2 +-
.../iotdb/commons/partition/SchemaPartition.java | 6 +
.../org/apache/iotdb/commons/path/PartialPath.java | 6 +-
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 2 +-
.../fa/dfa/transition/DFAWildcardTransition.java | 2 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 3 -
.../plugin/builtin/source/mqtt/MQTTSource.java | 68 -
.../service/PipePluginExecutableManager.java | 2 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 54 +-
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 39 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 56 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 20 +-
.../pipe/config/constant/PipeSinkConstant.java | 6 +
.../pipe/config/constant/PipeSourceConstant.java | 34 +-
.../pipe/config/constant/SystemConstant.java | 10 +-
.../datastructure/pattern/IoTDBTreePattern.java | 10 +-
.../datastructure/pattern/PrefixTreePattern.java | 4 +-
.../datastructure/pattern/SingleTreePattern.java} | 47 +-
.../pipe/datastructure/pattern/TreePattern.java | 185 +-
.../pattern/UnionIoTDBTreePattern.java | 161 ++
.../datastructure/pattern/UnionTreePattern.java | 95 +
.../listening/AbstractPipeListeningQueue.java | 10 +-
.../visibility/VisibilityTestUtils.java | 10 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 16 +
.../commons/pipe/event/PipeSnapshotEvent.java | 4 +
.../commons/pipe/event/PipeWritePlanEvent.java | 4 +
.../commons/pipe/event/ProgressReportEvent.java | 4 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 164 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 2 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 59 +-
.../pipe/sink/client/IoTDBClientManager.java | 7 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 28 +-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../commons/pipe/sink/protocol/IoTDBSink.java | 15 +
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 5 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 23 +-
.../iotdb/commons/pipe/source/IoTDBSource.java | 15 +
.../iotdb/commons/schema/SchemaConstant.java | 7 +-
.../schema/column/ColumnHeaderConstant.java | 36 +
.../apache/iotdb/commons/schema/table/Audit.java | 45 +
.../viewExpression/leaf/ConstantViewOperand.java | 2 +-
.../unary/RegularViewExpression.java | 2 +-
.../service/AbstractThriftServiceThread.java | 53 +-
.../iotdb/commons/service/ThriftServiceThread.java | 40 +-
.../meta/consumer/ConsumerGroupMeta.java | 3 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 6 +-
.../relational/TableBuiltinScalarFunction.java | 36 +
.../commons/udf/service/UDFExecutableManager.java | 2 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 36 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 23 +-
.../org/apache/iotdb/commons/utils/IOUtils.java | 30 +
.../org/apache/iotdb/commons/utils/RetryUtils.java | 3 +-
.../pipe/datastructure/PipeCommitQueueTest.java | 8 +
.../annotation/PipePluginAnnotationTest.java | 11 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 72 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 32 +
.../thrift-commons/src/main/thrift/common.thrift | 5 +
.../src/main/thrift/confignode.thrift | 91 +-
.../thrift-datanode/src/main/thrift/client.thrift | 18 -
.../src/main/thrift/datanode.thrift | 40 +-
library-udf/pom.xml | 2 +
pom.xml | 65 +-
scripts/sbin/start-cli.sh | 9 +-
scripts/sbin/windows/start-cli-table.bat | 116 +-
scripts/sbin/windows/start-cli.bat | 234 +-
1375 files changed, 59609 insertions(+), 16148 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeConcurrentInferenceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeInstanceManagementIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/auth/it/IoTDBLoginLockManagerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithCompressionRatioIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBMiscIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBAlignByDevice3IT.java
=> IoTDBAlignByDevice4IT.java} (58%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBAlignByDeviceWithTemplate2IT.java
=> IoTDBAlignByDeviceWithTemplate3IT.java} (59%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBAlignByDeviceWithTemplateAggregation2IT.java} (56%)
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/alignbydevice/{IoTDBOrderByWithAlignByDevice2IT.java
=> IoTDBOrderByWithAlignByDevice4IT.java} (58%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBShuffleSink1_2IT.java} (51%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBShuffleSink2_2IT.java} (50%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedMemQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/audit/AuditLogSet.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/audit/IoTDBAuditLogBasicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBSystemPermissionRelationalIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBTemplateAuthIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBUserRenameIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCountDeviceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFIntermediateBlockSerdeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeTsFileDecompositionWithModsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/IoTDBPipeTsFileDecompositionWithModsIT.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/{dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java
=> triple/AbstractPipeTripleManualIT.java} (57%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/IoTDBPipeForwardIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/{query/recent/IoTDBTableAggregationNonStreamIT.java
=> db/it/IoTDBPatternAggregation2IT.java} (55%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/{query/recent/IoTDBTableAggregationNonStreamIT.java
=> db/it/IoTDBPatternRecognition2IT.java} (55%)
copy
integration-test/src/test/java/org/apache/iotdb/{db/it/alignbydevice/IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> relational/it/db/it/IoTDBWindowFunction2IT.java} (55%)
copy
integration-test/src/test/java/org/apache/iotdb/{db/it/alignbydevice/IoTDBAlignByDevice3IT.java
=> relational/it/db/it/IoTDBWindowTVF2IT.java} (55%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/insertquery/IoTDBInsertQueryWithInternalSSLIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBTableAggregationNonStreamIT.java
=> IoTDBFillTable2IT.java} (58%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBTableAggregationNonStreamIT.java
=> IoTDBGapFillTable2IT.java} (62%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBTableAggregationNonStreamIT.java
=> IoTDBTableAggregation2IT.java} (66%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBTableAggregationNonStreamIT.java
=> IoTDBTableAggregationNonStream2IT.java} (83%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBTableAggregationNonStreamIT.java
=> IoTDBUnionTable2IT.java} (61%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBCRC32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase32ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase64ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase64UrlColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBigEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBigEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromHexColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromIEEE754_32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromIEEE754_64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromLittleEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromLittleEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacMd5FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacSha1FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacSha256FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacSha512FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBLpadFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBMd5ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBMurmur3ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBReverseFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBRpadFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSha1ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSha256ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSha512ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSpookyHashV2_32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSpookyHashV2_64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBase32ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBase64ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBase64UrlColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBigEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBigEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToHexColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToIEEE754_32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToIEEE754_64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToLittleEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToLittleEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBXXHash64ColumnFunctionIT.java
create mode 100644 integration-test/src/test/resources/test-keystore
create mode 100644 integration-test/src/test/resources/test-truststore
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/cli/IoTDBSyntaxHighlighter.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NettyTNonblockingTransport.java
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/{TNonblockingSocketWrapper.java
=> TNonblockingTransportWrapper.java} (65%)
delete mode 100644
iotdb-core/ainode/ainode/core/inference/inference_request_pool.py
delete mode 100644 iotdb-core/ainode/ainode/core/inference/pool_controller.py
delete mode 100644
iotdb-core/ainode/ainode/core/inference/pool_scheduler/basic_pool_scheduler.py
delete mode 100644 iotdb-core/ainode/ainode/core/rpc/handler.py
rename iotdb-core/ainode/{ainode => iotdb}/__init__.py (100%)
rename iotdb-core/ainode/{ainode/core => iotdb/ainode}/__init__.py (100%)
copy iotdb-core/ainode/{ainode/core/inference =>
iotdb/ainode/core}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ai_node.py (92%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/config.py (88%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/constant.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/exception.py (96%)
rename iotdb-core/ainode/{ainode/core/inference/dispatcher =>
iotdb/ainode/core/inference}/__init__.py (100%)
rename iotdb-core/ainode/{ainode/core/inference/pool_scheduler =>
iotdb/ainode/core/inference/batcher}/__init__.py (100%)
copy
iotdb-core/ainode/{ainode/core/inference/dispatcher/abstract_dispatcher.py =>
iotdb/ainode/core/inference/batcher/abstract_batcher.py} (60%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/batcher/basic_batcher.py
rename iotdb-core/ainode/{ainode/core/inference/request_scheduler =>
iotdb/ainode/core/inference/dispatcher}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/dispatcher/abstract_dispatcher.py (90%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/dispatcher/basic_dispatcher.py (84%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/inference_request.py (86%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/inference_request_pool.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_controller.py
rename iotdb-core/ainode/{ => iotdb}/ainode/core/inference/pool_group.py (54%)
rename iotdb-core/ainode/{ainode/core/inference/strategy =>
iotdb/ainode/core/inference/pool_scheduler}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/pool_scheduler/abstract_pool_scheduler.py (55%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_scheduler/basic_pool_scheduler.py
rename iotdb-core/ainode/{ainode/core/ingress =>
iotdb/ainode/core/inference/request_scheduler}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/request_scheduler/abstract_request_scheduler.py
(100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/request_scheduler/basic_request_scheduler.py (95%)
rename iotdb-core/ainode/{ainode/core/manager =>
iotdb/ainode/core/inference/strategy}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/abstract_inference_pipeline.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/timer_sundial_inference_pipeline.py (88%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/timerxl_inference_pipeline.py (71%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/inference/utils.py (100%)
rename iotdb-core/ainode/{ainode/core/model =>
iotdb/ainode/core/ingress}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ingress/dataset.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ingress/iotdb.py (95%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/log.py (97%)
rename iotdb-core/ainode/{ainode/core/model/sundial =>
iotdb/ainode/core/manager}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/cluster_manager.py
(93%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/inference_manager.py
(64%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/model_manager.py (82%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/utils.py (83%)
rename iotdb-core/ainode/{ainode/core/model/timerxl =>
iotdb/ainode/core/model}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/built_in_model_factory.py (98%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_enums.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_factory.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_info.py (98%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_storage.py (93%)
rename iotdb-core/ainode/{ainode/core/rpc =>
iotdb/ainode/core/model/sundial}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/configuration_sundial.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/sundial/flow_loss.py
(100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/modeling_sundial.py (90%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/ts_generation_mixin.py (97%)
rename iotdb-core/ainode/{ainode/core/util =>
iotdb/ainode/core/model/timerxl}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/configuration_timer.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/modeling_timer.py (90%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/ts_generation_mixin.py (97%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/uri_utils.py (94%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/rpc}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/client.py (86%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/service.py (70%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/status.py (89%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/script.py (90%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/util}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/activation.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/atmoic_int.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/batch_executor.py
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/cache.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/decorator.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/gpu_mapping.py
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/huggingface_cache.py
(100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/lock.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/masking.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/serde.py (98%)
rename iotdb-core/ainode/{ainode/core/inference/__init__.py =>
iotdb/ainode/core/util/thread_name.py} (87%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/audit/CNAuditLogger.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/ShowVariablesStatement.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/audit/DataNodeWriteAuditLogHandler.java}
(54%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/exception/NoAvailableAINodeException.java}
(74%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/auth/AuthorInfo.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/{AuthorInfo.java
=> auth/AuthorPlanExecutor.java} (89%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/auth/IAuthorPlanExecutor.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/NoHostnameVerificationTrustManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/DNAuditLogger.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/LoginLockManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/runtime/TableNotExistsRuntimeException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/util/ModsOperationUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/BatchEventProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/Disruptor.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/metadata/AlignedTimeseriesException.java
=> pipe/source/dataregion/realtime/disruptor/EventFactory.java} (64%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/CnToCnNodeRequestType.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/EventHandler.java}
(55%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/database/GetDatabasePlan.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/ExceptionHandler.java}
(52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/MultiProducerSequencer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/RingBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/Sequence.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/SequenceBarrier.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/SequenceGroups.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/mqtt/MQTTPublishHandler.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/mqtt/MQTTSource.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/MappingCollectOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/expression/CastComputation.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/IDualKeyCacheUpdating.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/{sys/KillQueryTask.java
=> metadata/ai/LoadModelTask.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{template/ShowPathSetTemplateTask.java
=> ai/ShowAIDevicesTask.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{template/ShowPathSetTemplateTask.java
=> ai/ShowLoadedModelsTask.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/{sys/KillQueryTask.java
=> metadata/ai/UnloadModelTask.java} (66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/ShowConfigurationTask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{audit/AuditLogStorage.java
=> queryengine/plan/expression/visitor/ConcatDeviceVisitor.java} (58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/cache/DeviceSchemaRequestCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/TreeAccessCheckContext.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/TreeAccessCheckVisitor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowTopics.java
=> LoadModel.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowTopics.java
=> ShowAIDevices.java} (58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{audit/AuditLogStorage.java
=> queryengine/plan/relational/sql/ast/ShowConfiguration.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowTopics.java
=> ShowLoadedModels.java} (55%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowTopics.java
=> UnloadModel.java} (52%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/{DropModelStatement.java
=> LoadModelStatement.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{ShowTTLStatement.java
=> model/ShowAIDevicesStatement.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys/SetSqlDialectStatement.java
=> metadata/model/ShowLoadedModelsStatement.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/{CreateModelStatement.java
=> UnloadModelStatement.java} (62%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkRetryTimesConfigurableException.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/AbstractShowExactTemplate.java}
(58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{SetConfigurationStatement.java
=> ShowConfigurationStatement.java} (58%)
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin =>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf}/BuiltinAggregationFunction.java
(98%)
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin =>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf}/BuiltinScalarFunction.java
(97%)
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin =>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf}/BuiltinTimeSeriesGeneratingFunction.java
(65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf/UDTFForecast.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/HmacColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/factory/HmacStrategiesFactory.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{audit/AuditLogStorage.java
=> queryengine/transformation/dag/column/binary/strategies/HmacStrategy.java}
(81%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/LpadColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/RpadColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/utils/BytePaddingUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToDoubleColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToFloatColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToIntColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToLongColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CRC32Transformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DoubleToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloatToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/GenericCodecColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/HmacConstantKeyColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LongToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/factory/CodecStrategiesFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/factory/NumericCodecStrategiesFactory.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{audit/AuditLogStorage.java
=>
queryengine/transformation/dag/column/unary/scalar/inteface/CodecStrategy.java}
(75%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/util/HexUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/util/SpookyHashV2Utils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/util/TransformerDebugUtils.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/statement/metadata/ShowConfigNodesStatement.java
=> storageengine/dataregion/read/reader/common/NoDataPointReader.java} (52%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/{LoadConvertedInsertTabletStatementExceptionVisitor.java
=> LoadTableConvertedInsertTabletStatementExceptionVisitor.java} (76%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/{LoadConvertedInsertTabletStatementExceptionVisitor.java
=> LoadTreeConvertedInsertTabletStatementExceptionVisitor.java} (97%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/EncryptDBUtils.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/{util =>
db/utils}/TabletDecoder.java (99%)
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/LoginLockManagerTest.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/queryengine/plan/analyze/load/TimeseriesMetadataIteratorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/PushAggregationThroughUnionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacMd5ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacSha1ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacSha256ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacSha512ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/LpadColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/RpadColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromBigEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromBigEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromIEEE754_32BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromIEEE754_64BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromLittleEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromLittleEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToBigEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToBigEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToIEEE754_32BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToIEEE754_64BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToLittleEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToLittleEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReverseColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/FromBase32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/FromBase64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/FromBase64UrlColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/ToBase32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/ToBase64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/ToBase64UrlColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Crc32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Md5ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Murmur3ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Sha1ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Sha256ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Sha512ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/SpookyHashV2_32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/SpookyHashV2_64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/XxHash64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hexEncoding/FromHexColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hexEncoding/ToHexColumnTransformerTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/AbstractAuditLogger.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/audit/AuditEventType.java}
(58%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/AuditLogFields.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/audit/AuditLogOperation.java
(94%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/IAuditEntity.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/audit/PrivilegeLevel.java}
(90%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/UserEntity.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/utils/AuthUtils.java
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{client
=> consensus/iotv2}/container/IoTV2GlobalComponentContainer.java (86%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeNonReportException.java}
(80%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/BidiMap.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/IterableSortedMap.java}
(66%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/OrderedBidiMap.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/ResettableListIterator.java}
(58%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/SortedBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/AbstractDualBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/DualTreeBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/collection/AbstractCollectionDecorator.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractIteratorDecorator.java}
(50%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractUntypedIteratorDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/ListIteratorWrapper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/keyvalue/AbstractMapEntryDecorator.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractIterableMap.java}
(58%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractSortedMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/EntrySetToMapIteratorAdapter.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/source/mqtt/MQTTSource.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{path/fa/dfa/transition/DFAWildcardTransition.java
=> pipe/datastructure/pattern/SingleTreePattern.java} (50%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/UnionIoTDBTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/UnionTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/Audit.java
