com.powerset.heritrix.writer
Class HBaseWriterPool

java.lang.Object
  org.archive.io.WriterPool
      com.powerset.heritrix.writer.HBaseWriterPool

public class HBaseWriterPool
extends org.archive.io.WriterPool

A pool of HBaseWriters.

Field Summary

Fields inherited from class org.archive.io.WriterPool

DEFAULT_MAX_ACTIVE, DEFAULT_MAXIMUM_WAIT, NO_MAX_IDLE

Constructor Summary

HBaseWriterPool(String zkQuorum, int zkClientPort, String table, int poolMaximumActive, int poolMaximumWait)
Constructor.

Method Summary

Methods inherited from class org.archive.io.WriterPool

borrowFile, close, getNumActive, getNumIdle, getPoolState, getPoolState, getSerialNo, getSettings, invalidateFile, returnFile

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseWriterPool

public HBaseWriterPool(String zkQuorum,
                       int zkClientPort,
                       String table,
                       int poolMaximumActive,
                       int poolMaximumWait)

Constructor.

Parameters:

zkQuorum - the list of zookeeper quorum servers that serve HBase, comma seperated. i.e.: zkHost1,zkHost2,zkHost3

zkClientPort - the port that clients should connect to on the given zk quorum servers. i.e.: 2181

table - the table name in HBase

poolMaximumActive - the maximum number of writers in the writer pool.

poolMaximumWait - the maximum waittime for all writers in the pool.