From 129f8f904b44c5f466b3c2bd27ed361e9af3acd3 Mon Sep 17 00:00:00 2001 From: Bryan Beaudreault Date: Fri, 29 Apr 2022 09:07:35 -0400 Subject: [PATCH] HubSpot Backport: HBASE-26990 Add default implementation for BufferedMutator interface setters --- .../apache/hadoop/hbase/client/BufferedMutator.java | 12 +++++++++--- 1 file changed, 9 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 7805f77e30e..b6f59ab0b1e 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 @@ -175,17 +175,23 @@ 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}.