node-hbase-thrift2
===

[![NPM Version][npm-image]][npm-url]
[![NPM Downloads][downloads-image]][downloads-url]

Yet another NodeJS HBase thrift2 client. Reinforcement the Reconnect support.

Installation

``sh
$ npm install --save node-hbase-thrift2
`

Usage

1. Create client

`javascript
var HBase = require('node-hbase-thrift2')

var config = {
hosts: ['host1','host2'],
port: 9090,
timeout:1000
};

var hbaseClient = HBase.createClient(config);
`

2. Get a row data

`javascript
var get = HBase.Get('rowkey');
get.add('family'); // or
get.add('family', 'qualifier'); // or
get.add('family', 'qualifier', 1); // has timestamp
hbaseClient.get('table', get, function(err,data){
if(err)
console.log('error:', err);
else
console.log('get:', data);
});
`

`sh
get: {
row: 'rowkey',
columnValues: [
{
family: 'family',
qualifier: 'qualifier',
value: ,
timestamp: 1488469442863
}
]
}
`

3. Put or Update columns value in a row

`javascript
var put = HBase.Put('rowkey');
put.add('family', 'qualifier', 'value'); // or
put.add('family', 'qualifier', 'value', Date.now()); // has timestamp
put.add('family', 'qualifier', HBase.Int64(65535)); // direct number buffer
hbaseClient.put('table', put, function(err){
if(err)
console.log('error:', err);
else
console.log('put is successfully');
});
`

> HBase.Int64()
>> Create node-int64 instance

4. Increment columns value in a row

`javascript
var inc = HBase.Inc('rowkey');
inc.add('family', 'qualifier');
inc.add('family', 'qualifier2', 2);
hbaseClient.inc('table', inc, function(err, data){
if(err)
console.log('error:', err);
else
console.log('inc:', data);
});
`

`sh
inc: {
row: 'rowkey',
columnValues: [
{
family: 'family',
qualifier: 'qualifier',
value: ,
timestamp: 1488469442863
},
{
family: 'family',
qualifier: 'qualifier2',
value: ,
timestamp: 1488469442863
}
]
}
`

5. Delete some columns value or a row

`javascript
var del = HBase.Del('rowkey');
del.add('family'); // or
del.add('family', 'qualifier'); // or
del.add('family', 'qualifier', 1); // has timestamp
hbaseClient.del('table', del, function(err){
if(err)
console.log('error:', err);
else
console.log('del is successfully');
});
`

6. Scan some rows

`javascript
var numRows = 10;
var scan = HBase.Scan('startrow');
scan.add('family'); // or
scan.add('family', 'qualifier'); // or
scan.add('family', 'qualifier', 1); // has timestamp
// scan number of rows
hbaseClient.scan('table', scan, numRows, function(err, rows){
if(err)
console.log('error:', err);
else
console.log('scan has', rows.length);
});
// scan each batch rows
hbaseClient.scanEach('table', scan, numRows, function(rows, next) {
console.log('scanEach:', rows.length);
next(null);
}, function(err, rows){
if(err)
console.log('error:', err);
else
console.log('scanEach is successfully');
});
``

License

ISC

[npm-image]: https://img.shields.io/npm/v/node-hbase-thrift2.svg
[npm-url]: https://npmjs.org/package/node-hbase-thrift2
[downloads-image]: https://img.shields.io/npm/dm/node-hbase-thrift2.svg
[downloads-url]: https://npmjs.org/package/node-hbase-thrift2