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

HBASE-21792 Mark HTableMultiplexer as deprecated and remove it in 3.0.0 

Signed-off-by: Michael Stack <stack@apache.org>
This commit is contained in:
Duo Zhang 2019-01-28 18:21:51 +08:00 committed by zhangduo
parent f359d260d3
commit e736d78362
1 changed files with 19 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
hbase-client/src/main/java/org/apache/hadoop/hbase/client/HTableMultiplexer.java
View File

@ -50,19 +50,21 @@ import org.apache.hbase.thirdparty.com.google.common.annotations.VisibleForTesti
import org.apache.hbase.thirdparty.com.google.common.util.concurrent.ThreadFactoryBuilder; import org.apache.hbase.thirdparty.com.google.common.util.concurrent.ThreadFactoryBuilder;
/** /**
* HTableMultiplexer provides a thread-safe non blocking PUT API across all the tables. * HTableMultiplexer provides a thread-safe non blocking PUT API across all the tables. Each put
* Each put will be sharded into different buffer queues based on its destination region server. * will be sharded into different buffer queues based on its destination region server. So each
* So each region server buffer queue will only have the puts which share the same destination. * region server buffer queue will only have the puts which share the same destination. And each
* And each queue will have a flush worker thread to flush the puts request to the region server. * queue will have a flush worker thread to flush the puts request to the region server. If any
* If any queue is full, the HTableMultiplexer starts to drop the Put requests for that * queue is full, the HTableMultiplexer starts to drop the Put requests for that particular queue.
* particular queue. * </p>
* * Also all the puts will be retried as a configuration number before dropping. And the
* Also all the puts will be retried as a configuration number before dropping. * HTableMultiplexer can report the number of buffered requests and the number of the failed
* And the HTableMultiplexer can report the number of buffered requests and the number of the * (dropped) requests in total or on per region server basis.
* failed (dropped) requests in total or on per region server basis. * <p/>
*
* This class is thread safe. * This class is thread safe.
* @deprecated since 2.2.0, will be removed in 3.0.0, without replacement. Please use
* {@link BufferedMutator} for batching mutations.
*/ */
@Deprecated
@InterfaceAudience.Public @InterfaceAudience.Public
public class HTableMultiplexer { public class HTableMultiplexer {
private static final Logger LOG = LoggerFactory.getLogger(HTableMultiplexer.class.getName()); private static final Logger LOG = LoggerFactory.getLogger(HTableMultiplexer.class.getName());
@ -128,7 +130,6 @@ public class HTableMultiplexer {
* been closed. * been closed.
* @throws IOException If there is an error closing the connection. * @throws IOException If there is an error closing the connection.
*/ */
@SuppressWarnings("deprecation")
public synchronized void close() throws IOException { public synchronized void close() throws IOException {
if (!getConnection().isClosed()) { if (!getConnection().isClosed()) {
getConnection().close(); getConnection().close();
@ -262,10 +263,13 @@ public class HTableMultiplexer {
} }
/** /**
* HTableMultiplexerStatus keeps track of the current status of the HTableMultiplexer. * HTableMultiplexerStatus keeps track of the current status of the HTableMultiplexer. report the
* report the number of buffered requests and the number of the failed (dropped) requests * number of buffered requests and the number of the failed (dropped) requests in total or on per
* in total or on per region server basis. * region server basis.
* @deprecated since 2.2.0, will be removed in 3.0.0, without replacement. Please use
* {@link BufferedMutator} for batching mutations.
*/ */
@Deprecated
@InterfaceAudience.Public @InterfaceAudience.Public
public static class HTableMultiplexerStatus { public static class HTableMultiplexerStatus {
private long totalFailedPutCounter; private long totalFailedPutCounter;