This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b090698af2 [IOTDB-3088]Implement MTreeAboveSG serialize and
deserialize (#5781)
add 4e913d7219 [IOTDB-3085] move auth to node-commons module (#5790)
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/cluster/RemoteTsFileResource.java | 2 +-
.../cluster/client/sync/SyncClientAdaptor.java | 2 +-
.../iotdb/cluster/log/logtypes/CloseFileLog.java | 2 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 10 +-
.../serializable/SyncLogDequeSerializer.java | 2 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 12 +-
.../cluster/partition/slot/SlotPartitionTable.java | 2 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 2 +-
.../cluster/query/aggregate/ClusterAggregator.java | 2 +-
.../query/groupby/RemoteGroupByExecutor.java | 2 +-
.../query/last/ClusterLastQueryExecutor.java | 2 +-
.../cluster/query/reader/ClusterReaderFactory.java | 2 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 2 +-
.../reader/RemoteSeriesReaderByTimestamp.java | 2 +-
.../query/reader/RemoteSimpleSeriesReader.java | 2 +-
.../query/reader/mult/MultDataSourceInfo.java | 2 +-
.../query/reader/mult/RemoteMultSeriesReader.java | 2 +-
.../handlers/caller/PreviousFillHandler.java | 2 +-
.../serializable/SyncLogDequeSerializerTest.java | 2 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 8 +-
.../cluster/partition/SlotPartitionTableTest.java | 2 +-
.../reader/RemoteSeriesReaderByTimestampTest.java | 2 +-
.../query/reader/RemoteSimpleSeriesReaderTest.java | 2 +-
.../mult/AssignPathManagedMergeReaderTest.java | 2 +-
.../reader/mult/RemoteMultSeriesReaderTest.java | 2 +-
.../cluster/server/member/DataGroupMemberTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 10 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +
.../consensus/request/auth/AuthorReq.java | 2 +-
.../statemachine/PartitionRegionStateMachine.java | 2 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 16 +-
.../service/executor/ConfigRequestExecutor.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 2 +-
.../consensus/request/ConfigRequestSerDeTest.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 2 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 2 +-
node-commons/pom.xml | 25 +++
.../apache/iotdb/commons}/auth/AuthException.java | 3 +-
.../auth/authorizer/AuthorizerManager.java | 123 +-------------
.../commons}/auth/authorizer/BasicAuthorizer.java | 25 ++-
.../commons}/auth/authorizer/IAuthorizer.java | 8 +-
.../auth/authorizer/LocalFileAuthorizer.java | 19 +--
.../commons}/auth/authorizer/OpenIdAuthorizer.java | 28 ++--
.../iotdb/commons}/auth/entity/PathPrivilege.java | 5 +-
.../iotdb/commons}/auth/entity/PrivilegeType.java | 3 +-
.../apache/iotdb/commons}/auth/entity/Role.java | 6 +-
.../apache/iotdb/commons}/auth/entity/User.java | 6 +-
.../iotdb/commons}/auth/role/BasicRoleManager.java | 8 +-
.../iotdb/commons}/auth/role/IRoleAccessor.java | 4 +-
.../iotdb/commons}/auth/role/IRoleManager.java | 6 +-
.../commons}/auth/role/LocalFileRoleAccessor.java | 10 +-
.../commons}/auth/role/LocalFileRoleManager.java | 3 +-
.../iotdb/commons}/auth/user/BasicUserManager.java | 17 +-
.../iotdb/commons}/auth/user/IUserAccessor.java | 4 +-
.../iotdb/commons}/auth/user/IUserManager.java | 6 +-
.../commons}/auth/user/LocalFileUserAccessor.java | 10 +-
.../commons}/auth/user/LocalFileUserManager.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 138 +++++++++++++++
.../iotdb/commons/file}/SystemFileFactory.java | 6 +-
.../security/encrypt/AsymmetricEncrypt.java | 2 +-
.../security/encrypt/AsymmetricEncryptFactory.java | 2 +-
.../security/encrypt/EncryptDecryptException.java | 2 +-
.../security/encrypt/MessageDigestEncrypt.java | 2 +-
.../org/apache/iotdb/commons}/utils/AuthUtils.java | 20 +--
.../org/apache/iotdb/commons}/utils/IOUtils.java | 4 +-
.../iotdb/commons}/utils/SerializeUtils.java | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 2 +-
server/pom.xml | 25 ---
.../resources/conf/iotdb-engine.properties | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 103 +++++++++++-
.../db/auth/authorizer/ClusterAuthorizer.java | 185 ---------------------
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 76 ---------
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 42 +++--
.../iotdb/db/conf/adapter/CompressionRatio.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 2 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 2 +-
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 2 +-
.../iotdb/db/engine/cq/ContinuousQueryService.java | 2 +-
.../apache/iotdb/db/engine/settle/SettleLog.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 2 +-
.../storagegroup/timeindex/V012FileTimeIndex.java | 2 +-
.../engine/trigger/service/TriggerClassLoader.java | 2 +-
.../engine/trigger/service/TriggerLogWriter.java | 2 +-
.../service/TriggerRegistrationService.java | 2 +-
.../apache/iotdb/db/engine/upgrade/UpgradeLog.java | 2 +-
.../version/SimpleFileVersionController.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 2 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 2 +-
.../iotdb/db/metadata/logfile/MLogReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogTxtReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 2 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 2 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 2 +-
.../metadata/schemaregion/SchemaRegionUtils.java | 2 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +-
.../iotdb/db/metadata/template/Template.java | 2 +-
.../execution/config/AuthorizerConfigTask.java | 118 ++++++++++++-
.../db/protocol/influxdb/handler/QueryHandler.java | 2 +-
.../db/protocol/mqtt/BrokerAuthenticator.java | 6 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 2 +-
.../protocol/rest/filter/AuthorizationFilter.java | 6 +-
.../rest/handler/AuthorizationHandler.java | 2 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 23 +--
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 4 +-
.../apache/iotdb/db/qp/physical/sys/LogPlan.java | 2 +-
.../iotdb/db/query/control/SessionManager.java | 4 +-
.../query/udf/datastructure/SerializableList.java | 2 +-
.../udf/service/TemporaryQueryDataFileService.java | 2 +-
.../iotdb/db/query/udf/service/UDFClassLoader.java | 2 +-
.../query/udf/service/UDFClassLoaderManager.java | 2 +-
.../iotdb/db/query/udf/service/UDFLogWriter.java | 2 +-
.../query/udf/service/UDFRegistrationService.java | 2 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 64 +++++--
.../db/service/thrift/impl/TSServiceImpl.java | 6 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 2 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 2 +-
.../db/tools/schema/SchemaFileSketchTool.java | 2 +-
.../java/org/apache/iotdb/db/utils/FileUtils.java | 2 +-
.../apache/iotdb/db/utils/writelog/LogWriter.java | 2 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 2 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 2 +-
.../iotdb/db/wal/recover/WALRecoverManager.java | 2 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 9 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 12 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 8 +-
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 2 +
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 3 +
.../org/apache/iotdb/db/auth/entity/UserTest.java | 3 +
.../db/auth/role/LocalFileRoleAccessorTest.java | 5 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 7 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 5 +-
.../db/auth/user/LocalFileUserManagerTest.java | 13 +-
.../SizeTieredCompactionRecoverTest.java | 2 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 2 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 2 +-
.../db/qp/physical/PhysicalPlanSerializeTest.java | 2 +-
.../db/query/control/FileReaderManagerTest.java | 2 +-
.../security/encrypt/MessageDigestEncryptTest.java | 13 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 1 +
.../apache/iotdb/spark/db/EnvironmentUtils.java | 6 +-
150 files changed, 759 insertions(+), 731 deletions(-)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/AuthException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/authorizer/AuthorizerManager.java
(51%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/authorizer/BasicAuthorizer.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/authorizer/IAuthorizer.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/authorizer/LocalFileAuthorizer.java
(64%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/authorizer/OpenIdAuthorizer.java
(91%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/entity/PathPrivilege.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/entity/PrivilegeType.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/entity/Role.java (96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/entity/User.java (97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/role/BasicRoleManager.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/role/IRoleAccessor.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/role/IRoleManager.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/role/LocalFileRoleAccessor.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/role/LocalFileRoleManager.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/user/BasicUserManager.java
(94%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/user/IUserAccessor.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/user/IUserManager.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/user/LocalFileUserAccessor.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/auth/user/LocalFileUserManager.java
(91%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
rename {server/src/main/java/org/apache/iotdb/db/engine/fileSystem =>
node-commons/src/main/java/org/apache/iotdb/commons/file}/SystemFileFactory.java
(91%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/security/encrypt/AsymmetricEncrypt.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/security/encrypt/AsymmetricEncryptFactory.java
(98%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/security/encrypt/EncryptDecryptException.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/security/encrypt/MessageDigestEncrypt.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/utils/AuthUtils.java (93%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/utils/IOUtils.java (98%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/utils/SerializeUtils.java
(99%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/auth/authorizer/ClusterAuthorizer.java
