Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
HBase >> mail # user >> Unable to add co-processor to table through HBase api


Copy link to this message
-
Unable to add co-processor to table through HBase api
Hi All,

I would like to add a RegionObserver to a HBase table through HBase api. I
don't want to put this RegionObserver as a user or system co-processor in
hbase-site.xml since this is specific to a table. So, option of using hbase
properties is out. I have already copied the jar file in the classpath of
region server and restarted the cluster.

Can any one point out the problem in following code for adding the
co-processor to the table:
    private void modifyTable(String name) throws IOException
    {
    Configuration conf = HBaseConfiguration.create();
    HBaseAdmin hAdmin = new HBaseAdmin(conf);
    hAdmin.disableTable("txn_subset");
    if(!hAdmin.isTableEnabled("txn_subset"))
    {
      System.err.println("Trying to add coproc to table"); // using err so
that it's easy to read this on eclipse console.

hAdmin.getTableDescriptor(Bytes.toBytes("txn_subset")).addCoprocessor("com.intuit.hbase.poc.coprocessor.observer.IhubTxnRegionObserver");
      if(
hAdmin.getTableDescriptor(Bytes.toBytes("txn_subset")).hasCoprocessor("com.intuit.hbase.poc.coprocessor.observer.IhubTxnRegionObserver")
)
      {
        System.err.println("YIPPPPPPPPPIEEEEE!!!!!!!");
      }
      hAdmin.enableTable("ihub_txn_subset");
    }
    hAdmin.close();
        }*
*
--
Thanks & Regards,
Anil Gupta
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB