From 341ce509febf3ceb53f62fc01ef9a11f65642f4f Mon Sep 17 00:00:00 2001 From: Bryan Beaudreault Date: Tue, 3 May 2022 14:57:49 -0400 Subject: [PATCH] HBASE-26990 Add default implementation for BufferedMutator interface setters (#4387) Signed-off-by: Josh Elser --- .../hadoop/hbase/client/BufferedMutator.java | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BufferedMutator.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BufferedMutator.java index 2cba44baf9d..7c95643ecc9 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BufferedMutator.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BufferedMutator.java @@ -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}.