lib/adapter/hbase/hbase.rb
#
# Autogenerated by Thrift Compiler (0.9.1)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
module Apache
module Hadoop
module Hbase
module Thrift
module Hbase
class Client
include ::Thrift::Client
def enableTable(tableName)
send_enableTable(tableName)
recv_enableTable()
end
def send_enableTable(tableName)
send_message('enableTable', EnableTable_args, :tableName => tableName)
end
def recv_enableTable()
result = receive_message(EnableTable_result)
raise result.io unless result.io.nil?
return
end
def disableTable(tableName)
send_disableTable(tableName)
recv_disableTable()
end
def send_disableTable(tableName)
send_message('disableTable', DisableTable_args, :tableName => tableName)
end
def recv_disableTable()
result = receive_message(DisableTable_result)
raise result.io unless result.io.nil?
return
end
def isTableEnabled(tableName)
send_isTableEnabled(tableName)
return recv_isTableEnabled()
end
def send_isTableEnabled(tableName)
send_message('isTableEnabled', IsTableEnabled_args, :tableName => tableName)
end
def recv_isTableEnabled()
result = receive_message(IsTableEnabled_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'isTableEnabled failed: unknown result')
end
def compact(tableNameOrRegionName)
send_compact(tableNameOrRegionName)
recv_compact()
end
def send_compact(tableNameOrRegionName)
send_message('compact', Compact_args, :tableNameOrRegionName => tableNameOrRegionName)
end
def recv_compact()
result = receive_message(Compact_result)
raise result.io unless result.io.nil?
return
end
def majorCompact(tableNameOrRegionName)
send_majorCompact(tableNameOrRegionName)
recv_majorCompact()
end
def send_majorCompact(tableNameOrRegionName)
send_message('majorCompact', MajorCompact_args, :tableNameOrRegionName => tableNameOrRegionName)
end
def recv_majorCompact()
result = receive_message(MajorCompact_result)
raise result.io unless result.io.nil?
return
end
def getTableNames()
send_getTableNames()
return recv_getTableNames()
end
def send_getTableNames()
send_message('getTableNames', GetTableNames_args)
end
def recv_getTableNames()
result = receive_message(GetTableNames_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTableNames failed: unknown result')
end
def getColumnDescriptors(tableName)
send_getColumnDescriptors(tableName)
return recv_getColumnDescriptors()
end
def send_getColumnDescriptors(tableName)
send_message('getColumnDescriptors', GetColumnDescriptors_args, :tableName => tableName)
end
def recv_getColumnDescriptors()
result = receive_message(GetColumnDescriptors_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getColumnDescriptors failed: unknown result')
end
def getTableRegions(tableName)
send_getTableRegions(tableName)
return recv_getTableRegions()
end
def send_getTableRegions(tableName)
send_message('getTableRegions', GetTableRegions_args, :tableName => tableName)
end
def recv_getTableRegions()
result = receive_message(GetTableRegions_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTableRegions failed: unknown result')
end
def createTable(tableName, columnFamilies)
send_createTable(tableName, columnFamilies)
recv_createTable()
end
def send_createTable(tableName, columnFamilies)
send_message('createTable', CreateTable_args, :tableName => tableName, :columnFamilies => columnFamilies)
end
def recv_createTable()
result = receive_message(CreateTable_result)
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
raise result.exist unless result.exist.nil?
return
end
def deleteTable(tableName)
send_deleteTable(tableName)
recv_deleteTable()
end
def send_deleteTable(tableName)
send_message('deleteTable', DeleteTable_args, :tableName => tableName)
end
def recv_deleteTable()
result = receive_message(DeleteTable_result)
raise result.io unless result.io.nil?
return
end
def get(tableName, row, column, attributes)
send_get(tableName, row, column, attributes)
return recv_get()
end
def send_get(tableName, row, column, attributes)
send_message('get', Get_args, :tableName => tableName, :row => row, :column => column, :attributes => attributes)
end
def recv_get()
result = receive_message(Get_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get failed: unknown result')
end
def getVer(tableName, row, column, numVersions, attributes)
send_getVer(tableName, row, column, numVersions, attributes)
return recv_getVer()
end
def send_getVer(tableName, row, column, numVersions, attributes)
send_message('getVer', GetVer_args, :tableName => tableName, :row => row, :column => column, :numVersions => numVersions, :attributes => attributes)
end
def recv_getVer()
result = receive_message(GetVer_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getVer failed: unknown result')
end
def getVerTs(tableName, row, column, timestamp, numVersions, attributes)
send_getVerTs(tableName, row, column, timestamp, numVersions, attributes)
return recv_getVerTs()
end
def send_getVerTs(tableName, row, column, timestamp, numVersions, attributes)
send_message('getVerTs', GetVerTs_args, :tableName => tableName, :row => row, :column => column, :timestamp => timestamp, :numVersions => numVersions, :attributes => attributes)
end
def recv_getVerTs()
result = receive_message(GetVerTs_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getVerTs failed: unknown result')
end
def getRow(tableName, row, attributes)
send_getRow(tableName, row, attributes)
return recv_getRow()
end
def send_getRow(tableName, row, attributes)
send_message('getRow', GetRow_args, :tableName => tableName, :row => row, :attributes => attributes)
end
def recv_getRow()
result = receive_message(GetRow_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRow failed: unknown result')
end
def getRowWithColumns(tableName, row, columns, attributes)
send_getRowWithColumns(tableName, row, columns, attributes)
return recv_getRowWithColumns()
end
def send_getRowWithColumns(tableName, row, columns, attributes)
send_message('getRowWithColumns', GetRowWithColumns_args, :tableName => tableName, :row => row, :columns => columns, :attributes => attributes)
end
def recv_getRowWithColumns()
result = receive_message(GetRowWithColumns_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowWithColumns failed: unknown result')
end
def getRowTs(tableName, row, timestamp, attributes)
send_getRowTs(tableName, row, timestamp, attributes)
return recv_getRowTs()
end
def send_getRowTs(tableName, row, timestamp, attributes)
send_message('getRowTs', GetRowTs_args, :tableName => tableName, :row => row, :timestamp => timestamp, :attributes => attributes)
end
def recv_getRowTs()
result = receive_message(GetRowTs_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowTs failed: unknown result')
end
def getRowWithColumnsTs(tableName, row, columns, timestamp, attributes)
send_getRowWithColumnsTs(tableName, row, columns, timestamp, attributes)
return recv_getRowWithColumnsTs()
end
def send_getRowWithColumnsTs(tableName, row, columns, timestamp, attributes)
send_message('getRowWithColumnsTs', GetRowWithColumnsTs_args, :tableName => tableName, :row => row, :columns => columns, :timestamp => timestamp, :attributes => attributes)
end
def recv_getRowWithColumnsTs()
result = receive_message(GetRowWithColumnsTs_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowWithColumnsTs failed: unknown result')
end
def getRows(tableName, rows, attributes)
send_getRows(tableName, rows, attributes)
return recv_getRows()
end
def send_getRows(tableName, rows, attributes)
send_message('getRows', GetRows_args, :tableName => tableName, :rows => rows, :attributes => attributes)
end
def recv_getRows()
result = receive_message(GetRows_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRows failed: unknown result')
end
def getRowsWithColumns(tableName, rows, columns, attributes)
send_getRowsWithColumns(tableName, rows, columns, attributes)
return recv_getRowsWithColumns()
end
def send_getRowsWithColumns(tableName, rows, columns, attributes)
send_message('getRowsWithColumns', GetRowsWithColumns_args, :tableName => tableName, :rows => rows, :columns => columns, :attributes => attributes)
end
def recv_getRowsWithColumns()
result = receive_message(GetRowsWithColumns_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowsWithColumns failed: unknown result')
end
def getRowsTs(tableName, rows, timestamp, attributes)
send_getRowsTs(tableName, rows, timestamp, attributes)
return recv_getRowsTs()
end
def send_getRowsTs(tableName, rows, timestamp, attributes)
send_message('getRowsTs', GetRowsTs_args, :tableName => tableName, :rows => rows, :timestamp => timestamp, :attributes => attributes)
end
def recv_getRowsTs()
result = receive_message(GetRowsTs_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowsTs failed: unknown result')
end
def getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes)
send_getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes)
return recv_getRowsWithColumnsTs()
end
def send_getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes)
send_message('getRowsWithColumnsTs', GetRowsWithColumnsTs_args, :tableName => tableName, :rows => rows, :columns => columns, :timestamp => timestamp, :attributes => attributes)
end
def recv_getRowsWithColumnsTs()
result = receive_message(GetRowsWithColumnsTs_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowsWithColumnsTs failed: unknown result')
end
def mutateRow(tableName, row, mutations, attributes)
send_mutateRow(tableName, row, mutations, attributes)
recv_mutateRow()
end
def send_mutateRow(tableName, row, mutations, attributes)
send_message('mutateRow', MutateRow_args, :tableName => tableName, :row => row, :mutations => mutations, :attributes => attributes)
end
def recv_mutateRow()
result = receive_message(MutateRow_result)
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
return
end
def mutateRowTs(tableName, row, mutations, timestamp, attributes)
send_mutateRowTs(tableName, row, mutations, timestamp, attributes)
recv_mutateRowTs()
end
def send_mutateRowTs(tableName, row, mutations, timestamp, attributes)
send_message('mutateRowTs', MutateRowTs_args, :tableName => tableName, :row => row, :mutations => mutations, :timestamp => timestamp, :attributes => attributes)
end
def recv_mutateRowTs()
result = receive_message(MutateRowTs_result)
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
return
end
def mutateRows(tableName, rowBatches, attributes)
send_mutateRows(tableName, rowBatches, attributes)
recv_mutateRows()
end
def send_mutateRows(tableName, rowBatches, attributes)
send_message('mutateRows', MutateRows_args, :tableName => tableName, :rowBatches => rowBatches, :attributes => attributes)
end
def recv_mutateRows()
result = receive_message(MutateRows_result)
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
return
end
def mutateRowsTs(tableName, rowBatches, timestamp, attributes)
send_mutateRowsTs(tableName, rowBatches, timestamp, attributes)
recv_mutateRowsTs()
end
def send_mutateRowsTs(tableName, rowBatches, timestamp, attributes)
send_message('mutateRowsTs', MutateRowsTs_args, :tableName => tableName, :rowBatches => rowBatches, :timestamp => timestamp, :attributes => attributes)
end
def recv_mutateRowsTs()
result = receive_message(MutateRowsTs_result)
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
return
end
def atomicIncrement(tableName, row, column, value)
send_atomicIncrement(tableName, row, column, value)
return recv_atomicIncrement()
end
def send_atomicIncrement(tableName, row, column, value)
send_message('atomicIncrement', AtomicIncrement_args, :tableName => tableName, :row => row, :column => column, :value => value)
end
def recv_atomicIncrement()
result = receive_message(AtomicIncrement_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'atomicIncrement failed: unknown result')
end
def deleteAll(tableName, row, column, attributes)
send_deleteAll(tableName, row, column, attributes)
recv_deleteAll()
end
def send_deleteAll(tableName, row, column, attributes)
send_message('deleteAll', DeleteAll_args, :tableName => tableName, :row => row, :column => column, :attributes => attributes)
end
def recv_deleteAll()
result = receive_message(DeleteAll_result)
raise result.io unless result.io.nil?
return
end
def deleteAllTs(tableName, row, column, timestamp, attributes)
send_deleteAllTs(tableName, row, column, timestamp, attributes)
recv_deleteAllTs()
end
def send_deleteAllTs(tableName, row, column, timestamp, attributes)
send_message('deleteAllTs', DeleteAllTs_args, :tableName => tableName, :row => row, :column => column, :timestamp => timestamp, :attributes => attributes)
end
def recv_deleteAllTs()
result = receive_message(DeleteAllTs_result)
raise result.io unless result.io.nil?
return
end
def deleteAllRow(tableName, row, attributes)
send_deleteAllRow(tableName, row, attributes)
recv_deleteAllRow()
end
def send_deleteAllRow(tableName, row, attributes)
send_message('deleteAllRow', DeleteAllRow_args, :tableName => tableName, :row => row, :attributes => attributes)
end
def recv_deleteAllRow()
result = receive_message(DeleteAllRow_result)
raise result.io unless result.io.nil?
return
end
def increment(increment)
send_increment(increment)
recv_increment()
end
def send_increment(increment)
send_message('increment', Increment_args, :increment => increment)
end
def recv_increment()
result = receive_message(Increment_result)
raise result.io unless result.io.nil?
return
end
def incrementRows(increments)
send_incrementRows(increments)
recv_incrementRows()
end
def send_incrementRows(increments)
send_message('incrementRows', IncrementRows_args, :increments => increments)
end
def recv_incrementRows()
result = receive_message(IncrementRows_result)
raise result.io unless result.io.nil?
return
end
def deleteAllRowTs(tableName, row, timestamp, attributes)
send_deleteAllRowTs(tableName, row, timestamp, attributes)
recv_deleteAllRowTs()
end
def send_deleteAllRowTs(tableName, row, timestamp, attributes)
send_message('deleteAllRowTs', DeleteAllRowTs_args, :tableName => tableName, :row => row, :timestamp => timestamp, :attributes => attributes)
end
def recv_deleteAllRowTs()
result = receive_message(DeleteAllRowTs_result)
raise result.io unless result.io.nil?
return
end
def scannerOpenWithScan(tableName, scan, attributes)
send_scannerOpenWithScan(tableName, scan, attributes)
return recv_scannerOpenWithScan()
end
def send_scannerOpenWithScan(tableName, scan, attributes)
send_message('scannerOpenWithScan', ScannerOpenWithScan_args, :tableName => tableName, :scan => scan, :attributes => attributes)
end
def recv_scannerOpenWithScan()
result = receive_message(ScannerOpenWithScan_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerOpenWithScan failed: unknown result')
end
def scannerOpen(tableName, startRow, columns, attributes)
send_scannerOpen(tableName, startRow, columns, attributes)
return recv_scannerOpen()
end
def send_scannerOpen(tableName, startRow, columns, attributes)
send_message('scannerOpen', ScannerOpen_args, :tableName => tableName, :startRow => startRow, :columns => columns, :attributes => attributes)
end
def recv_scannerOpen()
result = receive_message(ScannerOpen_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerOpen failed: unknown result')
end
def scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes)
send_scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes)
return recv_scannerOpenWithStop()
end
def send_scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes)
send_message('scannerOpenWithStop', ScannerOpenWithStop_args, :tableName => tableName, :startRow => startRow, :stopRow => stopRow, :columns => columns, :attributes => attributes)
end
def recv_scannerOpenWithStop()
result = receive_message(ScannerOpenWithStop_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerOpenWithStop failed: unknown result')
end
def scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes)
send_scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes)
return recv_scannerOpenWithPrefix()
end
def send_scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes)
send_message('scannerOpenWithPrefix', ScannerOpenWithPrefix_args, :tableName => tableName, :startAndPrefix => startAndPrefix, :columns => columns, :attributes => attributes)
end
def recv_scannerOpenWithPrefix()
result = receive_message(ScannerOpenWithPrefix_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerOpenWithPrefix failed: unknown result')
end
def scannerOpenTs(tableName, startRow, columns, timestamp, attributes)
send_scannerOpenTs(tableName, startRow, columns, timestamp, attributes)
return recv_scannerOpenTs()
end
def send_scannerOpenTs(tableName, startRow, columns, timestamp, attributes)
send_message('scannerOpenTs', ScannerOpenTs_args, :tableName => tableName, :startRow => startRow, :columns => columns, :timestamp => timestamp, :attributes => attributes)
end
def recv_scannerOpenTs()
result = receive_message(ScannerOpenTs_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerOpenTs failed: unknown result')
end
def scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes)
send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes)
return recv_scannerOpenWithStopTs()
end
def send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes)
send_message('scannerOpenWithStopTs', ScannerOpenWithStopTs_args, :tableName => tableName, :startRow => startRow, :stopRow => stopRow, :columns => columns, :timestamp => timestamp, :attributes => attributes)
end
def recv_scannerOpenWithStopTs()
result = receive_message(ScannerOpenWithStopTs_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerOpenWithStopTs failed: unknown result')
end
def scannerGet(id)
send_scannerGet(id)
return recv_scannerGet()
end
def send_scannerGet(id)
send_message('scannerGet', ScannerGet_args, :id => id)
end
def recv_scannerGet()
result = receive_message(ScannerGet_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerGet failed: unknown result')
end
def scannerGetList(id, nbRows)
send_scannerGetList(id, nbRows)
return recv_scannerGetList()
end
def send_scannerGetList(id, nbRows)
send_message('scannerGetList', ScannerGetList_args, :id => id, :nbRows => nbRows)
end
def recv_scannerGetList()
result = receive_message(ScannerGetList_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'scannerGetList failed: unknown result')
end
def scannerClose(id)
send_scannerClose(id)
recv_scannerClose()
end
def send_scannerClose(id)
send_message('scannerClose', ScannerClose_args, :id => id)
end
def recv_scannerClose()
result = receive_message(ScannerClose_result)
raise result.io unless result.io.nil?
raise result.ia unless result.ia.nil?
return
end
def getRowOrBefore(tableName, row, family)
send_getRowOrBefore(tableName, row, family)
return recv_getRowOrBefore()
end
def send_getRowOrBefore(tableName, row, family)
send_message('getRowOrBefore', GetRowOrBefore_args, :tableName => tableName, :row => row, :family => family)
end
def recv_getRowOrBefore()
result = receive_message(GetRowOrBefore_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowOrBefore failed: unknown result')
end
def getRegionInfo(row)
send_getRegionInfo(row)
return recv_getRegionInfo()
end
def send_getRegionInfo(row)
send_message('getRegionInfo', GetRegionInfo_args, :row => row)
end
def recv_getRegionInfo()
result = receive_message(GetRegionInfo_result)
return result.success unless result.success.nil?
raise result.io unless result.io.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRegionInfo failed: unknown result')
end
end
class Processor
include ::Thrift::Processor
def process_enableTable(seqid, iprot, oprot)
args = read_args(iprot, EnableTable_args)
result = EnableTable_result.new()
begin
@handler.enableTable(args.tableName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'enableTable', seqid)
end
def process_disableTable(seqid, iprot, oprot)
args = read_args(iprot, DisableTable_args)
result = DisableTable_result.new()
begin
@handler.disableTable(args.tableName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'disableTable', seqid)
end
def process_isTableEnabled(seqid, iprot, oprot)
args = read_args(iprot, IsTableEnabled_args)
result = IsTableEnabled_result.new()
begin
result.success = @handler.isTableEnabled(args.tableName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'isTableEnabled', seqid)
end
def process_compact(seqid, iprot, oprot)
args = read_args(iprot, Compact_args)
result = Compact_result.new()
begin
@handler.compact(args.tableNameOrRegionName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'compact', seqid)
end
def process_majorCompact(seqid, iprot, oprot)
args = read_args(iprot, MajorCompact_args)
result = MajorCompact_result.new()
begin
@handler.majorCompact(args.tableNameOrRegionName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'majorCompact', seqid)
end
def process_getTableNames(seqid, iprot, oprot)
args = read_args(iprot, GetTableNames_args)
result = GetTableNames_result.new()
begin
result.success = @handler.getTableNames()
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getTableNames', seqid)
end
def process_getColumnDescriptors(seqid, iprot, oprot)
args = read_args(iprot, GetColumnDescriptors_args)
result = GetColumnDescriptors_result.new()
begin
result.success = @handler.getColumnDescriptors(args.tableName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getColumnDescriptors', seqid)
end
def process_getTableRegions(seqid, iprot, oprot)
args = read_args(iprot, GetTableRegions_args)
result = GetTableRegions_result.new()
begin
result.success = @handler.getTableRegions(args.tableName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getTableRegions', seqid)
end
def process_createTable(seqid, iprot, oprot)
args = read_args(iprot, CreateTable_args)
result = CreateTable_result.new()
begin
@handler.createTable(args.tableName, args.columnFamilies)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
rescue ::Apache::Hadoop::Hbase::Thrift::AlreadyExists => exist
result.exist = exist
end
write_result(result, oprot, 'createTable', seqid)
end
def process_deleteTable(seqid, iprot, oprot)
args = read_args(iprot, DeleteTable_args)
result = DeleteTable_result.new()
begin
@handler.deleteTable(args.tableName)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'deleteTable', seqid)
end
def process_get(seqid, iprot, oprot)
args = read_args(iprot, Get_args)
result = Get_result.new()
begin
result.success = @handler.get(args.tableName, args.row, args.column, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'get', seqid)
end
def process_getVer(seqid, iprot, oprot)
args = read_args(iprot, GetVer_args)
result = GetVer_result.new()
begin
result.success = @handler.getVer(args.tableName, args.row, args.column, args.numVersions, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getVer', seqid)
end
def process_getVerTs(seqid, iprot, oprot)
args = read_args(iprot, GetVerTs_args)
result = GetVerTs_result.new()
begin
result.success = @handler.getVerTs(args.tableName, args.row, args.column, args.timestamp, args.numVersions, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getVerTs', seqid)
end
def process_getRow(seqid, iprot, oprot)
args = read_args(iprot, GetRow_args)
result = GetRow_result.new()
begin
result.success = @handler.getRow(args.tableName, args.row, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRow', seqid)
end
def process_getRowWithColumns(seqid, iprot, oprot)
args = read_args(iprot, GetRowWithColumns_args)
result = GetRowWithColumns_result.new()
begin
result.success = @handler.getRowWithColumns(args.tableName, args.row, args.columns, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRowWithColumns', seqid)
end
def process_getRowTs(seqid, iprot, oprot)
args = read_args(iprot, GetRowTs_args)
result = GetRowTs_result.new()
begin
result.success = @handler.getRowTs(args.tableName, args.row, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRowTs', seqid)
end
def process_getRowWithColumnsTs(seqid, iprot, oprot)
args = read_args(iprot, GetRowWithColumnsTs_args)
result = GetRowWithColumnsTs_result.new()
begin
result.success = @handler.getRowWithColumnsTs(args.tableName, args.row, args.columns, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRowWithColumnsTs', seqid)
end
def process_getRows(seqid, iprot, oprot)
args = read_args(iprot, GetRows_args)
result = GetRows_result.new()
begin
result.success = @handler.getRows(args.tableName, args.rows, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRows', seqid)
end
def process_getRowsWithColumns(seqid, iprot, oprot)
args = read_args(iprot, GetRowsWithColumns_args)
result = GetRowsWithColumns_result.new()
begin
result.success = @handler.getRowsWithColumns(args.tableName, args.rows, args.columns, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRowsWithColumns', seqid)
end
def process_getRowsTs(seqid, iprot, oprot)
args = read_args(iprot, GetRowsTs_args)
result = GetRowsTs_result.new()
begin
result.success = @handler.getRowsTs(args.tableName, args.rows, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRowsTs', seqid)
end
def process_getRowsWithColumnsTs(seqid, iprot, oprot)
args = read_args(iprot, GetRowsWithColumnsTs_args)
result = GetRowsWithColumnsTs_result.new()
begin
result.success = @handler.getRowsWithColumnsTs(args.tableName, args.rows, args.columns, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRowsWithColumnsTs', seqid)
end
def process_mutateRow(seqid, iprot, oprot)
args = read_args(iprot, MutateRow_args)
result = MutateRow_result.new()
begin
@handler.mutateRow(args.tableName, args.row, args.mutations, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'mutateRow', seqid)
end
def process_mutateRowTs(seqid, iprot, oprot)
args = read_args(iprot, MutateRowTs_args)
result = MutateRowTs_result.new()
begin
@handler.mutateRowTs(args.tableName, args.row, args.mutations, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'mutateRowTs', seqid)
end
def process_mutateRows(seqid, iprot, oprot)
args = read_args(iprot, MutateRows_args)
result = MutateRows_result.new()
begin
@handler.mutateRows(args.tableName, args.rowBatches, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'mutateRows', seqid)
end
def process_mutateRowsTs(seqid, iprot, oprot)
args = read_args(iprot, MutateRowsTs_args)
result = MutateRowsTs_result.new()
begin
@handler.mutateRowsTs(args.tableName, args.rowBatches, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'mutateRowsTs', seqid)
end
def process_atomicIncrement(seqid, iprot, oprot)
args = read_args(iprot, AtomicIncrement_args)
result = AtomicIncrement_result.new()
begin
result.success = @handler.atomicIncrement(args.tableName, args.row, args.column, args.value)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'atomicIncrement', seqid)
end
def process_deleteAll(seqid, iprot, oprot)
args = read_args(iprot, DeleteAll_args)
result = DeleteAll_result.new()
begin
@handler.deleteAll(args.tableName, args.row, args.column, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'deleteAll', seqid)
end
def process_deleteAllTs(seqid, iprot, oprot)
args = read_args(iprot, DeleteAllTs_args)
result = DeleteAllTs_result.new()
begin
@handler.deleteAllTs(args.tableName, args.row, args.column, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'deleteAllTs', seqid)
end
def process_deleteAllRow(seqid, iprot, oprot)
args = read_args(iprot, DeleteAllRow_args)
result = DeleteAllRow_result.new()
begin
@handler.deleteAllRow(args.tableName, args.row, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'deleteAllRow', seqid)
end
def process_increment(seqid, iprot, oprot)
args = read_args(iprot, Increment_args)
result = Increment_result.new()
begin
@handler.increment(args.increment)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'increment', seqid)
end
def process_incrementRows(seqid, iprot, oprot)
args = read_args(iprot, IncrementRows_args)
result = IncrementRows_result.new()
begin
@handler.incrementRows(args.increments)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'incrementRows', seqid)
end
def process_deleteAllRowTs(seqid, iprot, oprot)
args = read_args(iprot, DeleteAllRowTs_args)
result = DeleteAllRowTs_result.new()
begin
@handler.deleteAllRowTs(args.tableName, args.row, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'deleteAllRowTs', seqid)
end
def process_scannerOpenWithScan(seqid, iprot, oprot)
args = read_args(iprot, ScannerOpenWithScan_args)
result = ScannerOpenWithScan_result.new()
begin
result.success = @handler.scannerOpenWithScan(args.tableName, args.scan, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'scannerOpenWithScan', seqid)
end
def process_scannerOpen(seqid, iprot, oprot)
args = read_args(iprot, ScannerOpen_args)
result = ScannerOpen_result.new()
begin
result.success = @handler.scannerOpen(args.tableName, args.startRow, args.columns, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'scannerOpen', seqid)
end
def process_scannerOpenWithStop(seqid, iprot, oprot)
args = read_args(iprot, ScannerOpenWithStop_args)
result = ScannerOpenWithStop_result.new()
begin
result.success = @handler.scannerOpenWithStop(args.tableName, args.startRow, args.stopRow, args.columns, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'scannerOpenWithStop', seqid)
end
def process_scannerOpenWithPrefix(seqid, iprot, oprot)
args = read_args(iprot, ScannerOpenWithPrefix_args)
result = ScannerOpenWithPrefix_result.new()
begin
result.success = @handler.scannerOpenWithPrefix(args.tableName, args.startAndPrefix, args.columns, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'scannerOpenWithPrefix', seqid)
end
def process_scannerOpenTs(seqid, iprot, oprot)
args = read_args(iprot, ScannerOpenTs_args)
result = ScannerOpenTs_result.new()
begin
result.success = @handler.scannerOpenTs(args.tableName, args.startRow, args.columns, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'scannerOpenTs', seqid)
end
def process_scannerOpenWithStopTs(seqid, iprot, oprot)
args = read_args(iprot, ScannerOpenWithStopTs_args)
result = ScannerOpenWithStopTs_result.new()
begin
result.success = @handler.scannerOpenWithStopTs(args.tableName, args.startRow, args.stopRow, args.columns, args.timestamp, args.attributes)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'scannerOpenWithStopTs', seqid)
end
def process_scannerGet(seqid, iprot, oprot)
args = read_args(iprot, ScannerGet_args)
result = ScannerGet_result.new()
begin
result.success = @handler.scannerGet(args.id)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'scannerGet', seqid)
end
def process_scannerGetList(seqid, iprot, oprot)
args = read_args(iprot, ScannerGetList_args)
result = ScannerGetList_result.new()
begin
result.success = @handler.scannerGetList(args.id, args.nbRows)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'scannerGetList', seqid)
end
def process_scannerClose(seqid, iprot, oprot)
args = read_args(iprot, ScannerClose_args)
result = ScannerClose_result.new()
begin
@handler.scannerClose(args.id)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
rescue ::Apache::Hadoop::Hbase::Thrift::IllegalArgument => ia
result.ia = ia
end
write_result(result, oprot, 'scannerClose', seqid)
end
def process_getRowOrBefore(seqid, iprot, oprot)
args = read_args(iprot, GetRowOrBefore_args)
result = GetRowOrBefore_result.new()
begin
result.success = @handler.getRowOrBefore(args.tableName, args.row, args.family)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRowOrBefore', seqid)
end
def process_getRegionInfo(seqid, iprot, oprot)
args = read_args(iprot, GetRegionInfo_args)
result = GetRegionInfo_result.new()
begin
result.success = @handler.getRegionInfo(args.row)
rescue ::Apache::Hadoop::Hbase::Thrift::IOError => io
result.io = io
end
write_result(result, oprot, 'getRegionInfo', seqid)
end
end
# HELPER FUNCTIONS AND STRUCTURES
class EnableTable_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
FIELDS = {
# name of the table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class EnableTable_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DisableTable_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
FIELDS = {
# name of the table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DisableTable_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class IsTableEnabled_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
FIELDS = {
# name of the table to check
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class IsTableEnabled_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::BOOL, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class Compact_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAMEORREGIONNAME = 1
FIELDS = {
TABLENAMEORREGIONNAME => {:type => ::Thrift::Types::STRING, :name => 'tableNameOrRegionName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class Compact_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MajorCompact_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAMEORREGIONNAME = 1
FIELDS = {
TABLENAMEORREGIONNAME => {:type => ::Thrift::Types::STRING, :name => 'tableNameOrRegionName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MajorCompact_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetTableNames_args
include ::Thrift::Struct, ::Thrift::Struct_Union
FIELDS = {
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetTableNames_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetColumnDescriptors_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
FIELDS = {
# table name
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetColumnDescriptors_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::MAP, :name => 'success', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::ColumnDescriptor}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetTableRegions_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
FIELDS = {
# table name
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetTableRegions_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRegionInfo}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class CreateTable_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
COLUMNFAMILIES = 2
FIELDS = {
# name of table to create
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# list of column family descriptors
COLUMNFAMILIES => {:type => ::Thrift::Types::LIST, :name => 'columnFamilies', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::ColumnDescriptor}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class CreateTable_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
IA = 2
EXIST = 3
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument},
EXIST => {:type => ::Thrift::Types::STRUCT, :name => 'exist', :class => ::Apache::Hadoop::Hbase::Thrift::AlreadyExists}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteTable_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
FIELDS = {
# name of table to delete
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteTable_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class Get_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMN = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# column name
COLUMN => {:type => ::Thrift::Types::STRING, :name => 'column', :binary => true},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class Get_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TCell}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetVer_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMN = 3
NUMVERSIONS = 4
ATTRIBUTES = 5
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# column name
COLUMN => {:type => ::Thrift::Types::STRING, :name => 'column', :binary => true},
# number of versions to retrieve
NUMVERSIONS => {:type => ::Thrift::Types::I32, :name => 'numVersions'},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetVer_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TCell}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetVerTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMN = 3
TIMESTAMP = 4
NUMVERSIONS = 5
ATTRIBUTES = 6
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# column name
COLUMN => {:type => ::Thrift::Types::STRING, :name => 'column', :binary => true},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# number of versions to retrieve
NUMVERSIONS => {:type => ::Thrift::Types::I32, :name => 'numVersions'},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetVerTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TCell}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRow_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
ATTRIBUTES = 3
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRow_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowWithColumns_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMNS = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# List of columns to return, null for all columns
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowWithColumns_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
TIMESTAMP = 3
ATTRIBUTES = 4
FIELDS = {
# name of the table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowWithColumnsTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMNS = 3
TIMESTAMP = 4
ATTRIBUTES = 5
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# List of columns to return, null for all columns
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowWithColumnsTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRows_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROWS = 2
ATTRIBUTES = 3
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row keys
ROWS => {:type => ::Thrift::Types::LIST, :name => 'rows', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRows_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowsWithColumns_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROWS = 2
COLUMNS = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row keys
ROWS => {:type => ::Thrift::Types::LIST, :name => 'rows', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# List of columns to return, null for all columns
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowsWithColumns_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowsTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROWS = 2
TIMESTAMP = 3
ATTRIBUTES = 4
FIELDS = {
# name of the table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row keys
ROWS => {:type => ::Thrift::Types::LIST, :name => 'rows', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowsTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowsWithColumnsTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROWS = 2
COLUMNS = 3
TIMESTAMP = 4
ATTRIBUTES = 5
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row keys
ROWS => {:type => ::Thrift::Types::LIST, :name => 'rows', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# List of columns to return, null for all columns
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Get attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowsWithColumnsTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRow_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
MUTATIONS = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# list of mutation commands
MUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'mutations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::Mutation}},
# Mutation attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRow_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
IA = 2
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRowTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
MUTATIONS = 3
TIMESTAMP = 4
ATTRIBUTES = 5
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# list of mutation commands
MUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'mutations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::Mutation}},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Mutation attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRowTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
IA = 2
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRows_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROWBATCHES = 2
ATTRIBUTES = 3
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# list of row batches
ROWBATCHES => {:type => ::Thrift::Types::LIST, :name => 'rowBatches', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::BatchMutation}},
# Mutation attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRows_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
IA = 2
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRowsTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROWBATCHES = 2
TIMESTAMP = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# list of row batches
ROWBATCHES => {:type => ::Thrift::Types::LIST, :name => 'rowBatches', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::BatchMutation}},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Mutation attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class MutateRowsTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
IA = 2
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class AtomicIncrement_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMN = 3
VALUE = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row to increment
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# name of column
COLUMN => {:type => ::Thrift::Types::STRING, :name => 'column', :binary => true},
# amount to increment by
VALUE => {:type => ::Thrift::Types::I64, :name => 'value'}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class AtomicIncrement_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
IA = 2
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I64, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAll_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMN = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# Row to update
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# name of column whose value is to be deleted
COLUMN => {:type => ::Thrift::Types::STRING, :name => 'column', :binary => true},
# Delete attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAll_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAllTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
COLUMN = 3
TIMESTAMP = 4
ATTRIBUTES = 5
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# Row to update
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# name of column whose value is to be deleted
COLUMN => {:type => ::Thrift::Types::STRING, :name => 'column', :binary => true},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Delete attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAllTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAllRow_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
ATTRIBUTES = 3
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# key of the row to be completely deleted.
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# Delete attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAllRow_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class Increment_args
include ::Thrift::Struct, ::Thrift::Struct_Union
INCREMENT = 1
FIELDS = {
# The single increment to apply
INCREMENT => {:type => ::Thrift::Types::STRUCT, :name => 'increment', :class => ::Apache::Hadoop::Hbase::Thrift::TIncrement}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class Increment_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class IncrementRows_args
include ::Thrift::Struct, ::Thrift::Struct_Union
INCREMENTS = 1
FIELDS = {
# The list of increments
INCREMENTS => {:type => ::Thrift::Types::LIST, :name => 'increments', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TIncrement}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class IncrementRows_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAllRowTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
TIMESTAMP = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# key of the row to be completely deleted.
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Delete attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class DeleteAllRowTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithScan_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
SCAN = 2
ATTRIBUTES = 3
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# Scan instance
SCAN => {:type => ::Thrift::Types::STRUCT, :name => 'scan', :class => ::Apache::Hadoop::Hbase::Thrift::TScan},
# Scan attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithScan_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I32, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpen_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
STARTROW = 2
COLUMNS = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# Starting row in table to scan.
# Send "" (empty string) to start at the first row.
STARTROW => {:type => ::Thrift::Types::STRING, :name => 'startRow', :binary => true},
# columns to scan. If column name is a column family, all
# columns of the specified column family are returned. It's also possible
# to pass a regex in the column qualifier.
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# Scan attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpen_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I32, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithStop_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
STARTROW = 2
STOPROW = 3
COLUMNS = 4
ATTRIBUTES = 5
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# Starting row in table to scan.
# Send "" (empty string) to start at the first row.
STARTROW => {:type => ::Thrift::Types::STRING, :name => 'startRow', :binary => true},
# row to stop scanning on. This row is *not* included in the
# scanner's results
STOPROW => {:type => ::Thrift::Types::STRING, :name => 'stopRow', :binary => true},
# columns to scan. If column name is a column family, all
# columns of the specified column family are returned. It's also possible
# to pass a regex in the column qualifier.
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# Scan attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithStop_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I32, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithPrefix_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
STARTANDPREFIX = 2
COLUMNS = 3
ATTRIBUTES = 4
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# the prefix (and thus start row) of the keys you want
STARTANDPREFIX => {:type => ::Thrift::Types::STRING, :name => 'startAndPrefix', :binary => true},
# the columns you want returned
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# Scan attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithPrefix_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I32, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
STARTROW = 2
COLUMNS = 3
TIMESTAMP = 4
ATTRIBUTES = 5
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# Starting row in table to scan.
# Send "" (empty string) to start at the first row.
STARTROW => {:type => ::Thrift::Types::STRING, :name => 'startRow', :binary => true},
# columns to scan. If column name is a column family, all
# columns of the specified column family are returned. It's also possible
# to pass a regex in the column qualifier.
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Scan attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I32, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithStopTs_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
STARTROW = 2
STOPROW = 3
COLUMNS = 4
TIMESTAMP = 5
ATTRIBUTES = 6
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# Starting row in table to scan.
# Send "" (empty string) to start at the first row.
STARTROW => {:type => ::Thrift::Types::STRING, :name => 'startRow', :binary => true},
# row to stop scanning on. This row is *not* included in the
# scanner's results
STOPROW => {:type => ::Thrift::Types::STRING, :name => 'stopRow', :binary => true},
# columns to scan. If column name is a column family, all
# columns of the specified column family are returned. It's also possible
# to pass a regex in the column qualifier.
COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRING, :binary => true}},
# timestamp
TIMESTAMP => {:type => ::Thrift::Types::I64, :name => 'timestamp'},
# Scan attributes
ATTRIBUTES => {:type => ::Thrift::Types::MAP, :name => 'attributes', :key => {:type => ::Thrift::Types::STRING, :binary => true}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerOpenWithStopTs_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I32, :name => 'success'},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerGet_args
include ::Thrift::Struct, ::Thrift::Struct_Union
ID = 1
FIELDS = {
# id of a scanner returned by scannerOpen
ID => {:type => ::Thrift::Types::I32, :name => 'id'}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerGet_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
IA = 2
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerGetList_args
include ::Thrift::Struct, ::Thrift::Struct_Union
ID = 1
NBROWS = 2
FIELDS = {
# id of a scanner returned by scannerOpen
ID => {:type => ::Thrift::Types::I32, :name => 'id'},
# number of results to return
NBROWS => {:type => ::Thrift::Types::I32, :name => 'nbRows'}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerGetList_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
IA = 2
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TRowResult}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerClose_args
include ::Thrift::Struct, ::Thrift::Struct_Union
ID = 1
FIELDS = {
# id of a scanner returned by scannerOpen
ID => {:type => ::Thrift::Types::I32, :name => 'id'}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class ScannerClose_result
include ::Thrift::Struct, ::Thrift::Struct_Union
IO = 1
IA = 2
FIELDS = {
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError},
IA => {:type => ::Thrift::Types::STRUCT, :name => 'ia', :class => ::Apache::Hadoop::Hbase::Thrift::IllegalArgument}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowOrBefore_args
include ::Thrift::Struct, ::Thrift::Struct_Union
TABLENAME = 1
ROW = 2
FAMILY = 3
FIELDS = {
# name of table
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName', :binary => true},
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true},
# column name
FAMILY => {:type => ::Thrift::Types::STRING, :name => 'family', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRowOrBefore_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Apache::Hadoop::Hbase::Thrift::TCell}},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRegionInfo_args
include ::Thrift::Struct, ::Thrift::Struct_Union
ROW = 1
FIELDS = {
# row key
ROW => {:type => ::Thrift::Types::STRING, :name => 'row', :binary => true}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetRegionInfo_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
IO = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Apache::Hadoop::Hbase::Thrift::TRegionInfo},
IO => {:type => ::Thrift::Types::STRUCT, :name => 'io', :class => ::Apache::Hadoop::Hbase::Thrift::IOError}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
end
end
end
end
end