From 64a6ba364710418d1ace5b143457ed87c104e939 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 d755926a697..f790f5a4e2f 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 @@ -177,7 +177,10 @@ 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 @@ -185,7 +188,10 @@ public interface BufferedMutator extends Closeable { * {@link BufferedMutatorParams}. */ @Deprecated - 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 @@ -193,7 +199,10 @@ public interface BufferedMutator extends Closeable { * {@link BufferedMutatorParams}. */ @Deprecated - 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}.