Package org.apache.hadoop.hbase.util

Class MultiHConnection

java.lang.Object

org.apache.hadoop.hbase.util.MultiHConnection

@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	Description
private ExecutorService	batchPool
private Connection[]	connections
private final Object	connectionsLock
private static final org.slf4j.Logger	LOG
private final int	noOfConnections

Constructor Summary

Constructors

Constructor	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	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 Details

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 Details

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 Details

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)