This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch skipNotSatisfiedTimeRange
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0425267e1c9 skip time range in MemPointIterator
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
new 5a58eb90d25 Merge branch 'iotdb_master' into skipNotSatisfiedTimeRange
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 31 +-
.github/workflows/cluster-it-1c1d1a.yml | 4 +-
.github/workflows/cluster-it-1c3d.yml | 26 +-
.github/workflows/compile-check.yml | 24 +-
.github/workflows/daily-it.yml | 208 ++-
.github/workflows/daily-ut.yml | 14 +-
.github/workflows/dependency-check.yml | 22 +-
.github/workflows/pipe-it.yml | 128 +-
.github/workflows/sonar-codecov.yml | 10 +-
.github/workflows/table-cluster-it-1c1d.yml | 33 +-
.github/workflows/table-cluster-it-1c3d.yml | 26 +-
.github/workflows/unit-test.yml | 22 +-
.github/workflows/vulnerability-check.yml | 12 +-
CONTRIBUTING.md | 2 +-
LICENSE | 35 +-
LICENSE-binary | 22 +-
README.md | 18 +-
README_ZH.md | 17 +-
dependencies.json | 1 -
docker/ReadMe.md | 2 +-
.../src/TableModelSessionExample.cpp | 4 +-
example/jdbc/pom.xml | 8 +
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 24 +
.../env/cluster/config/MppSharedCommonConfig.java | 28 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +-
.../it/env/remote/config/RemoteCommonConfig.java | 20 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 8 +
.../itbase/runtime/ClusterTestConnection.java | 10 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 4 +-
.../iotdb/itbase/runtime/NodeConnection.java | 12 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 239 +++
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 114 +-
.../ainode/it/AINodeInstanceManagementIT.java | 212 +++
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 35 +
.../iotdb/auth/it/IoTDBLoginLockManagerIT.java | 179 ++
...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 +-
...IoTDBRegionOperationReliabilityITFramework.java | 10 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 4 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 2 +-
... IoTDBRegionMigrateWithCompressionRatioIT.java} | 51 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 9 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 6 +-
.../iotdb/db/it/audit/IoTDBAuditLogBasicIT.java | 1272 +++++++++++++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 372 ++--
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 98 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 61 +-
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 154 +-
.../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 | 119 ++
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 12 +
.../iotdb/db/it/schema/IoTDBDeleteDatabaseIT.java | 3 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 139 +-
.../pipe/it/dual/tablemodel/TableModelUtils.java | 25 +-
.../tablemodel/manual/basic/IoTDBPipeAlterIT.java | 59 +-
.../manual/basic/IoTDBPipeDataSinkIT.java | 217 +--
.../manual/basic/IoTDBPipeLifeCycleIT.java | 220 +--
.../manual/basic/IoTDBPipePermissionIT.java | 124 +-
.../manual/basic/IoTDBPipeProtocolIT.java | 58 +-
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 264 +--
.../manual/basic/IoTDBPipeSwitchStatusIT.java | 62 +-
.../tablemodel/manual/basic/IoTDBPipeSyntaxIT.java | 47 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 7 +-
.../manual/basic/IoTDBTablePatternFormatIT.java | 287 +--
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 13 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 148 +-
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 88 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 32 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 72 +-
.../enhanced/IoTDBPipeSinkCompressionIT.java | 22 +-
.../manual/enhanced/IoTDBPipeSinkParallelIT.java | 6 +-
.../IoTDBPipeTypeConversionISessionIT.java | 4 +-
.../manual/enhanced/IoTDBPipeTypeConversionIT.java | 14 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java | 4 +-
.../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 | 12 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 52 +-
.../auto/basic/IoTDBPipeSinkParallelIT.java | 6 +-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 98 +-
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 64 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 25 +-
.../auto/basic/IoTDBTreePatternFormatIT.java | 18 +-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 104 +-
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 12 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 143 +-
.../enhanced/IoTDBPipeConditionalOperationsIT.java | 16 +-
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 15 +-
.../auto/enhanced/IoTDBPipeNullValueIT.java | 28 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 22 +-
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 12 +-
.../treemodel/auto/enhanced/PipeNowFunctionIT.java | 13 +-
.../manual/AbstractPipeDualTreeModelManualIT.java | 4 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 50 +-
.../manual/IoTDBPipeManualConflictIT.java | 24 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 43 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 28 +-
.../treemodel/manual/IoTDBPipeMetaRestartIT.java | 23 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 12 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 91 +-
.../treemodel/manual/IoTDBPipeReqAutoSliceIT.java | 4 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 5 +-
.../manual/IoTDBPipeTypeConversionIT.java | 15 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 18 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 15 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 86 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 8 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 6 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 56 +
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 85 +-
.../scalar/IoTDBBitwiseFunctionTableIT.java | 36 +-
.../it/query/recent/IoTDBMaintainAuthIT.java | 40 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 18 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 19 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 4 +-
.../it/session/IoTDBSessionRelationalIT.java | 82 +
.../iotdb/session/it/IoTDBSessionComplexIT.java | 15 +-
.../iotdb/session/it/IoTDBSessionCompressedIT.java | 10 +-
.../IoTDBSubscriptionConsumerGroupIT.java | 58 +-
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 20 +-
.../relational/table/argument/ScalarArgument.java | 22 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 10 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 6 +-
.../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 80 -
.../iotdb/tool/backup/IoTDBDataBackTool.java | 4 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 7 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 2 +
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 5 +-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 2 +
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 12 +
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 | 4 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 1763 +++++++++---------
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 14 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 572 +++---
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 -
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 4 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 17 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 37 +
.../java/org/apache/iotdb/session/Session.java | 2 +-
iotdb-core/ainode/.gitignore | 14 +-
iotdb-core/ainode/iotdb/__init__.py | 17 -
iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 2 +
iotdb-core/ainode/iotdb/ainode/core/constant.py | 5 +-
iotdb-core/ainode/iotdb/ainode/core/exception.py | 4 +-
.../abstract_batcher.py} | 17 +-
.../ainode/core/inference/batcher/basic_batcher.py | 63 +
.../core/inference/dispatcher/basic_dispatcher.py | 4 +-
.../ainode/core/inference/inference_request.py | 12 +-
.../core/inference/inference_request_pool.py | 153 +-
.../iotdb/ainode/core/inference/pool_controller.py | 460 ++++-
.../iotdb/ainode/core/inference/pool_group.py | 49 +-
.../pool_scheduler/abstract_pool_scheduler.py | 33 +-
.../pool_scheduler/basic_pool_scheduler.py | 152 +-
.../strategy/timerxl_inference_pipeline.py | 6 +-
iotdb-core/ainode/iotdb/ainode/core/log.py | 1 +
.../iotdb/ainode/core/manager/inference_manager.py | 123 +-
.../iotdb/ainode/core/manager/model_manager.py | 17 +-
.../ainode/iotdb/ainode/core/manager/utils.py | 19 +-
.../iotdb/ainode/core/model/model_storage.py | 6 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 59 +
iotdb-core/ainode/iotdb/ainode/core/script.py | 5 +-
.../ainode/iotdb/ainode/core/util/atmoic_int.py | 66 +
.../iotdb/ainode/core/util/batch_executor.py | 133 ++
.../ainode/iotdb/ainode/core/util/gpu_mapping.py | 93 +
.../ainode/iotdb/ainode/core/util/thread_name.py | 7 +-
iotdb-core/ainode/poetry.lock | 694 +++----
iotdb-core/ainode/pom.xml | 40 +-
iotdb-core/ainode/pyproject.toml | 105 +-
.../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 | 11 +
.../iotdb/confignode/audit/CNAuditLogger.java | 94 +
.../async/AsyncDataNodeHeartbeatClientPool.java | 11 +
.../client/async/CnToDnAsyncRequestType.java | 3 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 8 +-
.../audit/DataNodeWriteAuditLogHandler.java} | 29 +-
.../client/sync/SyncDataNodeClientPool.java | 3 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 9 +-
.../conf/ConfigNodeSystemPropertiesHandler.java | 23 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 18 +
.../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 +-
.../response/auth/PermissionInfoResp.java | 11 +
.../response/pipe/task/PipeTableResp.java | 91 +-
...eption.java => NoAvailableAINodeException.java} | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 138 +-
.../apache/iotdb/confignode/manager/IManager.java | 35 +-
.../iotdb/confignode/manager/ModelManager.java | 96 +-
.../confignode/manager/PermissionManager.java | 21 +-
.../iotdb/confignode/manager/ProcedureManager.java | 10 +-
.../manager/load/balancer/PartitionBalancer.java | 4 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 4 +-
.../region/GreedyRegionGroupAllocator.java | 4 +-
.../manager/load/service/HeartbeatService.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 49 +-
.../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 | 14 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 5 +-
.../payload/PipeTransferConfigSnapshotSealReq.java | 8 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 5 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 8 +-
.../pipe/source/ConfigRegionListeningFilter.java | 11 +-
.../pipe/source/ConfigRegionListeningQueue.java | 25 +-
.../pipe/source/IoTDBConfigRegionSource.java | 3 +-
.../manager/schema/ClusterSchemaManager.java | 14 +-
.../confignode/persistence/auth/AuthorInfo.java | 169 ++
.../AuthorPlanExecutor.java} | 290 ++-
.../persistence/auth/IAuthorPlanExecutor.java | 62 +
.../persistence/executor/ConfigPlanExecutor.java | 15 +-
.../persistence/partition/PartitionInfo.java | 13 +-
.../schema/CNPhysicalPlanGenerator.java | 32 +-
.../persistence/schema/ClusterSchemaInfo.java | 20 +-
.../confignode/persistence/schema/ConfigMTree.java | 7 +-
.../schema/ConfigNodeSnapshotParser.java | 5 +-
.../persistence/schema/TemplateTable.java | 8 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 2 +
.../impl/pipe/task/CreatePipeProcedureV2.java | 46 +-
.../impl/schema/AlterLogicalViewProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 17 +-
.../confignode/procedure/store/ProcedureType.java | 2 +
.../iotdb/confignode/service/ConfigNode.java | 27 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 98 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 4 +-
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 3 +-
.../confignode/persistence/AuthorInfoTest.java | 5 +-
.../persistence/CNPhysicalPlanGeneratorTest.java | 43 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 1 +
.../persistence/schema/ConfigMTreeTest.java | 22 +-
.../pipe/annotation/PipePluginAnnotationTest.java | 11 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedureTest.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 3 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 13 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 9 +-
.../utils/NoHostnameVerificationTrustManager.java | 88 +
.../apache/iotdb/consensus/ratis/utils/Utils.java | 25 +-
iotdb-core/datanode/pom.xml | 7 +
.../org/apache/iotdb/db/audit/AuditLogger.java | 271 ---
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 463 +++++
.../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 | 387 ++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 158 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 29 +-
.../dataregion/DataExecutionVisitor.java | 4 +-
.../runtime/TableNotExistsRuntimeException.java | 36 -
.../PipeDataRegionSourceConstructor.java | 4 -
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 28 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 12 +-
.../agent/task/connection/PipeEventCollector.java | 16 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 6 +
.../db/pipe/event/common/PipeInsertionEvent.java | 16 +-
.../common/deletion/PipeDeleteDataNodeEvent.java | 19 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 10 +
.../schema/PipeSchemaRegionWritePlanEvent.java | 10 +-
.../statement/PipeStatementInsertionEvent.java | 6 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 24 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 43 +-
.../event/common/terminate/PipeTerminateEvent.java | 4 +
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 8 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 89 +-
.../table/TsFileInsertionEventTableParser.java | 9 +-
...ileInsertionEventTableParserTabletIterator.java | 25 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 25 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 34 +
.../downsampling/PartialPathLastObjectCache.java | 60 +-
.../schemachange/RenameDatabaseProcessor.java | 2 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 9 +-
.../protocol/legacy/loader/DeletionLoader.java | 9 +-
.../protocol/legacy/loader/TsFileLoader.java | 9 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 45 +-
.../statement/PipeConvertedInsertRowStatement.java | 13 +-
.../visitor/PipeStatementTSStatusVisitor.java | 3 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 17 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 78 +-
.../client/IoTDBDataNodeSyncClientManager.java | 7 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 14 +-
.../handler/PipeTransferTrackableHandler.java | 5 +
.../thrift/sync/IoTDBDataNodeSyncSink.java | 5 +-
.../sink/protocol/writeback/WriteBackSink.java | 30 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 113 +-
.../realtime/PipeRealtimeDataRegionSource.java | 22 +
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +
.../dataregion/realtime/epoch/TsFileEpoch.java | 13 +-
.../matcher/CachedSchemaPatternMatcher.java | 32 +-
.../db/pipe/source/mqtt/MQTTPublishHandler.java | 320 ----
.../iotdb/db/pipe/source/mqtt/MQTTSource.java | 264 ---
.../schemaregion/IoTDBSchemaRegionSource.java | 9 +-
.../PipePlanTablePrivilegeParseVisitor.java | 36 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 90 +-
.../db/protocol/client/DataNodeInternalClient.java | 13 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 15 +-
.../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 +
.../v1/handler/StatementConstructionHandler.java | 7 +-
.../rest/v1/handler/ExecuteStatementHandler.java | 4 +
.../rest/v1/handler/QueryDataSetHandler.java | 4 +
.../rest/v2/handler/ExecuteStatementHandler.java | 4 +
.../rest/v2/handler/QueryDataSetHandler.java | 4 +
.../iotdb/db/protocol/session/IClientSession.java | 10 +
.../iotdb/db/protocol/session/SessionManager.java | 210 +--
.../iotdb/db/protocol/thrift/OperationType.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 358 ++--
.../impl/DataNodeInternalRPCServiceImpl.java | 64 +-
.../db/queryengine/common/MPPQueryContext.java | 116 +-
.../iotdb/db/queryengine/common/SessionInfo.java | 75 +-
.../common/header/DatasetHeaderFactory.java | 8 +
.../common/schematree/DeviceSchemaInfo.java | 12 +-
.../execution/executor/RegionWriteExecutor.java | 14 +-
.../execution/fragment/DataNodeQueryContext.java | 68 +-
.../fragment/FragmentInstanceContext.java | 7 +-
.../process/InsertTabletStatementGenerator.java | 39 +-
.../TableInsertTabletStatementGenerator.java | 2 +-
.../TreeInsertTabletStatementGenerator.java | 2 +-
.../operator/source/ShowQueriesOperator.java | 10 +-
.../InformationSchemaContentSupplierFactory.java | 127 +-
.../relational/LastQueryAggTableScanOperator.java | 99 +-
.../aggregation/approximate/HyperLogLog.java | 11 +-
.../queue/IndexedBlockingReserveQueue.java | 3 +-
.../metric/DriverSchedulerMetricSet.java | 20 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 26 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 3 -
.../queryengine/plan/analyze/AnalyzeVisitor.java | 160 +-
.../plan/analyze/ClusterPartitionFetcher.java | 76 +-
.../plan/analyze/IPartitionFetcher.java | 13 +-
.../analyze/cache/partition/PartitionCache.java | 49 +-
.../cache/schema/DataNodeDevicePathCache.java | 2 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 2 +-
.../schema/dualkeycache/IDualKeyCacheUpdating.java | 45 -
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 2 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 9 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 107 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 47 +-
.../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 | 281 ++-
.../execution/config/TreeConfigTaskVisitor.java | 93 +-
.../config/executor/ClusterConfigTaskExecutor.java | 164 +-
.../config/executor/IConfigTaskExecutor.java | 11 +-
.../{CreateModelTask.java => LoadModelTask.java} | 12 +-
.../ShowAIDevicesTask.java} | 38 +-
.../ShowLoadedModelsTask.java} | 41 +-
.../{CreateModelTask.java => UnloadModelTask.java} | 12 +-
.../template/ShowNodesInSchemaTemplateTask.java | 47 +-
.../metadata/template/ShowPathSetTemplateTask.java | 20 +-
.../plan/execution/config/sys/KillQueryTask.java | 3 +-
.../config/sys/ShowConfigurationTask.java | 6 +
.../execution/config/sys/pipe/ShowPipeTask.java | 6 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 120 +-
.../plan/parser/StatementGenerator.java | 6 +-
.../plan/planner/LogicalPlanBuilder.java | 13 +-
.../plan/planner/LogicalPlanVisitor.java | 3 +-
.../plan/planner/OperatorTreeGenerator.java | 15 +-
.../plan/planner/TableOperatorGenerator.java | 176 +-
.../plan/planner/distribution/SourceRewriter.java | 31 +
.../metadata/write/view/AlterLogicalViewNode.java | 44 +-
.../planner/plan/node/source/ShowQueriesNode.java | 18 +-
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 58 +-
.../relational/metadata/TableMetadataImpl.java | 4 +-
.../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/TranslationMap.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 3 +
.../distribute/TableModelQueryFragmentPlanner.java | 42 +
.../planner/node/AggregationTableScanNode.java | 62 +
.../plan/relational/security/AccessControl.java | 106 +-
.../relational/security/AccessControlImpl.java | 457 +++--
.../relational/security/AllowAllAccessControl.java | 120 +-
.../relational/security/ITableAuthChecker.java | 51 +-
.../relational/security/ITableAuthCheckerImpl.java | 375 +++-
.../relational/security/TableModelPrivilege.java | 41 +
.../security/TreeAccessCheckContext.java | 140 ++
.../security/TreeAccessCheckVisitor.java | 1910 ++++++++++++++++++++
.../sql/ast/AbstractQueryDeviceWithCache.java | 3 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 2 +-
.../plan/relational/sql/ast/AstVisitor.java | 16 +
.../plan/relational/sql/ast/DeleteDevice.java | 5 +-
.../sql/ast/{CreateModel.java => LoadModel.java} | 23 +-
.../sql/ast/RelationalAuthorStatement.java | 158 +-
.../ast/{NaturalJoin.java => ShowAIDevices.java} | 34 +-
.../{RemoveAINode.java => ShowLoadedModels.java} | 26 +-
.../sql/ast/{CreateModel.java => UnloadModel.java} | 22 +-
.../relational/sql/ast/WrappedInsertStatement.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 134 +-
.../plan/relational/type/AuthorRType.java | 5 +-
.../db/queryengine/plan/statement/AuthorType.java | 14 +-
.../statement/AuthorityInformationStatement.java | 30 +-
.../db/queryengine/plan/statement/Statement.java | 8 -
.../queryengine/plan/statement/StatementType.java | 5 +-
.../plan/statement/StatementVisitor.java | 39 +-
.../plan/statement/crud/DeleteDataStatement.java | 17 -
.../plan/statement/crud/InsertBaseStatement.java | 21 +-
.../crud/InsertMultiTabletsStatement.java | 1 +
.../plan/statement/crud/InsertRowsStatement.java | 1 +
.../plan/statement/crud/InsertStatement.java | 17 -
.../plan/statement/crud/InsertTabletStatement.java | 24 +-
.../plan/statement/crud/LoadTsFileStatement.java | 8 -
.../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 -
.../AbstractShowExactTemplate.java} | 22 +-
.../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 | 237 +--
.../statement/sys/ExplainAnalyzeStatement.java | 6 -
.../plan/statement/sys/KillQueryStatement.java | 17 +-
.../statement/sys/SetConfigurationStatement.java | 39 +
.../plan/statement/sys/SetSqlDialectStatement.java | 8 -
.../statement/sys/ShowConfigurationStatement.java | 13 +
.../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 -
.../schemaregion/SchemaRegionLoader.java | 18 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 3 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 5 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 17 -
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 17 -
.../mtree/loader/MNodeFactoryLoader.java | 25 +-
.../mtree/traverser/counter/DatabaseCounter.java | 13 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 2 +-
.../schemaregion/utils/MetaFormatUtils.java | 2 +-
.../db/schemaengine/table/DataNodeTableCache.java | 15 +-
.../template/ClusterTemplateManager.java | 24 +-
.../db/schemaengine/template/ITemplateManager.java | 2 +
.../java/org/apache/iotdb/db/service/DataNode.java | 71 +-
.../db/service/DataNodeInternalRPCService.java | 14 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 19 +
.../metrics/IoTDBInternalLocalReporter.java | 15 +-
.../db/storageengine/dataregion/DataRegion.java | 64 +-
.../performer/impl/FastCompactionPerformer.java | 18 +-
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../impl/ReadPointCompactionPerformer.java | 6 +-
.../execute/utils/CompactionPathUtils.java | 9 +-
.../execute/utils/CompactionTableSchema.java | 11 +-
.../utils/CompactionTableSchemaCollector.java | 33 +-
.../compaction/execute/utils/CompactionUtils.java | 16 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 39 +-
.../executor/fast/SeriesCompactionExecutor.java | 6 +-
.../utils/writer/AbstractCompactionWriter.java | 11 +
.../estimator/AbstractCompactionEstimator.java | 4 +
.../RepairUnsortedFileCompactionEstimator.java | 5 +
.../impl/NewSizeTieredCompactionSelector.java | 2 +-
.../selector/impl/SettleSelectorImpl.java | 2 +-
.../compaction/tool/SingleSequenceFileTask.java | 11 +-
.../compaction/tool/TimePartitionProcessTask.java | 9 +-
.../dataregion/flush/CompressionRatio.java | 19 +-
.../dataregion/memtable/TsFileProcessor.java | 5 +-
.../dataregion/modification/ModificationFile.java | 2 -
.../dataregion/snapshot/SnapshotLoader.java | 42 +-
.../dataregion/snapshot/SnapshotTaker.java | 27 +
.../dataregion/tsfile/TsFileResource.java | 25 +-
.../db/storageengine/load/LoadTsFileManager.java | 2 +-
...vertedInsertTabletStatementTSStatusVisitor.java | 3 +-
...rtedInsertTabletStatementExceptionVisitor.java} | 18 +-
...leStatementDataTypeConvertExecutionVisitor.java | 23 +-
...rtedInsertTabletStatementExceptionVisitor.java} | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 19 +-
.../converter/LoadTsFileDataTypeConverter.java | 19 +-
.../load/splitter/TsFileSplitter.java | 21 +
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../agent/SubscriptionAgentLauncher.java | 4 +-
.../event/cache/SubscriptionPollResponseCache.java | 54 +-
.../resource/log/SubscriptionLogStatus.java | 2 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 25 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 16 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 5 +-
.../iotdb/db/tools/utils/TsFileStatisticScan.java | 6 +-
.../db/trigger/executor/TriggerFireVisitor.java | 6 +
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 200 +-
.../iotdb/{util => db/utils}/TabletDecoder.java | 2 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 3 +
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 538 ++++++
.../auth/authorizer/LocalFileAuthorizerTest.java | 4 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 16 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 19 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 19 +-
.../db/pipe/consensus/DeletionResourceTest.java | 2 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 3 +
.../annotation/PipePluginAnnotationTest.java | 11 +-
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 22 +-
.../operator/MergeTreeSortOperatorTest.java | 4 +-
.../plan/analyze/ExpressionAnalyzerTest.java | 2 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 7 +-
.../plan/analyze/FakeSchemaFetcherImpl.java | 22 +-
.../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 +-
.../plan/relational/analyzer/TSBSMetadata.java | 10 +-
.../plan/relational/analyzer/TestMetadata.java | 10 +-
.../relational/sql/parser/AuthorStatementTest.java | 27 +-
.../compaction/AbstractCompactionTest.java | 2 +
.../CompactionTableSchemaCollectorTest.java | 8 +-
.../TableModelFastCompactionPerformerTest.java | 125 +-
...TableModelReadChunkCompactionPerformerTest.java | 94 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 8 +
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 | 1 +
.../conf/iotdb-system.properties.template | 13 +-
.../iotdb/commons/audit/AbstractAuditLogger.java | 125 ++
.../iotdb/commons/audit/AuditEventType.java} | 47 +-
.../apache/iotdb/commons/audit/AuditLogFields.java | 182 ++
.../iotdb/commons}/audit/AuditLogOperation.java | 4 +-
.../IAuditEntity.java} | 49 +-
.../iotdb/commons/audit/PrivilegeLevel.java} | 8 +-
.../org/apache/iotdb/commons/audit/UserEntity.java | 154 ++
.../commons/auth/authorizer/BasicAuthorizer.java | 24 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 28 +
.../auth/authorizer/LocalFileAuthorizer.java | 4 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 5 +
.../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 | 82 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 154 +-
.../commons/auth/user/LocalFileUserAccessor.java | 57 +-
.../commons/auth/user/LocalFileUserManager.java | 1 +
.../apache/iotdb/commons/auth/utils/AuthUtils.java | 49 +
.../apache/iotdb/commons/client/ThriftClient.java | 4 +-
.../iotdb/commons/client/ainode/AINodeClient.java | 53 +
.../apache/iotdb/commons/conf/CommonConfig.java | 109 +-
.../iotdb/commons/conf/CommonDescriptor.java | 30 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 43 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
.../iotdb/commons/partition/SchemaPartition.java | 6 +
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 3 -
.../plugin/builtin/source/mqtt/MQTTSource.java | 68 -
.../commons/pipe/agent/task/PipeTaskAgent.java | 6 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 4 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../pipe/config/constant/PipeSinkConstant.java | 6 +
.../pipe/config/constant/PipeSourceConstant.java | 34 +-
.../pipe/config/constant/SystemConstant.java | 5 +-
.../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 | 52 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 55 +-
.../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 | 4 +
.../iotdb/commons/pipe/source/IoTDBSource.java | 15 +
.../iotdb/commons/schema/SchemaConstant.java | 1 +
.../schema/column/ColumnHeaderConstant.java | 18 +
.../apache/iotdb/commons/schema/table/Audit.java} | 38 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 36 +-
.../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 | 79 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 32 +
.../src/main/thrift/confignode.thrift | 77 +-
.../src/main/thrift/datanode.thrift | 38 +-
pom.xml | 8 +-
scripts/sbin/start-cli.sh | 9 +-
scripts/sbin/windows/start-cli-table.bat | 124 +-
scripts/sbin/windows/start-cli.bat | 234 +--
702 files changed, 22366 insertions(+), 10749 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
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/{IoTDBRegionMigrateWithLastEmptyDeletionIT.java
=> IoTDBRegionMigrateWithCompressionRatioIT.java} (63%)
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
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/cli/IoTDBSyntaxHighlighter.java
copy
iotdb-core/ainode/iotdb/ainode/core/inference/{dispatcher/abstract_dispatcher.py
=> batcher/abstract_batcher.py} (64%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/batcher/basic_batcher.py
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
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/gpu_mapping.py
copy iotdb-client/session/src/test/resources/iotdb-datanode.properties =>
iotdb-core/ainode/iotdb/ainode/core/util/thread_name.py (88%)
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%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/exception/{DatabaseNotExistsException.java
=> NoAvailableAINodeException.java} (79%)
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
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
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/metadata/ai/{CreateModelTask.java
=> LoadModelTask.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ShowClusterIdTask.java
=> ai/ShowAIDevicesTask.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ShowAINodesTask.java
=> ai/ShowLoadedModelsTask.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/{CreateModelTask.java
=> UnloadModelTask.java} (82%)
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/{CreateModel.java
=> LoadModel.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{NaturalJoin.java
=> ShowAIDevices.java} (80%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{RemoveAINode.java
=> ShowLoadedModels.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreateModel.java
=> UnloadModel.java} (73%)
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/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{UnSetTTLStatement.java
=> template/AbstractShowExactTemplate.java} (64%)
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%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/{util =>
db/utils}/TabletDecoder.java (99%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/LoginLockManagerTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/AbstractAuditLogger.java
copy
iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/SystemType.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%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{exception/IllegalPrivilegeException.java
=> audit/IAuditEntity.java} (51%)
rename
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
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/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/RemoveRootPrefixVisitor.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/table/Audit.java}
(50%)
