Skip to content

Use long primitive types for refreshMeta and refreshHfiles procedures #8130

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
sharmaar12 wants to merge 1 commit into
base: HBASE-29081
Choose a base branch
from
Open

Use long primitive types for refreshMeta and refreshHfiles procedures #8130

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2706,30 +2706,30 @@ List<LogEntry> getLogEntries(Set<ServerName> serverNames, String logType, Server
/**
* Perform hbase:meta table refresh
*/
Long refreshMeta() throws IOException;
long refreshMeta() throws IOException;

/**
* Refresh HFiles for the table
* @param tableName table to refresh HFiles for
* @return ID of the procedure started for refreshing HFiles
* @throws IOException if a remote or network exception occurs
*/
Long refreshHFiles(final TableName tableName) throws IOException;
long refreshHFiles(final TableName tableName) throws IOException;

/**
* Refresh HFiles for all the tables under given namespace
* @param namespace Namespace for which we should call refresh HFiles for all tables under it
* @return ID of the procedure started for refreshing HFiles
* @throws IOException if a remote or network exception occurs
*/
Long refreshHFiles(final String namespace) throws IOException;
long refreshHFiles(final String namespace) throws IOException;

/**
* Refresh HFiles for all the tables
* @return ID of the procedure started for refreshing HFiles
* @throws IOException if a remote or network exception occurs
*/
Long refreshHFiles() throws IOException;
long refreshHFiles() throws IOException;

@InterfaceAudience.Private
void restoreBackupSystemTable(String snapshotName) throws IOException;
Expand Down
8 changes: 4 additions & 4 deletions hbase-client/src/main/java/org/apache/hadoop/hbase/client/AdminOverAsyncAdmin.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1154,22 +1154,22 @@ public List<String> getCachedFilesList(ServerName serverName) throws IOException
}

@Override
public Long refreshMeta() throws IOException {
public long refreshMeta() throws IOException {
return get(admin.refreshMeta());
}

@Override
public Long refreshHFiles(final TableName tableName) throws IOException {
public long refreshHFiles(final TableName tableName) throws IOException {
return get(admin.refreshHFiles(tableName));
}

@Override
public Long refreshHFiles(final String namespace) throws IOException {
public long refreshHFiles(final String namespace) throws IOException {
return get(admin.refreshHFiles(namespace));
}

@Override
public Long refreshHFiles() throws IOException {
public long refreshHFiles() throws IOException {
return get(admin.refreshHFiles());
}

Expand Down
8 changes: 4 additions & 4 deletions hbase-server/src/test/java/org/apache/hadoop/hbase/rsgroup/VerifyingRSGroupAdmin.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1012,22 +1012,22 @@ public boolean isReplicationPeerModificationEnabled() throws IOException {
}

@Override
public Long refreshMeta() throws IOException {
public long refreshMeta() throws IOException {
return admin.refreshMeta();
}

@Override
public Long refreshHFiles(final TableName tableName) throws IOException {
public long refreshHFiles(final TableName tableName) throws IOException {
return admin.refreshHFiles(tableName);
}

@Override
public Long refreshHFiles(final String namespace) throws IOException {
public long refreshHFiles(final String namespace) throws IOException {
return admin.refreshHFiles(namespace);
}

@Override
public Long refreshHFiles() throws IOException {
public long refreshHFiles() throws IOException {
return admin.refreshHFiles();
}
}
8 changes: 4 additions & 4 deletions hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/client/ThriftAdmin.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1375,7 +1375,7 @@ public void restoreBackupSystemTable(String snapshotName) throws IOException {
}

@Override
public Long refreshMeta() throws IOException {
public long refreshMeta() throws IOException {
throw new NotImplementedException("refreshMeta not supported in ThriftAdmin");
}

Expand All @@ -1393,17 +1393,17 @@ public boolean isReplicationPeerModificationEnabled() throws IOException {
}

@Override
public Long refreshHFiles(final TableName tableName) throws IOException {
public long refreshHFiles(final TableName tableName) throws IOException {
throw new NotImplementedException("refreshHFiles not supported in ThriftAdmin");
}

@Override
public Long refreshHFiles(final String namespace) throws IOException {
public long refreshHFiles(final String namespace) throws IOException {
throw new NotImplementedException("refreshHFiles not supported in ThriftAdmin");
}

@Override
public Long refreshHFiles() throws IOException {
public long refreshHFiles() throws IOException {
throw new NotImplementedException("refreshHFiles not supported in ThriftAdmin");
}
}
Loading