com.github.hackerwin7.jlib.utils.drivers.hbase.client

Class HBaseClient

java.lang.Object

com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

public class HBaseClient
extends Object

Created by IntelliJ IDEA. User: hackerwin7 Date: 2015/12/22 Time: 4:34 PM Desc: hbase client for hbase-client 1.1.2

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HBaseClient.FlushTask
static interface	HBaseClient.NextRowkeyHandler

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_SCAN_CACHING
static int	LOOKAHEAD_SCAN_SEEK
static long	TIMER_DELAY_SCHEDULE
static long	TIMER_PERIOD_SCHEDULE

Constructor Summary

Constructors

Constructor and Description
HBaseClient(HBaseConf hconf) init hbase conn and admin and table

Method Summary

Modifier and Type	Method and Description
void	addFamily(String tbName, String[] families) add family columng
void	close() close the connection
void	createNamespace(String namespace) create namespace
void	createTable(String tbName) create htable
void	createTable(String tbName, String[] families) create the hbase table with hbase descriptor
void	delete(String tbName, byte[] rowkey) delete by rowkey
void	delete(String tbName, List<byte[]> rows)
void	deleteAsync(String tbName, List<byte[]> rows)
void	deleteAsyncHData(String tbName, List<HData> datas)
void	deleteAsyncOrigin(String tbName, List<org.apache.hadoop.hbase.client.Delete> deletes) original delete async
void	deleteFamily(String tbName, String family) delete family column
void	deleteHData(String tbName, HData data) delete hdata
void	deleteHData(String tbName, List<HData> datas)
void	deleteNamespace(String namespace) delete namespace
void	deleteOrigin(String tbName, org.apache.hadoop.hbase.client.Delete delete) delete the delte
void	deleteOrigin(String tbName, List<org.apache.hadoop.hbase.client.Delete> deletes)
void	deleteTable(String tbName) delete htable
boolean	existsRow(String tbName, byte[] rowkey) overloading with rowkey
boolean	existsRow(String tbName, org.apache.hadoop.hbase.client.Get get) exists getOrigin
boolean	existsTable(String tbName) htable is exists
HData	get(String tbName, byte[] rowkey) overloading
List<HData>	get(String tbName, List<byte[]> rows)
org.apache.hadoop.hbase.HColumnDescriptor[]	getColumnFamilies(String tbName) getOrigin column families
List<String>	getColumnFamiliesName(String tbName) getOrigin all column families name
HData	getHdata(String tbName, HData data) hdata parameter
List<HData>	getHdata(String tbName, List<HData> datas)
HData	getOrigin(String tbName, org.apache.hadoop.hbase.client.Get get) origonal getOrigin
List<HData>	getOrigin(String tbName, List<org.apache.hadoop.hbase.client.Get> gets) batch
List<HData>	gets(String tbName, byte[] start, byte[] stop) scan data by start rowkey and stop rowkey
List<HData>	gets(String tbName, byte[] start, byte[] stop, byte[] family)
List<HData>	gets(String tbName, byte[] start, byte[] stop, byte[] family, byte[] qualifier)
List<HData>	gets(String tbName, byte[] start, int count, HBaseClient.NextRowkeyHandler nextHandler) set start and load count hdatas to list
List<HData>	gets(String tbName, byte[] start, int count, HBaseClient.NextRowkeyHandler nextHandler, byte[] family)
List<HData>	gets(String tbName, byte[] start, int count, HBaseClient.NextRowkeyHandler nextHandler, byte[] family, byte[] qualifier)
List<HData>	getsOrigin(String tbName, org.apache.hadoop.hbase.client.Scan scan) original scanner
List<String>	getTableNameList() getOrigin table name list
void	put(String tbName, HData data) put single data
void	put(String tbName, List<HData> datas) put list datas
void	putAsync(String tbName, HData data) async put HData
void	putAsync(String tbName, List<HData> datas) async put bulk data, but no flush per minute or same interval flush the mutator
void	putAsyncOrigin(String tbName, List<org.apache.hadoop.hbase.client.Put> puts) async batch mutate
void	putAsyncOrigin(String tbName, org.apache.hadoop.hbase.client.Put put) async mutate
void	putOrigin(String tbName, List<org.apache.hadoop.hbase.client.Put> puts) origin puts
void	putOrigin(String tbName, org.apache.hadoop.hbase.client.Put put) origin put

