com.atlantbh.jmeter.plugins.hbasecrud

Class HbaseCrudHelper

java.lang.Object

com.atlantbh.jmeter.plugins.hbasecrud.HbaseCrudHelper

public class HbaseCrudHelper
extends Object

This class exposes functionalities for hbase record crud operations. Those functionalities are: 1. addOrUpdateDataToHBase (by latest timestamp or with filter for excluded column families for timestamp evaluation) 2. deleteDataFromHbase (by latest timestamp or with filter for excluded column families for timestamp evaluation)

Field Summary

Fields

Modifier and Type	Field and Description
protected ArrayList<String>	fullColumnNamesList
protected org.apache.hadoop.hbase.client.HTableInterface	hTable

Constructor Summary

Constructors

Constructor and Description
HbaseCrudHelper()

Method Summary

Modifier and Type	Method and Description
void	addOrUpdateDataToHBase(String rowKey, String columnFamilyColumnQualifiers)
void	deleteDataFromHbase(String rowKey, String columnFamilyColumnQualifiers)
String	getResponseMessage()
void	parseColumnFamilies(String columnFamilies)
void	setConfiguration(String hbaseZK, String hbaseTable)
void	setResponseMessage(String responseMessage)

Methods inherited from class java.lang.Object

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

Field Detail

hTable

protected org.apache.hadoop.hbase.client.HTableInterface hTable

fullColumnNamesList

protected ArrayList<String> fullColumnNamesList

Constructor Detail

HbaseCrudHelper

public HbaseCrudHelper()

Method Detail

getResponseMessage

public String getResponseMessage()

setResponseMessage

public void setResponseMessage(String responseMessage)

setConfiguration

public void setConfiguration(String hbaseZK,
                             String hbaseTable)
                      throws IOException

Throws:

IOException

parseColumnFamilies

public void parseColumnFamilies(String columnFamilies)

addOrUpdateDataToHBase

public void addOrUpdateDataToHBase(String rowKey,
                                   String columnFamilyColumnQualifiers)
                            throws IOException

Throws:

IOException

deleteDataFromHbase

public void deleteDataFromHbase(String rowKey,
                                String columnFamilyColumnQualifiers)
                         throws IOException

Throws:

IOException