Package org.apache.hadoop.hbase.client

Class HTableMultiplexer

java.lang.Object

org.apache.hadoop.hbase.client.HTableMultiplexer

@Deprecated
@Public
public class HTableMultiplexer
extends Object

Deprecated.

since 2.2.0, will be removed in 3.0.0, without replacement. Please use BufferedMutator for batching mutations.

HTableMultiplexer provides a thread-safe non blocking PUT API across all the tables. Each put will be sharded into different buffer queues based on its destination region server. So each region server buffer queue will only have the puts which share the same destination. And each queue will have a flush worker thread to flush the puts request to the region server. If any queue is full, the HTableMultiplexer starts to drop the Put requests for that particular queue.

Also all the puts will be retried as a configuration number before dropping. And the HTableMultiplexer can report the number of buffered requests and the number of the failed (dropped) requests in total or on per region server basis.

This class is thread safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	HTableMultiplexer.AtomicAverageCounter	Deprecated. Helper to count the average over an interval until reset.
(package private) static class	HTableMultiplexer.FlushWorker	Deprecated.
static class	HTableMultiplexer.HTableMultiplexerStatus	Deprecated. since 2.2.0, will be removed in 3.0.0, without replacement.
(package private) static class	HTableMultiplexer.PutStatus	Deprecated.

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hadoop.conf.Configuration	conf	Deprecated.
private final ClusterConnection	conn	Deprecated.
private final ScheduledExecutorService	executor	Deprecated.
private final long	flushPeriod	Deprecated.
private static final org.slf4j.Logger	LOG	Deprecated.
private final int	maxAttempts	Deprecated.
private final int	maxKeyValueSize	Deprecated.
private final int	perRegionServerBufferQueueSize	Deprecated.
private final ExecutorService	pool	Deprecated.
private final Map<HRegionLocation,HTableMultiplexer.FlushWorker>	serverToFlushWorkerMap	Deprecated. The map between each region server to its flush worker
static final String	TABLE_MULTIPLEXER_FLUSH_PERIOD_MS	Deprecated.
static final String	TABLE_MULTIPLEXER_INIT_THREADS	Deprecated.
static final String	TABLE_MULTIPLEXER_MAX_RETRIES_IN_QUEUE	Deprecated.

Constructor Summary

Constructors

Constructor	Description
HTableMultiplexer(org.apache.hadoop.conf.Configuration conf, int perRegionServerBufferQueueSize)	Deprecated.
HTableMultiplexer(Connection conn, org.apache.hadoop.conf.Configuration conf, int perRegionServerBufferQueueSize)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	close()	Deprecated. Closes the internal Connection.
(package private) ClusterConnection	getConnection()	Deprecated.
HTableMultiplexer.HTableMultiplexerStatus	getHTableMultiplexerStatus()	Deprecated. Returns the current HTableMultiplexerStatus
(package private) LinkedBlockingQueue<HTableMultiplexer.PutStatus>	getQueue(HRegionLocation addr)	Deprecated.
List<Put>	put(byte[] tableName, List<Put> puts)	Deprecated. Use put(TableName, List) instead.
boolean	put(byte[] tableName, Put put)	Deprecated. Use put(TableName, Put) instead.
boolean	put(byte[] tableName, Put put, int retry)	Deprecated. Use put(TableName, Put) instead.
List<Put>	put(TableName tableName, List<Put> puts)	Deprecated. The puts request will be buffered by their corresponding buffer queue.
boolean	put(TableName tableName, Put put)	Deprecated. The put request will be buffered by its corresponding buffer queue.
boolean	put(TableName tableName, Put put, int maxAttempts)	Deprecated. The put request will be buffered by its corresponding buffer queue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

Deprecated.

TABLE_MULTIPLEXER_FLUSH_PERIOD_MS

public static final String TABLE_MULTIPLEXER_FLUSH_PERIOD_MS

Deprecated.

See Also:

• Constant Field Values

TABLE_MULTIPLEXER_INIT_THREADS

public static final String TABLE_MULTIPLEXER_INIT_THREADS

Deprecated.

See Also:

• Constant Field Values

TABLE_MULTIPLEXER_MAX_RETRIES_IN_QUEUE

public static final String TABLE_MULTIPLEXER_MAX_RETRIES_IN_QUEUE

Deprecated.

See Also:

• Constant Field Values

serverToFlushWorkerMap

private final Map<HRegionLocation,HTableMultiplexer.FlushWorker> serverToFlushWorkerMap

Deprecated.

The map between each region server to its flush worker

conf

private final org.apache.hadoop.conf.Configuration conf

Deprecated.

conn

private final ClusterConnection conn

Deprecated.

pool

private final ExecutorService pool

Deprecated.

maxAttempts

private final int maxAttempts

Deprecated.

perRegionServerBufferQueueSize

private final int perRegionServerBufferQueueSize

Deprecated.

maxKeyValueSize

private final int maxKeyValueSize

Deprecated.

executor

private final ScheduledExecutorService executor

Deprecated.

flushPeriod

private final long flushPeriod

Deprecated.

Constructor Details

HTableMultiplexer

public HTableMultiplexer(org.apache.hadoop.conf.Configuration conf,
 int perRegionServerBufferQueueSize)
                  throws IOException

Deprecated.

Parameters:

conf - The HBaseConfiguration

perRegionServerBufferQueueSize - determines the max number of the buffered Put ops for each region server before dropping the request.

Throws:

IOException

HTableMultiplexer

public HTableMultiplexer(Connection conn,
 org.apache.hadoop.conf.Configuration conf,
 int perRegionServerBufferQueueSize)

Deprecated.

Parameters:

conn - The HBase connection.

conf - The HBase configuration

perRegionServerBufferQueueSize - determines the max number of the buffered Put ops for each region server before dropping the request.

Method Details

close

public void close()
           throws IOException

Deprecated.

Closes the internal Connection. Does nothing if the Connection has already been closed.

Throws:

IOException - If there is an error closing the connection.

put

public boolean put(TableName tableName,
 Put put)

Deprecated.

The put request will be buffered by its corresponding buffer queue. Return false if the queue is already full.

Returns:

true if the request can be accepted by its corresponding buffer queue.

put

public List<Put> put(TableName tableName,
 List<Put> puts)

Deprecated.

The puts request will be buffered by their corresponding buffer queue. Return the list of puts which could not be queued.

Returns:

the list of puts which could not be queued

put

@Deprecated
public List<Put> put(byte[] tableName,
 List<Put> puts)

Deprecated.

Use put(TableName, List) instead.

put

public boolean put(TableName tableName,
 Put put,
 int maxAttempts)

Deprecated.

The put request will be buffered by its corresponding buffer queue. And the put request will be retried before dropping the request. Return false if the queue is already full.

Returns:

true if the request can be accepted by its corresponding buffer queue.

put

@Deprecated
public boolean put(byte[] tableName,
 Put put,
 int retry)

Deprecated.

Use put(TableName, Put) instead.

put

@Deprecated
public boolean put(byte[] tableName,
 Put put)

Deprecated.

Use put(TableName, Put) instead.

getHTableMultiplexerStatus

public HTableMultiplexer.HTableMultiplexerStatus getHTableMultiplexerStatus()

Deprecated.

Returns the current HTableMultiplexerStatus

getQueue

@Private
LinkedBlockingQueue<HTableMultiplexer.PutStatus> getQueue(HRegionLocation addr)

Deprecated.

getConnection

@Private
ClusterConnection getConnection()

Deprecated.