Sha256: 66c48d17455903e4bb65e8b3a2107880d18f3ba31a2c61489709911223752131
Contents?: true
Size: 1.45 KB
Versions: 11
Compression:
Stored size: 1.45 KB
Contents
require 'thrift'
require File.join(File.dirname(__FILE__), 'hbase', 'hbase_constants')
require File.join(File.dirname(__FILE__), 'hbase', 'hbase_types')
require File.join(File.dirname(__FILE__), 'hbase', 'hbase')
# Try to make the crazy nesting that Thrift generates a little less painful
module Hbase
Client = ::Apache::Hadoop::Hbase::Thrift::Hbase::Client
Apache::Hadoop::Hbase::Thrift.constants.each do |constant|
const_set(constant, Apache::Hadoop::Hbase::Thrift.const_get(constant))
end
class Client
def incrementAndReturn(table_name,amount)
c_row = get('table_indices','0',table_name,{})[0].value.to_i
n_row = c_row+amount
mutateRow('table_indices','0',[HBase::Mutation.new(column: table_name, value: n_row.to_s)],{})
c_row
end
def getRowsByScanner(table,columns,filters,limit,obj={})
scan = HBase::TScan.new
filters = "(RowFilter(>=, 'binary:0'))" if filters == ''
scan.filterString = filters
scanner = scannerOpenWithScan(table, scan, obj)
results = []
scan_limit = limit || 100000
rows = scannerGetList(scanner, scan_limit)
rows.each do |row|
if columns[0] == '*'
results << row.columns.each{ |k,v| row.columns[k] = v.value }
else
row_result = {}
columns.each{ |k| row_result[k] = row.columns[k].value }
results << row_result
end
end
results
end
end
end
HBase = Hbase
Version data entries
11 entries across 11 versions & 1 rubygems