HBASE-26990 Add default implementation for BufferedMutator interface setters (#4387)
Signed-off-by: Josh Elser <elserj@apache.org>
This commit is contained in:
parent
3a1536169e
commit
341ce509fe
|
@ -173,17 +173,26 @@ public interface BufferedMutator extends Closeable {
|
|||
* The default value comes from the configuration parameter {@code hbase.client.write.buffer}.
|
||||
* @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
|
||||
*/
|
||||
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
|
||||
*/
|
||||
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}.
|
||||
|
|
Loading…
Reference in New Issue