Methods inherited from class java.lang.Object

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

Field Detail

TIMER_DELAY_SCHEDULE

public static final long TIMER_DELAY_SCHEDULE

See Also:

Constant Field Values

TIMER_PERIOD_SCHEDULE

public static final long TIMER_PERIOD_SCHEDULE

See Also:

Constant Field Values

DEFAULT_SCAN_CACHING

public static final int DEFAULT_SCAN_CACHING

See Also:

Constant Field Values

LOOKAHEAD_SCAN_SEEK

public static final int LOOKAHEAD_SCAN_SEEK

See Also:

Constant Field Values

Constructor Detail

HBaseClient

public HBaseClient(HBaseConf hconf)
            throws Exception

init hbase conn and admin and table

Parameters:

hconf -

Throws:

Exception

Method Detail

existsTable

public boolean existsTable(String tbName)
                    throws Exception

htable is exists

Parameters:

tbName -

Returns:

bool

Throws:

Exception

createTable

public void createTable(String tbName)
                 throws Exception

create htable

Parameters:

tbName -

Throws:

Exception

createTable

public void createTable(String tbName,
                        String[] families)
                 throws Exception

create the hbase table with hbase descriptor

Parameters:

tbName -

families -

Throws:

Exception

getColumnFamilies

public org.apache.hadoop.hbase.HColumnDescriptor[] getColumnFamilies(String tbName)
                                                              throws Exception

getOrigin column families

Parameters:

tbName -

Returns:

Throws:

Exception

getColumnFamiliesName

public List<String> getColumnFamiliesName(String tbName)
                                   throws Exception

getOrigin all column families name

Parameters:

tbName -

Returns:

families name

Throws:

Exception

addFamily

public void addFamily(String tbName,
                      String[] families)
               throws Exception

add family columng

Parameters:

tbName -

families -

Throws:

Exception

createNamespace

public void createNamespace(String namespace)
                     throws Exception

create namespace

Parameters:

namespace -

Throws:

Exception

deleteFamily

public void deleteFamily(String tbName,
                         String family)
                  throws Exception

delete family column

Parameters:

tbName -

family -

Throws:

Exception

deleteNamespace

public void deleteNamespace(String namespace)
                     throws Exception

delete namespace

Parameters:

namespace -

Throws:

Exception

deleteTable

public void deleteTable(String tbName)
                 throws Exception

delete htable

Parameters:

tbName -

Throws:

Exception

getTableNameList

public List<String> getTableNameList()
                              throws Exception

getOrigin table name list

Returns:

name list

Throws:

Exception

putOrigin

public void putOrigin(String tbName,
                      org.apache.hadoop.hbase.client.Put put)
               throws Exception

origin put

Parameters:

tbName -

put -

Throws:

Exception

putOrigin

public void putOrigin(String tbName,
                      List<org.apache.hadoop.hbase.client.Put> puts)
               throws Exception

origin puts

Parameters:

tbName -

puts -

Throws:

Exception

put

public void put(String tbName,
                HData data)
         throws Exception

put single data

Parameters:

tbName -

data -

Throws:

Exception

put

public void put(String tbName,
                List<HData> datas)
         throws Exception

put list datas

Parameters:

tbName -

datas -

Throws:

Exception

putAsyncOrigin

public void putAsyncOrigin(String tbName,
                           org.apache.hadoop.hbase.client.Put put)
                    throws Exception

async mutate

Parameters:

tbName -

put -

Throws:

Exception

putAsyncOrigin

public void putAsyncOrigin(String tbName,
                           List<org.apache.hadoop.hbase.client.Put> puts)
                    throws Exception

async batch mutate

Parameters:

tbName -

puts -

Throws:

Exception

putAsync

public void putAsync(String tbName,
                     HData data)
              throws Exception

async put HData

Parameters:

tbName -

data -

Throws:

Exception

putAsync

public void putAsync(String tbName,
                     List<HData> datas)
              throws Exception

async put bulk data, but no flush per minute or same interval flush the mutator

Parameters:

tbName -

datas -

Throws:

Exception

getOrigin

public HData getOrigin(String tbName,
                       org.apache.hadoop.hbase.client.Get get)
                throws Exception

origonal getOrigin

Parameters:

tbName -

get -

Returns:

hdata

Throws:

Exception

getOrigin

