Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HubSpot Backport: HBASE-26990 Add default implementation for BufferedMutator interface setters

This commit is contained in:
Bryan Beaudreault 2022-04-29 09:07:35 -04:00
parent e827cfbbb6
commit 129f8f904b
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-client/src/main/java/org/apache/hadoop/hbase/client/BufferedMutator.java
View File

@ -175,17 +175,23 @@ public interface BufferedMutator extends Closeable {
* The default value comes from the configuration parameter {@code hbase.client.write.buffer}. * The default value comes from the configuration parameter {@code hbase.client.write.buffer}.
* @return The size of the write buffer in bytes. * @return The size of the write buffer in bytes.
*/ */
long getWriteBufferSize(); default long getWriteBufferSize() {
throw new UnsupportedOperationException("The BufferedMutator::getWriteBufferSize has not been implemented");
}
/** /**
* Set rpc timeout for this mutator instance * Set rpc timeout for this mutator instance
*/ */
void setRpcTimeout(int timeout); default void setRpcTimeout(int timeout) {
throw new UnsupportedOperationException("The BufferedMutator::setRpcTimeout has not been implemented");
}
/** /**
* Set operation timeout for this mutator instance * Set operation timeout for this mutator instance
*/ */
void setOperationTimeout(int timeout); default void setOperationTimeout(int timeout) {
throw new UnsupportedOperationException("The BufferedMutator::setOperationTimeout has not been implemented");
}
/** /**
* Listens for asynchronous exceptions on a {@link BufferedMutator}. * Listens for asynchronous exceptions on a {@link BufferedMutator}.