org.apache.hadoop.hbase.util

Class MultiHConnection

java.lang.Object

org.apache.hadoop.hbase.util.MultiHConnection

@InterfaceAudience.Private
public class MultiHConnection
extends Object

Provides ability to create multiple Connection instances and allows to process a batch of actions using CHTable.doBatchWithCallback()

Field Summary

Fields

Modifier and Type	Field and Description
private ExecutorService	batchPool
private Connection[]	connections
private Object	connectionsLock
private static org.slf4j.Logger	LOG
private int	noOfConnections

Constructor Summary

Constructors

Constructor and Description
MultiHConnection(org.apache.hadoop.conf.Configuration conf, int noOfConnections) Create multiple Connection instances and initialize a thread pool executor

Method Summary

Modifier and Type	Method and Description
void	close() Close the open connections and shutdown the batchpool
private void	createBatchPool(org.apache.hadoop.conf.Configuration conf)
<R> void	processBatchCallback(List<? extends Row> actions, TableName tableName, Object[] results, Batch.Callback<R> callback) Randomly pick a connection and process the batch of actions for a given table

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

connections

private Connection[] connections

connectionsLock

private final Object connectionsLock

noOfConnections

private final int noOfConnections

batchPool

private ExecutorService batchPool

Constructor Detail

MultiHConnection

public MultiHConnection(org.apache.hadoop.conf.Configuration conf,
                        int noOfConnections)
                 throws IOException

Create multiple Connection instances and initialize a thread pool executor

Parameters:

conf - configuration

noOfConnections - total no of Connections to create

Throws:

IOException - if IO failure occurs

Method Detail

close

public void close()

Close the open connections and shutdown the batchpool

processBatchCallback

public <R> void processBatchCallback(List<? extends Row> actions,
                                     TableName tableName,
                                     Object[] results,
                                     Batch.Callback<R> callback)
                              throws IOException

Randomly pick a connection and process the batch of actions for a given table

Parameters:

actions - the actions

tableName - table name

results - the results array

callback - to run when results are in

Throws:

IOException - If IO failure occurs

createBatchPool

private void createBatchPool(org.apache.hadoop.conf.Configuration conf)