public List<HData> getOrigin(String tbName,
                             List<org.apache.hadoop.hbase.client.Get> gets)
                      throws Exception

batch

Parameters:

tbName -

gets -

Returns:

list of hdata

Throws:

Exception

get

public HData get(String tbName,
                 byte[] rowkey)
          throws Exception

overloading

Parameters:

tbName -

rowkey -

Returns:

hdata

Throws:

Exception

get

public List<HData> get(String tbName,
                       List<byte[]> rows)
                throws Exception

Throws:

Exception

getHdata

public HData getHdata(String tbName,
                      HData data)
               throws Exception

hdata parameter

Parameters:

tbName -

data -

Returns:

hbase data

Throws:

Exception

getHdata

public List<HData> getHdata(String tbName,
                            List<HData> datas)
                     throws Exception

Throws:

Exception

existsRow

public boolean existsRow(String tbName,
                         org.apache.hadoop.hbase.client.Get get)
                  throws Exception

exists getOrigin

Parameters:

tbName -

get -

Returns:

bool

Throws:

Exception

existsRow

public boolean existsRow(String tbName,
                         byte[] rowkey)
                  throws Exception

overloading with rowkey

Parameters:

tbName -

rowkey -

Returns:

bool

Throws:

Exception

deleteOrigin

public void deleteOrigin(String tbName,
                         org.apache.hadoop.hbase.client.Delete delete)
                  throws Exception

delete the delte

Parameters:

tbName -

delete -

Throws:

Exception

deleteOrigin

public void deleteOrigin(String tbName,
                         List<org.apache.hadoop.hbase.client.Delete> deletes)
                  throws Exception

Throws:

Exception

delete

public void delete(String tbName,
                   byte[] rowkey)
            throws Exception

delete by rowkey

Parameters:

tbName -

rowkey -

Throws:

Exception

delete

public void delete(String tbName,
                   List<byte[]> rows)
            throws Exception

Throws:

Exception

deleteHData

public void deleteHData(String tbName,
                        HData data)
                 throws Exception

delete hdata

Parameters:

tbName -

Throws:

Exception

deleteHData

public void deleteHData(String tbName,
                        List<HData> datas)
                 throws Exception

Throws:

Exception

deleteAsyncOrigin

public void deleteAsyncOrigin(String tbName,
                              List<org.apache.hadoop.hbase.client.Delete> deletes)
                       throws Exception

original delete async

Parameters:

tbName -

deletes -

Throws:

Exception

deleteAsync

public void deleteAsync(String tbName,
                        List<byte[]> rows)
                 throws Exception

Throws:

Exception

deleteAsyncHData

public void deleteAsyncHData(String tbName,
                             List<HData> datas)
                      throws Exception

Throws:

Exception

getsOrigin

public List<HData> getsOrigin(String tbName,
                              org.apache.hadoop.hbase.client.Scan scan)
                       throws Exception

original scanner

Parameters:

tbName -

scan -

Returns:

Throws:

Exception

gets

public List<HData> gets(String tbName,
                        byte[] start,
                        byte[] stop)
                 throws Exception

scan data by start rowkey and stop rowkey

Parameters:

tbName -

start -

stop -

Returns:

list of hdata

Throws:

Exception

gets

public List<HData> gets(String tbName,
                        byte[] start,
                        byte[] stop,
                        byte[] family)
                 throws Exception

Throws:

Exception

gets

public List<HData> gets(String tbName,
                        byte[] start,
                        byte[] stop,
                        byte[] family,
                        byte[] qualifier)
                 throws Exception

Throws:

Exception

gets

public List<HData> gets(String tbName,
                        byte[] start,
                        int count,
                        HBaseClient.NextRowkeyHandler nextHandler)
                 throws Exception

set start and load count hdatas to list

Parameters:

tbName -

start -

count -

nextHandler -

Returns:

hdatas

Throws:

Exception

gets

public List<HData> gets(String tbName,
                        byte[] start,
                        int count,
                        HBaseClient.NextRowkeyHandler nextHandler,
                        byte[] family)
                 throws Exception

Throws:

Exception

gets

public List<HData> gets(String tbName,
                        byte[] start,
                        int count,
                        HBaseClient.NextRowkeyHandler nextHandler,
                        byte[] family,
                        byte[] qualifier)
                 throws Exception

Throws:

Exception

close

public void close()
           throws Exception

close the connection

Throws:

Exception