Class: OkHbase::Client

Inherits:
Apache::Hadoop::Hbase::Thrift::Hbase::Client show all
Defined in:
lib/ok_hbase/client.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Apache::Hadoop::Hbase::Thrift::Hbase::Client

#atomicIncrement, #compact, #createTable, #deleteAll, #deleteAllRow, #deleteAllRowTs, #deleteAllTs, #deleteTable, #disableTable, #enableTable, #get, #getColumnDescriptors, #getRow, #getRowTs, #getRowWithColumns, #getRowWithColumnsTs, #getRows, #getRowsTs, #getRowsWithColumns, #getRowsWithColumnsTs, #getTableNames, #getTableRegions, #getVer, #getVerTs, #isTableEnabled, #majorCompact, #mutateRow, #mutateRowTs, #mutateRows, #mutateRowsTs, #recv_atomicIncrement, #recv_compact, #recv_createTable, #recv_deleteAll, #recv_deleteAllRow, #recv_deleteAllRowTs, #recv_deleteAllTs, #recv_deleteTable, #recv_disableTable, #recv_enableTable, #recv_get, #recv_getColumnDescriptors, #recv_getRow, #recv_getRowTs, #recv_getRowWithColumns, #recv_getRowWithColumnsTs, #recv_getRows, #recv_getRowsTs, #recv_getRowsWithColumns, #recv_getRowsWithColumnsTs, #recv_getTableNames, #recv_getTableRegions, #recv_getVer, #recv_getVerTs, #recv_isTableEnabled, #recv_majorCompact, #recv_mutateRow, #recv_mutateRowTs, #recv_mutateRows, #recv_mutateRowsTs, #recv_scannerClose, #recv_scannerGet, #recv_scannerGetList, #recv_scannerOpen, #recv_scannerOpenTs, #recv_scannerOpenWithPrefix, #recv_scannerOpenWithScan, #recv_scannerOpenWithStop, #recv_scannerOpenWithStopTs, #scannerClose, #scannerGet, #scannerGetList, #scannerOpen, #scannerOpenTs, #scannerOpenWithPrefix, #scannerOpenWithScan, #scannerOpenWithStop, #scannerOpenWithStopTs, #send_atomicIncrement, #send_compact, #send_createTable, #send_deleteAll, #send_deleteAllRow, #send_deleteAllRowTs, #send_deleteAllTs, #send_deleteTable, #send_disableTable, #send_enableTable, #send_get, #send_getColumnDescriptors, #send_getRow, #send_getRowTs, #send_getRowWithColumns, #send_getRowWithColumnsTs, #send_getRows, #send_getRowsTs, #send_getRowsWithColumns, #send_getRowsWithColumnsTs, #send_getTableNames, #send_getTableRegions, #send_getVer, #send_getVerTs, #send_isTableEnabled, #send_majorCompact, #send_mutateRow, #send_mutateRowTs, #send_mutateRows, #send_mutateRowsTs, #send_scannerClose, #send_scannerGet, #send_scannerGetList, #send_scannerOpen, #send_scannerOpenTs, #send_scannerOpenWithPrefix, #send_scannerOpenWithScan, #send_scannerOpenWithStop, #send_scannerOpenWithStopTs

Constructor Details

#initialize(iprot, oprot = nil, max_tries = nil) ⇒ Client

Returns a new instance of Client.



14
15
16
17
 
# File 'lib/ok_hbase/client.rb', line 14

def initialize(iprot, oprot=nil, max_tries=nil)
  @max_tries = max_tries || 0
  super(iprot, oprot)
end

Instance Attribute Details

#max_tries ⇒ Object

Returns the value of attribute max_tries.



12
13
14
 
# File 'lib/ok_hbase/client.rb', line 12

def max_tries
  @max_tries
end

Instance Method Details

#recoverable?(e) ⇒ Boolean

Returns:

  • (Boolean) 


37
38
39
40
 
# File 'lib/ok_hbase/client.rb', line 37

def recoverable?(e)
  e.is_a?(Apache::Hadoop::Hbase::Thrift::IOError) ||
      e.is_a?(Thrift::TransportException)
end