我正在使用node.js的thrift npm库进行一个项目。
使用hbase shell运行以下扫描时,得到1个结果(正确):
scan "UserLog", {COLUMNS => ["entry"], FILTER => "(SingleColumnValueFilter('entry', 'addedTime', >=,'binary:1437696000000',true,true)) AND (SingleColumnValueFilter('entry', 'addedTime', <=,'binary:1437764400000',true,true))"}
使用nodejs thrift进行相同的扫描(以节点格式),我没有得到任何结果(不正确):
var query = { columns: [ 'entry' ], filterString: '(SingleColumnValueFilter('entry', 'addedTime', >=,'binary:1437696000000',true,true)) AND (SingleColumnValueFilter('entry', 'addedTime', <=,'binary:1437764400000',true,true)) ' }
我们使用的nodejs节俭代码是:
this.connection.hbaseConnect(function(client, connectionHbase) {
if(client) {
client.scannerOpenWithScan(tableName, new _hbase_types.TScan(query), null, function (err, scannerId) {
client.scannerGet(scannerId, function (err, result) {
client.scannerGetList(scannerId, 1000, function(err, res){
if(err) {
console.log(err);
}
callback(res);
connectionHbase.end();
});
});
});
}
else
{
callback(false);
}}, Message);
我们的环境细节是:
我们使用的是hbase 0.98.1。
nodejs节俭包可以在这里找到-https://www.npmjs.com/package/thrift
暂无答案!
目前还没有任何答案,快来回答吧!