Toggle navigation
Home
java.lang.String to com.facebook.presto.spi.security.PrestoPrincipal
No. of Instances - 61
No. of Commits - 3
No. of Projects - {'presto'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Rename Variable
user
to
principal
user
to
principal
user
to
principal
user
to
principal
user
to
principal
Add or Remove Method invocation
stats.getGrantTablePrivileges().wrap(() -> { try (HiveMetastoreClient metastoreClient=clientProvider.createMetastoreClient()){ HivePrincipal hivePrincipal=toHivePrincipal(grantee); Set<HivePrivilegeInfo> existingPrivileges=listTablePrivileges(databaseName,tableName,new PrestoPrincipal(USER,grantee)); Set<PrivilegeGrantInfo> privilegesToGrant=new HashSet<>(requestedPrivileges); Iterator<PrivilegeGrantInfo> iterator=privilegesToGrant.iterator(); while (iterator.hasNext()) { HivePrivilegeInfo requestedPrivilege=getOnlyElement(parsePrivilege(iterator.next())); for ( HivePrivilegeInfo existingPrivilege : existingPrivileges) { if ((requestedPrivilege.isContainedIn(existingPrivilege))) { iterator.remove(); } else if (existingPrivilege.isContainedIn(requestedPrivilege)) { throw new PrestoException(NOT_SUPPORTED,format("Granting %s WITH GRANT OPTION is not supported while %s possesses %s",requestedPrivilege.getHivePrivilege().name(),grantee,requestedPrivilege.getHivePrivilege().name())); } } } if (privilegesToGrant.isEmpty()) { return null; } metastoreClient.grantPrivileges(buildPrivilegeBag(databaseName,tableName,hivePrincipal,privilegesToGrant)); } return null; } )
to
stats.getGrantTablePrivileges().wrap(() -> { try (HiveMetastoreClient metastoreClient=clientProvider.createMetastoreClient()){ Set<HivePrivilegeInfo> existingPrivileges=listTablePrivileges(databaseName,tableName,grantee); Set<PrivilegeGrantInfo> privilegesToGrant=new HashSet<>(requestedPrivileges); Iterator<PrivilegeGrantInfo> iterator=privilegesToGrant.iterator(); while (iterator.hasNext()) { HivePrivilegeInfo requestedPrivilege=getOnlyElement(parsePrivilege(iterator.next())); for ( HivePrivilegeInfo existingPrivilege : existingPrivileges) { if ((requestedPrivilege.isContainedIn(existingPrivilege))) { iterator.remove(); } else if (existingPrivilege.isContainedIn(requestedPrivilege)) { throw new PrestoException(NOT_SUPPORTED,format("Granting %s WITH GRANT OPTION is not supported while %s possesses %s",requestedPrivilege.getHivePrivilege().name(),grantee,requestedPrivilege.getHivePrivilege().name())); } } } if (privilegesToGrant.isEmpty()) { return null; } metastoreClient.grantPrivileges(buildPrivilegeBag(databaseName,tableName,grantee,privilegesToGrant)); } return null; } )
stats.getRevokeTablePrivileges().wrap(() -> { try (HiveMetastoreClient metastoreClient=clientProvider.createMetastoreClient()){ HivePrincipal hivePrincipal=toHivePrincipal(grantee); Set<HivePrivilege> existingHivePrivileges=listTablePrivileges(databaseName,tableName,new PrestoPrincipal(USER,grantee)).stream().map(HivePrivilegeInfo::getHivePrivilege).collect(toSet()); Set<PrivilegeGrantInfo> privilegesToRevoke=requestedPrivileges.stream().filter(privilegeGrantInfo -> existingHivePrivileges.contains(getOnlyElement(parsePrivilege(privilegeGrantInfo)).getHivePrivilege())).collect(toSet()); if (privilegesToRevoke.isEmpty()) { return null; } metastoreClient.revokePrivileges(buildPrivilegeBag(databaseName,tableName,hivePrincipal,privilegesToRevoke)); } return null; } )
to
stats.getRevokeTablePrivileges().wrap(() -> { try (HiveMetastoreClient metastoreClient=clientProvider.createMetastoreClient()){ Set<HivePrivilege> existingHivePrivileges=listTablePrivileges(databaseName,tableName,grantee).stream().map(HivePrivilegeInfo::getHivePrivilege).collect(toSet()); Set<PrivilegeGrantInfo> privilegesToRevoke=requestedPrivileges.stream().filter(privilegeGrantInfo -> existingHivePrivileges.contains(getOnlyElement(parsePrivilege(privilegeGrantInfo)).getHivePrivilege())).collect(toSet()); if (privilegesToRevoke.isEmpty()) { return null; } metastoreClient.revokePrivileges(buildPrivilegeBag(databaseName,tableName,grantee,privilegesToRevoke)); } return null; } )
getPrestoPrincipal(grantee)
to
grantee
getPrestoPrincipal(grantee)
to
grantee
Other
new PrestoPrincipal(USER,grantee)
to
grantee
Update Class Instacne Creation
new UserTableKey(new PrestoPrincipal(USER,grantee),databaseName,tableName)
to
new UserTableKey(grantee,databaseName,tableName)
new UserTableKey(new PrestoPrincipal(USER,grantee),databaseName,tableName)
to
new UserTableKey(grantee,databaseName,tableName)