org.apache.storm.hbase.common
Class HBaseClient

java.lang.Object
  extended by org.apache.storm.hbase.common.HBaseClient

public class HBaseClient
extends Object


Constructor Summary
HBaseClient(Map<String,Object> map, org.apache.hadoop.conf.Configuration configuration, String tableName)
           
 
Method Summary
 org.apache.hadoop.hbase.client.Result[] batchGet(List<org.apache.hadoop.hbase.client.Get> gets)
           
 void batchMutate(List<org.apache.hadoop.hbase.client.Mutation> mutations)
           
 org.apache.hadoop.hbase.client.Get constructGetRequests(byte[] rowKey, HBaseProjectionCriteria projectionCriteria)
           
 List<org.apache.hadoop.hbase.client.Mutation> constructMutationReq(byte[] rowKey, ColumnList cols, org.apache.hadoop.hbase.client.Durability durability)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HBaseClient

public HBaseClient(Map<String,Object> map,
                   org.apache.hadoop.conf.Configuration configuration,
                   String tableName)
Method Detail

constructMutationReq

public List<org.apache.hadoop.hbase.client.Mutation> constructMutationReq(byte[] rowKey,
                                                                          ColumnList cols,
                                                                          org.apache.hadoop.hbase.client.Durability durability)

batchMutate

public void batchMutate(List<org.apache.hadoop.hbase.client.Mutation> mutations)
                 throws Exception
Throws:
Exception

constructGetRequests

public org.apache.hadoop.hbase.client.Get constructGetRequests(byte[] rowKey,
                                                               HBaseProjectionCriteria projectionCriteria)

batchGet

public org.apache.hadoop.hbase.client.Result[] batchGet(List<org.apache.hadoop.hbase.client.Get> gets)
                                                 throws Exception
Throws:
Exception


Copyright © 2014 The Apache Software Foundation. All Rights Reserved.