This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-collector
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8b7a762b88a fix
add 52da69813b0 Fixed the NPE of TableDeviceLastEntry
add 1b0af7dfd25 Permission for Relation model
add f2d24ffdc7d Introduce operator of window function.
add 25128fcc1a7 Remove duplicate code in column transformer
add 9c9b2393af3 Fix query error after insert an all null aligned tablet
and flush (#14777)
add 024b05cc4d8 Fixed the bug that the database is not totally separated
in partition cache
add 526f678f746 [RatisConsensus] Prevent misuse of addRemotePeer (#14779)
add 43eb55ad927 Pipe: Introduce periodic verification for username and
password on receiver side (#14764)
add 02ff0d27c57 Pipe / Load: Enable validation skip for load tsFile
(#14774)
add cbd683ece36 Adapte table model in import/export tools (#14677)
add 03b4ea2e7ba Merge branch 'master' of https://github.com/apache/iotdb
into iotdb-collector
add b9bca568cfe refactor IService
No new revisions were added by this update.
Summary of changes:
.../it/database/IoTDBDatabaseSetAndDeleteIT.java | 4 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 137 +--
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 71 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 513 +++++++++
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 350 ++++++
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 71 ++
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 16 +-
.../pipe/it/tablemodel/IoTDBPipeDataSinkIT.java | 97 ++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 22 +
.../relational/it/schema/IoTDBDatabaseIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 70 ++
.../org/apache/iotdb/tool/common/Constants.java | 319 ++++++
.../org/apache/iotdb/tool/common/OptionsUtil.java | 915 ++++++++++++++++
.../apache/iotdb/tool/data/AbstractDataTool.java | 1019 +++++-------------
.../apache/iotdb/tool/data/AbstractExportData.java | 70 ++
.../AbstractImportData.java} | 216 ++--
.../apache/iotdb/tool/data/AsyncImportData.java | 160 ---
.../org/apache/iotdb/tool/data/ExportData.java | 775 +++-----------
.../apache/iotdb/tool/data/ExportDataTable.java | 341 ++++++
.../org/apache/iotdb/tool/data/ExportDataTree.java | 420 ++++++++
.../org/apache/iotdb/tool/data/ImportData.java | 793 ++++++--------
.../apache/iotdb/tool/data/ImportDataScanTool.java | 4 -
.../apache/iotdb/tool/data/ImportDataTable.java | 392 +++++++
.../org/apache/iotdb/tool/data/ImportDataTree.java | 476 +++++++++
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 12 +-
.../iotdb/tool/tsfile/ImportTsFileLocally.java | 8 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 8 +
.../org/apache/iotdb/collector/Application.java | 62 +-
.../iotdb/collector/config/CollectorConfig.java | 4 -
.../apache/iotdb/collector/service/ApiService.java | 48 +-
.../apache/iotdb/collector/service/IService.java | 17 +-
iotdb-collector/collector-openapi/pom.xml | 8 +-
.../consensus/request/ConfigPhysicalPlan.java | 34 +-
.../consensus/request/ConfigPhysicalPlanType.java | 33 +
.../request/read/auth/AuthorReadPlan.java | 143 ---
.../consensus/request/write/auth/AuthorPlan.java | 168 +--
.../request/write/auth/AuthorRelationalPlan.java | 167 +++
.../auth/{AuthorPlan.java => AuthorTreePlan.java} | 176 +--
.../statemachine/ConfigRegionStateMachine.java | 1 -
.../iotdb/confignode/manager/ConfigManager.java | 18 +-
.../apache/iotdb/confignode/manager/IManager.java | 6 +-
.../confignode/manager/PermissionManager.java | 23 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 34 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 66 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 551 +++++-----
.../persistence/executor/ConfigPlanExecutor.java | 40 +-
.../schema/CNPhysicalPlanGenerator.java | 148 ++-
.../persistence/schema/ClusterSchemaInfo.java | 6 +-
.../impl/sync/AuthOperationProcedure.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 98 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 45 +-
...figPhysicalPlanTreePatternParseVisitorTest.java | 18 +-
.../confignode/persistence/AuthorInfoTest.java | 917 +++++++---------
.../persistence/CNPhysicalPlanGeneratorTest.java | 23 +-
.../ConfigRegionListeningQueueTest.java | 4 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 4 +-
.../impl/sync/AuthOperationProcedureTest.java | 39 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 11 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 215 +++-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 8 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 475 +++++----
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 37 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../async/IoTDBDataRegionAsyncConnector.java | 3 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 44 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 20 +-
.../process/window/TableWindowOperator.java | 411 +++++++
.../function/WindowFunction.java} | 30 +-
.../aggregate/AggregationWindowFunction.java | 113 ++
.../function/aggregate/WindowAggregator.java} | 104 +-
.../function/rank/CumeDistFunction.java} | 33 +-
.../function/rank/DenseRankFunction.java} | 33 +-
.../function/rank/NTileFunction.java} | 48 +-
.../function/rank/PercentRankFunction.java} | 53 +-
.../function/rank/RankFunction.java} | 38 +-
.../window/function/rank/RankWindowFunction.java | 66 ++
.../function/rank/RowNumberFunction.java} | 24 +-
.../window/function/value/FirstValueFunction.java | 64 ++
.../process/window/function/value/LagFunction.java | 77 ++
.../window/function/value/LastValueFunction.java | 64 ++
.../window/function/value/LeadFunction.java | 79 ++
.../window/function/value/NthValueFunction.java | 81 ++
.../function/value/ValueWindowFunction.java} | 40 +-
.../process/window/partition/Partition.java | 226 ++++
.../window/partition/PartitionExecutor.java | 197 ++++
.../partition/frame/Frame.java} | 8 +-
.../process/window/partition/frame/FrameInfo.java | 145 +++
.../window/partition/frame/GroupsFrame.java | 238 +++++
.../process/window/partition/frame/RangeFrame.java | 617 +++++++++++
.../process/window/partition/frame/RowsFrame.java | 108 ++
.../operator/process/window/utils/ColumnList.java | 141 +++
.../utils/Range.java} | 20 +-
.../process/window/utils/RowComparator.java | 231 ++++
.../InformationSchemaContentSupplierFactory.java | 9 +-
.../relational/aggregation/AvgAccumulator.java | 2 +-
.../relational/ColumnTransformerBuilder.java | 234 ++--
.../iotdb/db/queryengine/plan/Coordinator.java | 9 +-
.../analyze/cache/partition/PartitionCache.java | 5 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 17 +-
.../RelationalAuthorizerTask.java} | 23 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 7 +-
.../metadata/write/view/AlterLogicalViewNode.java | 2 +-
.../fetcher/cache/TableDeviceLastCache.java | 2 +-
.../plan/relational/security/AccessControl.java | 10 +
.../relational/security/AccessControlImpl.java | 217 ++++
.../relational/security/AllowAllAccessControl.java | 7 +
.../relational/security/ITableAuthChecker.java | 17 +
.../relational/security/ITableAuthCheckerImpl.java | 169 +++
.../relational/security/TableModelPrivilege.java | 54 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/ast/LoadTsFile.java | 7 +
.../sql/ast/RelationalAuthorStatement.java | 247 +++++
.../plan/relational/sql/parser/AstBuilder.java | 260 +++++
.../plan/relational/sql/util/SqlFormatter.java | 223 ++++
.../type/{TypeManager.java => AuthorRType.java} | 48 +-
.../statement/AuthorityInformationStatement.java | 2 +-
.../plan/statement/crud/DeleteDataStatement.java | 3 +-
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../plan/statement/crud/InsertStatement.java | 2 +-
.../plan/statement/crud/QueryStatement.java | 2 +-
.../InternalBatchActivateTemplateStatement.java | 3 +-
.../InternalCreateMultiTimeSeriesStatement.java | 2 +-
.../InternalCreateTimeSeriesStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 3 +-
.../statement/metadata/CountDevicesStatement.java | 6 +-
.../metadata/CountTimeSeriesStatement.java | 6 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateContinuousQueryStatement.java | 2 +-
.../metadata/CreateFunctionStatement.java | 2 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 3 +-
.../statement/metadata/CreateTriggerStatement.java | 2 +-
.../metadata/DatabaseSchemaStatement.java | 2 +-
.../metadata/DeleteDatabaseStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 3 +-
.../metadata/DropContinuousQueryStatement.java | 2 +-
.../statement/metadata/DropFunctionStatement.java | 2 +-
.../statement/metadata/DropTriggerStatement.java | 2 +-
.../metadata/RemoveDataNodeStatement.java | 2 +-
.../plan/statement/metadata/SetTTLStatement.java | 3 +-
.../statement/metadata/ShowClusterStatement.java | 2 +-
.../metadata/ShowContinuousQueriesStatement.java | 2 +-
.../statement/metadata/ShowDevicesStatement.java | 6 +-
.../statement/metadata/ShowFunctionsStatement.java | 2 +-
.../metadata/ShowTimeSeriesStatement.java | 6 +-
.../statement/metadata/ShowTriggersStatement.java | 2 +-
.../metadata/model/CreateModelStatement.java | 2 +-
.../metadata/model/DropModelStatement.java | 2 +-
.../metadata/model/ShowModelsStatement.java | 2 +-
.../metadata/pipe/AlterPipeStatement.java | 2 +-
.../metadata/pipe/CreatePipePluginStatement.java | 2 +-
.../metadata/pipe/CreatePipeStatement.java | 2 +-
.../metadata/pipe/DropPipePluginStatement.java | 2 +-
.../statement/metadata/pipe/DropPipeStatement.java | 2 +-
.../metadata/pipe/ShowPipePluginsStatement.java | 2 +-
.../metadata/pipe/ShowPipesStatement.java | 2 +-
.../metadata/pipe/StartPipeStatement.java | 2 +-
.../statement/metadata/pipe/StopPipeStatement.java | 2 +-
.../metadata/region/ExtendRegionStatement.java | 2 +-
.../metadata/region/MigrateRegionStatement.java | 2 +-
.../region/ReconstructRegionStatement.java | 2 +-
.../metadata/region/RemoveRegionStatement.java | 2 +-
.../subscription/CreateTopicStatement.java | 2 +-
.../metadata/subscription/DropTopicStatement.java | 2 +-
.../subscription/ShowSubscriptionsStatement.java | 2 +-
.../metadata/subscription/ShowTopicsStatement.java | 2 +-
.../template/ActivateTemplateStatement.java | 3 +-
.../template/BatchActivateTemplateStatement.java | 3 +-
.../template/DeactivateTemplateStatement.java | 3 +-
.../metadata/view/AlterLogicalViewStatement.java | 6 +-
.../metadata/view/CreateLogicalViewStatement.java | 6 +-
.../metadata/view/DeleteLogicalViewStatement.java | 3 +-
.../metadata/view/RenameLogicalViewStatement.java | 2 +-
.../plan/statement/sys/AuthorStatement.java | 56 +-
.../plan/statement/sys/KillQueryStatement.java | 2 +-
.../plan/statement/sys/ShowQueriesStatement.java | 2 +-
.../dataregion/flush/MemTableFlushTask.java | 2 +-
.../memtable/AlignedWritableMemChunk.java | 13 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 2 +-
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../load/config/LoadTsFileConfigurator.java | 20 +
.../iotdb/db/auth/AuthorizerManagerTest.java | 318 +++---
.../auth/authorizer/LocalFileAuthorizerTest.java | 226 ++--
.../db/auth/entity/DataBasePrivilegeTest.java | 75 ++
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 42 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 57 +-
.../iotdb/db/auth/entity/TablePrivilegeTest.java | 67 ++
.../org/apache/iotdb/db/auth/entity/UserTest.java | 14 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 87 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 162 +--
.../db/auth/user/LocalFileUserAccessorTest.java | 119 +--
.../db/auth/user/LocalFileUserManagerTest.java | 117 +-
.../process/window/TableWindowOperatorTest.java | 320 ++++++
.../window/TableWindowOperatorTestUtils.java | 131 +++
.../process/window/function/FunctionTestUtils.java | 113 ++
.../aggregate/AggregationWindowFunctionTest.java | 195 ++++
.../window/function/rank/CumeDistFunctionTest.java | 72 ++
.../function/rank/DenseRankFunctionTest.java | 71 ++
.../window/function/rank/NTileFunctionTest.java | 128 +++
.../function/rank/PercentRankFunctionTest.java | 72 ++
.../window/function/rank/RankFunctionTest.java | 71 ++
.../function/rank/RowNumberFunctionTest.java | 70 ++
.../function/value/FirstValueFunctionTest.java | 120 +++
.../window/function/value/LagFunctionTest.java | 159 +++
.../function/value/LastValueFunctionTest.java | 120 +++
.../window/function/value/LeadFunctionTest.java | 159 +++
.../function/value/NthValueFunctionTest.java | 150 +++
.../window/partition/frame/FrameTestUtils.java | 139 +++
.../window/partition/frame/GroupsFrameTest.java | 359 +++++++
.../window/partition/frame/RangeFrameTest.java | 1127 ++++++++++++++++++++
.../window/partition/frame/RowsFrameTest.java | 359 +++++++
.../plan/parser/StatementGeneratorTest.java | 13 +-
.../relational/sql/parser/AuthorStatementTest.java | 351 ++++++
.../security/encrypt/MessageDigestEncryptTest.java | 8 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 271 ++---
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 142 +--
.../commons/auth/authorizer/OpenIdAuthorizer.java | 9 +-
.../commons/auth/entity/DatabasePrivilege.java | 250 +++++
.../IEntityAccessor.java} | 42 +-
.../iotdb/commons/auth/entity/ModelType.java | 9 +-
.../iotdb/commons/auth/entity/PathPrivilege.java | 151 +--
.../commons/auth/entity/PriPrivilegeType.java | 153 ---
.../commons/auth/entity/PrivilegeModelType.java | 10 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 90 +-
.../iotdb/commons/auth/entity/PrivilegeUnion.java | 151 +++
.../org/apache/iotdb/commons/auth/entity/Role.java | 558 ++++++++--
.../iotdb/commons/auth/entity/TablePrivilege.java | 166 +++
.../org/apache/iotdb/commons/auth/entity/User.java | 81 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 267 ++---
.../iotdb/commons/auth/role/IEntityManager.java | 77 ++
.../iotdb/commons/auth/role/IRoleAccessor.java | 70 --
.../iotdb/commons/auth/role/IRoleManager.java | 109 --
.../commons/auth/role/LocalFileRoleAccessor.java | 288 ++---
.../commons/auth/role/LocalFileRoleManager.java | 6 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 260 +----
.../iotdb/commons/auth/user/IUserManager.java | 162 ---
.../commons/auth/user/LocalFileUserAccessor.java | 414 ++-----
.../commons/auth/user/LocalFileUserManager.java | 8 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 12 +
.../iotdb/commons/conf/CommonDescriptor.java | 6 +
.../iotdb/commons/pipe/config/PipeConfig.java | 10 +
.../config/constant/PipeConnectorConstant.java | 5 +
.../pipe/connector/client/IoTDBClientManager.java | 6 +-
.../connector/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 8 +
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 7 +
.../schema/column/ColumnHeaderConstant.java | 5 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 299 +++---
.../org/apache/iotdb/commons/utils/IOUtils.java | 140 +--
.../apache/iotdb/commons/utils/SerializeUtils.java | 21 +
.../apache/iotdb/commons/utils/AuthUtilsTest.java | 72 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 124 +++
.../src/main/thrift/confignode.thrift | 59 +-
266 files changed, 18982 insertions(+), 7326 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBClusterAuthorityRelationalIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBRelationalAuthIT.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/Constants.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/OptionsUtil.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AbstractExportData.java
copy
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{tsfile/ImportTsFileBase.java
=> data/AbstractImportData.java} (55%)
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AsyncImportData.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ExportDataTable.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ExportDataTree.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataTable.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataTree.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTask.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/IService.java
(78%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/auth/AuthorReadPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/AuthorRelationalPlan.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/{AuthorPlan.java
=> AuthorTreePlan.java} (54%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/WindowFunction.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/aggregate/AggregationWindowFunction.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/{source/relational/aggregation/TableAggregator.java
=> process/window/function/aggregate/WindowAggregator.java} (53%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/CumeDistFunction.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/DenseRankFunction.java} (63%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityLinearFill.java
=> window/function/rank/NTileFunction.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityLinearFill.java
=> window/function/rank/PercentRankFunction.java} (54%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/RankFunction.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/RankWindowFunction.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/RowNumberFunction.java} (66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/FirstValueFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LagFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LastValueFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LeadFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/NthValueFunction.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityLinearFill.java
=> window/function/value/ValueWindowFunction.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/Partition.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/PartitionExecutor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{ProcessOperator.java
=> window/partition/frame/Frame.java} (78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/FrameInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/GroupsFrame.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RangeFrame.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RowsFrame.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/utils/ColumnList.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{ProcessOperator.java
=> window/utils/Range.java} (76%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/utils/RowComparator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{template/DropSchemaTemplateTask.java
=> relational/RelationalAuthorizerTask.java} (67%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/ITableAuthCheckerImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RelationalAuthorStatement.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/type/{TypeManager.java
=> AuthorRType.java} (61%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/DataBasePrivilegeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/TablePrivilegeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/FunctionTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/aggregate/AggregationWindowFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/CumeDistFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/DenseRankFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/NTileFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/PercentRankFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/RankFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/RowNumberFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/FirstValueFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LagFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LastValueFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LeadFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/NthValueFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/FrameTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/GroupsFrameTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RangeFrameTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RowsFrameTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/AuthorStatementTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/DatabasePrivilege.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/{user/IUserAccessor.java
=> entity/IEntityAccessor.java} (60%)
copy iotdb-client/cli/src/main/java/org/apache/iotdb/cli/type/ExitType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/ModelType.java
(89%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PriPrivilegeType.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionRegressionConsumer.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PrivilegeModelType.java
(86%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PrivilegeUnion.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/TablePrivilege.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/IEntityManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/IRoleAccessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/IRoleManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/user/IUserManager.java
