package org.archive.io.hbase;
   
   import java.io.IOException;
   import java.util.concurrent.atomic.AtomicInteger;
   
   import org.archive.io.WriterPool;
   import org.archive.io.WriterPoolMember;
   import org.archive.io.WriterPoolSettings;
   
  // TODO: Auto-generated Javadoc
  /**
   * The Class HBaseWriterPool.
   */
  public class HBaseWriterPool extends WriterPool {
  
  	/** The _parameters. */
  	private HBaseParameters _parameters;
  
  	/**
  	 * Instantiates a new h base writer pool.
  	 *
  	 * @param serial the serial
  	 * @param settings the settings
  	 * @param poolMaximumActive the pool maximum active
  	 * @param poolMaximumWait the pool maximum wait
  	 * @param parameters the parameters
  	 */
  	public HBaseWriterPool(AtomicInteger serial, WriterPoolSettings settings, int poolMaximumActive, int poolMaximumWait, HBaseParameters parameters) {
  
  		super(serial, settings, poolMaximumActive, poolMaximumWait);
  
  		_parameters = parameters;
  	}
  
  	/* (non-Javadoc)
  	 * @see org.archive.io.WriterPool#makeWriter()
  	 */
  	@Override
  	protected WriterPoolMember makeWriter() {
  		try {
  			return new HBaseWriter(getSerialNo(), getSettings(), _parameters);
  		} catch (IOException e) {
  			throw new RuntimeException("Couldn't create a " + HBaseWriter.class.getName() + " writer object");
  		}
  	}
  
  }