Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• hConnections

  private HConnection[] hConnections

• hConnectionsLock

  private final Object hConnectionsLock

• noOfConnections

  private int noOfConnections

• batchPool

  private ExecutorService batchPool

Constructor Detail

• MultiHConnection

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

  Create multiple HConnection instances and initialize a thread pool executor

  Parameters:

  conf - configuration

  noOfConnections - total no of HConnections to create

  Throws:

  IOException

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 -

  Throws:

  IOException

• createBatchPool

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