Skip to content

Commit

Permalink
checkstyle fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
szucsvillo committed Dec 10, 2024
1 parent 059a647 commit 3b54675
Show file tree
Hide file tree
Showing 2 changed files with 20 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2183,7 +2183,8 @@ private MetaDataMutationResult metaDataCoprocessorExec(String tableName, byte[]
long startTime = EnvironmentEdgeManager.currentTimeMillis();
while (true) {
if (retried) {
connection.getRegionLocator(SchemaUtil.getPhysicalName(systemTableName, this.getProps()))
connection.getRegionLocator(SchemaUtil.getPhysicalName(
systemTableName, this.getProps()))
.getRegionLocation(tableKey, true);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6524,15 +6524,20 @@ public MutationState changePermissions(ChangePermsStatement changePermsStatement
return new MutationState(0, 0, connection);
}

private void changePermsOnSchema(org.apache.hadoop.hbase.client.Connection hConnection, ChangePermsStatement changePermsStatement) throws Throwable {
private void changePermsOnSchema(org.apache.hadoop.hbase.client.Connection hConnection,
ChangePermsStatement changePermsStatement) throws Throwable {
if (changePermsStatement.isGrantStatement()) {
AccessControlClient.grant(hConnection, changePermsStatement.getSchemaName(), changePermsStatement.getName(), changePermsStatement.getPermsList());
AccessControlClient.grant(hConnection, changePermsStatement.getSchemaName(),
changePermsStatement.getName(), changePermsStatement.getPermsList());
} else {
AccessControlClient.revoke(hConnection, changePermsStatement.getSchemaName(), changePermsStatement.getName(), Permission.Action.values());
AccessControlClient.revoke(hConnection, changePermsStatement.getSchemaName(),
changePermsStatement.getName(), Permission.Action.values());
}
}

private void changePermsOnTables(org.apache.hadoop.hbase.client.Connection hConnection, Admin admin, ChangePermsStatement changePermsStatement, PTable inputTable) throws Throwable {
private void changePermsOnTables(org.apache.hadoop.hbase.client.Connection hConnection,
Admin admin, ChangePermsStatement changePermsStatement,
PTable inputTable) throws Throwable {

org.apache.hadoop.hbase.TableName tableName = SchemaUtil.getPhysicalTableName
(inputTable.getPhysicalName().getBytes(), inputTable.isNamespaceMapped());
Expand Down Expand Up @@ -6587,7 +6592,9 @@ private void changePermsOnTables(org.apache.hadoop.hbase.client.Connection hConn
}
}

private void changePermsOnTable(org.apache.hadoop.hbase.client.Connection hConnection, ChangePermsStatement changePermsStatement, org.apache.hadoop.hbase.TableName tableName)
private void changePermsOnTable(org.apache.hadoop.hbase.client.Connection hConnection,
ChangePermsStatement changePermsStatement,
org.apache.hadoop.hbase.TableName tableName)
throws Throwable {
if (changePermsStatement.isGrantStatement()) {
AccessControlClient.grant(hConnection, tableName, changePermsStatement.getName(),
Expand All @@ -6598,12 +6605,15 @@ private void changePermsOnTable(org.apache.hadoop.hbase.client.Connection hConne
}
}

private void changePermsOnUser(org.apache.hadoop.hbase.client.Connection hConnection, ChangePermsStatement changePermsStatement)
private void changePermsOnUser(org.apache.hadoop.hbase.client.Connection hConnection,
ChangePermsStatement changePermsStatement)
throws Throwable {
if (changePermsStatement.isGrantStatement()) {
AccessControlClient.grant(hConnection, changePermsStatement.getName(), changePermsStatement.getPermsList());
AccessControlClient.grant(hConnection, changePermsStatement.getName(),
changePermsStatement.getPermsList());
} else {
AccessControlClient.revoke(hConnection, changePermsStatement.getName(), Permission.Action.values());
AccessControlClient.revoke(hConnection, changePermsStatement.getName(),
Permission.Action.values());
}
}
}

0 comments on commit 3b54675

Please sign in to comment.