| Package | Description |
|---|---|
| com.github.hackerwin7.jlib.utils.commons.convert | |
| com.github.hackerwin7.jlib.utils.drivers.hbase.client |
| Modifier and Type | Method and Description |
|---|---|
static HData |
Convert.result2hdata(org.apache.hadoop.hbase.client.Result result)
convert a result into a hdata
Single row result of a Get or Scan query.
|
| Modifier and Type | Method and Description |
|---|---|
static org.apache.hadoop.hbase.client.Put |
Convert.hdata2put(HData data)
convert hdata to put
|
| Modifier and Type | Method and Description |
|---|---|
HData |
HBaseClient.get(String tbName,
byte[] rowkey)
overloading
|
HData |
HBaseClient.getHdata(String tbName,
HData data)
hdata parameter
|
HData |
HBaseClient.getOrigin(String tbName,
org.apache.hadoop.hbase.client.Get get)
origonal getOrigin
|
| Modifier and Type | Method and Description |
|---|---|
List<HData> |
HBaseClient.get(String tbName,
List<byte[]> rows) |
List<HData> |
HBaseClient.getHdata(String tbName,
List<HData> datas) |
List<HData> |
HBaseClient.getOrigin(String tbName,
List<org.apache.hadoop.hbase.client.Get> gets)
batch
|
List<HData> |
HBaseClient.gets(String tbName,
byte[] start,
byte[] stop)
scan data by start rowkey and stop rowkey
|
List<HData> |
HBaseClient.gets(String tbName,
byte[] start,
byte[] stop,
byte[] family) |
List<HData> |
HBaseClient.gets(String tbName,
byte[] start,
byte[] stop,
byte[] family,
byte[] qualifier) |
List<HData> |
HBaseClient.gets(String tbName,
byte[] start,
int count,
HBaseClient.NextRowkeyHandler nextHandler)
set start and load count hdatas to list
|
List<HData> |
HBaseClient.gets(String tbName,
byte[] start,
int count,
HBaseClient.NextRowkeyHandler nextHandler,
byte[] family) |
List<HData> |
HBaseClient.gets(String tbName,
byte[] start,
int count,
HBaseClient.NextRowkeyHandler nextHandler,
byte[] family,
byte[] qualifier) |
List<HData> |
HBaseClient.getsOrigin(String tbName,
org.apache.hadoop.hbase.client.Scan scan)
original scanner
|
| Modifier and Type | Method and Description |
|---|---|
void |
HBaseClient.deleteHData(String tbName,
HData data)
delete hdata
|
HData |
HBaseClient.getHdata(String tbName,
HData data)
hdata parameter
|
void |
HBaseClient.put(String tbName,
HData data)
put single data
|
void |
HBaseClient.putAsync(String tbName,
HData data)
async put HData
|
| Modifier and Type | Method and Description |
|---|---|
void |
HBaseClient.deleteAsyncHData(String tbName,
List<HData> datas) |
void |
HBaseClient.deleteHData(String tbName,
List<HData> datas) |
List<HData> |
HBaseClient.getHdata(String tbName,
List<HData> datas) |
void |
HBaseClient.put(String tbName,
List<HData> datas)
put list datas
|
void |
HBaseClient.putAsync(String tbName,
List<HData> datas)
async put bulk data, but no flush
per minute or same interval flush the mutator
|
Copyright © 2016. All rights reserved.