Class: HbaseClient::Thrift::Hbase::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/hbase-client/thrift/hbase.rb

Instance Method Summary collapse

Instance Method Details

#append(append) ⇒ Object 



697
698
699
700
 
# File 'lib/hbase-client/thrift/hbase.rb', line 697

def append(append)
  send_append(append)
  return recv_append()
end

#atomicIncrement(tableName, row, column, value) ⇒ Object 



412
413
414
415
 
# File 'lib/hbase-client/thrift/hbase.rb', line 412

def atomicIncrement(tableName, row, column, value)
  send_atomicIncrement(tableName, row, column, value)
  return recv_atomicIncrement()
end

#checkAndPut(tableName, row, column, value, mput, attributes) ⇒ Object 



713
714
715
716
 
# File 'lib/hbase-client/thrift/hbase.rb', line 713

def checkAndPut(tableName, row, column, value, mput, attributes)
  send_checkAndPut(tableName, row, column, value, mput, attributes)
  return recv_checkAndPut()
end

#compact(tableNameOrRegionName) ⇒ Object 



62
63
64
65
 
# File 'lib/hbase-client/thrift/hbase.rb', line 62

def compact(tableNameOrRegionName)
  send_compact(tableNameOrRegionName)
  recv_compact()
end

#createTable(tableName, columnFamilies) ⇒ Object 



140
141
142
143
 
# File 'lib/hbase-client/thrift/hbase.rb', line 140

def createTable(tableName, columnFamilies)
  send_createTable(tableName, columnFamilies)
  recv_createTable()
end

#deleteAll(tableName, row, column, attributes) ⇒ Object 



429
430
431
432
 
# File 'lib/hbase-client/thrift/hbase.rb', line 429

def deleteAll(tableName, row, column, attributes)
  send_deleteAll(tableName, row, column, attributes)
  recv_deleteAll()
end

#deleteAllRow(tableName, row, attributes) ⇒ Object 



459
460
461
462
 
# File 'lib/hbase-client/thrift/hbase.rb', line 459

def deleteAllRow(tableName, row, attributes)
  send_deleteAllRow(tableName, row, attributes)
  recv_deleteAllRow()
end

#deleteAllRowTs(tableName, row, timestamp, attributes) ⇒ Object 



504
505
506
507
 
# File 'lib/hbase-client/thrift/hbase.rb', line 504

def deleteAllRowTs(tableName, row, timestamp, attributes)
  send_deleteAllRowTs(tableName, row, timestamp, attributes)
  recv_deleteAllRowTs()
end

#deleteAllTs(tableName, row, column, timestamp, attributes) ⇒ Object 



444
445
446
447
 
# File 'lib/hbase-client/thrift/hbase.rb', line 444

def deleteAllTs(tableName, row, column, timestamp, attributes)
  send_deleteAllTs(tableName, row, column, timestamp, attributes)
  recv_deleteAllTs()
end

#deleteTable(tableName) ⇒ Object 



157
158
159
160
 
# File 'lib/hbase-client/thrift/hbase.rb', line 157

def deleteTable(tableName)
  send_deleteTable(tableName)
  recv_deleteTable()
end

#disableTable(tableName) ⇒ Object 



31
32
33
34
 
# File 'lib/hbase-client/thrift/hbase.rb', line 31

def disableTable(tableName)
  send_disableTable(tableName)
  recv_disableTable()
end

#enableTable(tableName) ⇒ Object 



16
17
18
19
 
# File 'lib/hbase-client/thrift/hbase.rb', line 16

def enableTable(tableName)
  send_enableTable(tableName)
  recv_enableTable()
end

#get(tableName, row, column, attributes) ⇒ Object 



172
173
174
175
 
# File 'lib/hbase-client/thrift/hbase.rb', line 172

def get(tableName, row, column, attributes)
  send_get(tableName, row, column, attributes)
  return recv_get()
end

#getColumnDescriptors(tableName) ⇒ Object 



108
109
110
111
 
# File 'lib/hbase-client/thrift/hbase.rb', line 108

def getColumnDescriptors(tableName)
  send_getColumnDescriptors(tableName)
  return recv_getColumnDescriptors()
end

#getRegionInfo(row) ⇒ Object 



681
682
683
684
 
# File 'lib/hbase-client/thrift/hbase.rb', line 681

def getRegionInfo(row)
  send_getRegionInfo(row)
  return recv_getRegionInfo()
end

#getRow(tableName, row, attributes) ⇒ Object 



220
221
222
223
 
# File 'lib/hbase-client/thrift/hbase.rb', line 220

def getRow(tableName, row, attributes)
  send_getRow(tableName, row, attributes)
  return recv_getRow()
end

#getRowOrBefore(tableName, row, family) ⇒ Object 



665
666
667
668
 
# File 'lib/hbase-client/thrift/hbase.rb', line 665

def getRowOrBefore(tableName, row, family)
  send_getRowOrBefore(tableName, row, family)
  return recv_getRowOrBefore()
end

#getRows(tableName, rows, attributes) ⇒ Object 



284
285
286
287
 
# File 'lib/hbase-client/thrift/hbase.rb', line 284

def getRows(tableName, rows, attributes)
  send_getRows(tableName, rows, attributes)
  return recv_getRows()
end

#getRowsTs(tableName, rows, timestamp, attributes) ⇒ Object 



316
317
318
319
 
# File 'lib/hbase-client/thrift/hbase.rb', line 316

def getRowsTs(tableName, rows, timestamp, attributes)
  send_getRowsTs(tableName, rows, timestamp, attributes)
  return recv_getRowsTs()
end

#getRowsWithColumns(tableName, rows, columns, attributes) ⇒ Object 



300
301
302
303
 
# File 'lib/hbase-client/thrift/hbase.rb', line 300

def getRowsWithColumns(tableName, rows, columns, attributes)
  send_getRowsWithColumns(tableName, rows, columns, attributes)
  return recv_getRowsWithColumns()
end

#getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes) ⇒ Object 



332
333
334
335
 
# File 'lib/hbase-client/thrift/hbase.rb', line 332

def getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes)
  send_getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes)
  return recv_getRowsWithColumnsTs()
end

#getRowTs(tableName, row, timestamp, attributes) ⇒ Object 



252
253
254
255
 
# File 'lib/hbase-client/thrift/hbase.rb', line 252

def getRowTs(tableName, row, timestamp, attributes)
  send_getRowTs(tableName, row, timestamp, attributes)
  return recv_getRowTs()
end

#getRowWithColumns(tableName, row, columns, attributes) ⇒ Object 



236
237
238
239
 
# File 'lib/hbase-client/thrift/hbase.rb', line 236

def getRowWithColumns(tableName, row, columns, attributes)
  send_getRowWithColumns(tableName, row, columns, attributes)
  return recv_getRowWithColumns()
end

#getRowWithColumnsTs(tableName, row, columns, timestamp, attributes) ⇒ Object 



268
269
270
271
 
# File 'lib/hbase-client/thrift/hbase.rb', line 268

def getRowWithColumnsTs(tableName, row, columns, timestamp, attributes)
  send_getRowWithColumnsTs(tableName, row, columns, timestamp, attributes)
  return recv_getRowWithColumnsTs()
end

#getTableNames ⇒ Object 



92
93
94
95
 
# File 'lib/hbase-client/thrift/hbase.rb', line 92

def getTableNames()
  send_getTableNames()
  return recv_getTableNames()
end

#getTableRegions(tableName) ⇒ Object 



124
125
126
127
 
# File 'lib/hbase-client/thrift/hbase.rb', line 124

def getTableRegions(tableName)
  send_getTableRegions(tableName)
  return recv_getTableRegions()
end

#getVer(tableName, row, column, numVersions, attributes) ⇒ Object 



188
189
190
191
 
# File 'lib/hbase-client/thrift/hbase.rb', line 188

def getVer(tableName, row, column, numVersions, attributes)
  send_getVer(tableName, row, column, numVersions, attributes)
  return recv_getVer()
end

#getVerTs(tableName, row, column, timestamp, numVersions, attributes) ⇒ Object 



204
205
206
207
 
# File 'lib/hbase-client/thrift/hbase.rb', line 204

def getVerTs(tableName, row, column, timestamp, numVersions, attributes)
  send_getVerTs(tableName, row, column, timestamp, numVersions, attributes)
  return recv_getVerTs()
end

#increment(increment) ⇒ Object 



474
475
476
477
 
# File 'lib/hbase-client/thrift/hbase.rb', line 474

def increment(increment)
  send_increment(increment)
  recv_increment()
end

#incrementRows(increments) ⇒ Object 



489
490
491
492
 
# File 'lib/hbase-client/thrift/hbase.rb', line 489

def incrementRows(increments)
  send_incrementRows(increments)
  recv_incrementRows()
end

#isTableEnabled(tableName) ⇒ Object 



46
47
48
49
 
# File 'lib/hbase-client/thrift/hbase.rb', line 46

def isTableEnabled(tableName)
  send_isTableEnabled(tableName)
  return recv_isTableEnabled()
end

#majorCompact(tableNameOrRegionName) ⇒ Object 



77
78
79
80
 
# File 'lib/hbase-client/thrift/hbase.rb', line 77

def majorCompact(tableNameOrRegionName)
  send_majorCompact(tableNameOrRegionName)
  recv_majorCompact()
end

#mutateRow(tableName, row, mutations, attributes) ⇒ Object 



348
349
350
351
 
# File 'lib/hbase-client/thrift/hbase.rb', line 348

def mutateRow(tableName, row, mutations, attributes)
  send_mutateRow(tableName, row, mutations, attributes)
  recv_mutateRow()
end

#mutateRows(tableName, rowBatches, attributes) ⇒ Object 



380
381
382
383
 
# File 'lib/hbase-client/thrift/hbase.rb', line 380

def mutateRows(tableName, rowBatches, attributes)
  send_mutateRows(tableName, rowBatches, attributes)
  recv_mutateRows()
end

#mutateRowsTs(tableName, rowBatches, timestamp, attributes) ⇒ Object 



396
397
398
399
 
# File 'lib/hbase-client/thrift/hbase.rb', line 396

def mutateRowsTs(tableName, rowBatches, timestamp, attributes)
  send_mutateRowsTs(tableName, rowBatches, timestamp, attributes)
  recv_mutateRowsTs()
end

#mutateRowTs(tableName, row, mutations, timestamp, attributes) ⇒ Object 



364
365
366
367
 
# File 'lib/hbase-client/thrift/hbase.rb', line 364

def mutateRowTs(tableName, row, mutations, timestamp, attributes)
  send_mutateRowTs(tableName, row, mutations, timestamp, attributes)
  recv_mutateRowTs()
end

#recv_append ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


706
707
708
709
710
711
 
# File 'lib/hbase-client/thrift/hbase.rb', line 706

def recv_append()
  result = receive_message(Append_result)
  return result.success unless result.success.nil?
  raise result.io unless result.io.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'append failed: unknown result')
end

#recv_atomicIncrement ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


421
422
423
424
425
426
427
 
# File 'lib/hbase-client/thrift/hbase.rb', line 421

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

#recv_checkAndPut ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


722
723
724
725
726
727
728
 
# File 'lib/hbase-client/thrift/hbase.rb', line 722

def recv_checkAndPut()
  result = receive_message(CheckAndPut_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, 'checkAndPut failed: unknown result')
end

#recv_compact ⇒ Object 



71
72
73
74
75
 
# File 'lib/hbase-client/thrift/hbase.rb', line 71

def recv_compact()
  result = receive_message(Compact_result)
  raise result.io unless result.io.nil?
  return
end

#recv_createTable ⇒ Object 



149
150
151
152
153
154
155
 
# File 'lib/hbase-client/thrift/hbase.rb', line 149

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

#recv_deleteAll ⇒ Object 



438
439
440
441
442
 
# File 'lib/hbase-client/thrift/hbase.rb', line 438

def recv_deleteAll()
  result = receive_message(DeleteAll_result)
  raise result.io unless result.io.nil?
  return
end

#recv_deleteAllRow ⇒ Object 



468
469
470
471
472
 
# File 'lib/hbase-client/thrift/hbase.rb', line 468

def recv_deleteAllRow()
  result = receive_message(DeleteAllRow_result)
  raise result.io unless result.io.nil?
  return
end

#recv_deleteAllRowTs ⇒ Object 



513
514
515
516
517
 
# File 'lib/hbase-client/thrift/hbase.rb', line 513

def recv_deleteAllRowTs()
  result = receive_message(DeleteAllRowTs_result)
  raise result.io unless result.io.nil?
  return
end

#recv_deleteAllTs ⇒ Object 



453
454
455
456
457
 
# File 'lib/hbase-client/thrift/hbase.rb', line 453

def recv_deleteAllTs()
  result = receive_message(DeleteAllTs_result)
  raise result.io unless result.io.nil?
  return
end

#recv_deleteTable ⇒ Object 



166
167
168
169
170
 
# File 'lib/hbase-client/thrift/hbase.rb', line 166

def recv_deleteTable()
  result = receive_message(DeleteTable_result)
  raise result.io unless result.io.nil?
  return
end

#recv_disableTable ⇒ Object 



40
41
42
43
44
 
# File 'lib/hbase-client/thrift/hbase.rb', line 40

def recv_disableTable()
  result = receive_message(DisableTable_result)
  raise result.io unless result.io.nil?
  return
end

#recv_enableTable ⇒ Object 



25
26
27
28
29
 
# File 'lib/hbase-client/thrift/hbase.rb', line 25

def recv_enableTable()
  result = receive_message(EnableTable_result)
  raise result.io unless result.io.nil?
  return
end

#recv_get ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


181
182
183
184
185
186
 
# File 'lib/hbase-client/thrift/hbase.rb', line 181

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

#recv_getColumnDescriptors ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


117
118
119
120
121
122
 
# File 'lib/hbase-client/thrift/hbase.rb', line 117

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

#recv_getRegionInfo ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


690
691
692
693
694
695
 
# File 'lib/hbase-client/thrift/hbase.rb', line 690

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

#recv_getRow ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


229
230
231
232
233
234
 
# File 'lib/hbase-client/thrift/hbase.rb', line 229

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

#recv_getRowOrBefore ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


674
675
676
677
678
679
 
# File 'lib/hbase-client/thrift/hbase.rb', line 674

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

#recv_getRows ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


293
294
295
296
297
298
 
# File 'lib/hbase-client/thrift/hbase.rb', line 293

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

#recv_getRowsTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


325
326
327
328
329
330
 
# File 'lib/hbase-client/thrift/hbase.rb', line 325

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

#recv_getRowsWithColumns ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


309
310
311
312
313
314
 
# File 'lib/hbase-client/thrift/hbase.rb', line 309

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

#recv_getRowsWithColumnsTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


341
342
343
344
345
346
 
# File 'lib/hbase-client/thrift/hbase.rb', line 341

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

#recv_getRowTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


261
262
263
264
265
266
 
# File 'lib/hbase-client/thrift/hbase.rb', line 261

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

#recv_getRowWithColumns ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


245
246
247
248
249
250
 
# File 'lib/hbase-client/thrift/hbase.rb', line 245

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

#recv_getRowWithColumnsTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


277
278
279
280
281
282
 
# File 'lib/hbase-client/thrift/hbase.rb', line 277

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

#recv_getTableNames ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


101
102
103
104
105
106
 
# File 'lib/hbase-client/thrift/hbase.rb', line 101

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

#recv_getTableRegions ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


133
134
135
136
137
138
 
# File 'lib/hbase-client/thrift/hbase.rb', line 133

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

#recv_getVer ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


197
198
199
200
201
202
 
# File 'lib/hbase-client/thrift/hbase.rb', line 197

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

#recv_getVerTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


213
214
215
216
217
218
 
# File 'lib/hbase-client/thrift/hbase.rb', line 213

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

#recv_increment ⇒ Object 



483
484
485
486
487
 
# File 'lib/hbase-client/thrift/hbase.rb', line 483

def recv_increment()
  result = receive_message(Increment_result)
  raise result.io unless result.io.nil?
  return
end

#recv_incrementRows ⇒ Object 



498
499
500
501
502
 
# File 'lib/hbase-client/thrift/hbase.rb', line 498

def recv_incrementRows()
  result = receive_message(IncrementRows_result)
  raise result.io unless result.io.nil?
  return
end

#recv_isTableEnabled ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


55
56
57
58
59
60
 
# File 'lib/hbase-client/thrift/hbase.rb', line 55

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

#recv_majorCompact ⇒ Object 



86
87
88
89
90
 
# File 'lib/hbase-client/thrift/hbase.rb', line 86

def recv_majorCompact()
  result = receive_message(MajorCompact_result)
  raise result.io unless result.io.nil?
  return
end

#recv_mutateRow ⇒ Object 



357
358
359
360
361
362
 
# File 'lib/hbase-client/thrift/hbase.rb', line 357

def recv_mutateRow()
  result = receive_message(MutateRow_result)
  raise result.io unless result.io.nil?
  raise result.ia unless result.ia.nil?
  return
end

#recv_mutateRows ⇒ Object 



389
390
391
392
393
394
 
# File 'lib/hbase-client/thrift/hbase.rb', line 389

def recv_mutateRows()
  result = receive_message(MutateRows_result)
  raise result.io unless result.io.nil?
  raise result.ia unless result.ia.nil?
  return
end

#recv_mutateRowsTs ⇒ Object 



405
406
407
408
409
410
 
# File 'lib/hbase-client/thrift/hbase.rb', line 405

def recv_mutateRowsTs()
  result = receive_message(MutateRowsTs_result)
  raise result.io unless result.io.nil?
  raise result.ia unless result.ia.nil?
  return
end

#recv_mutateRowTs ⇒ Object 



373
374
375
376
377
378
 
# File 'lib/hbase-client/thrift/hbase.rb', line 373

def recv_mutateRowTs()
  result = receive_message(MutateRowTs_result)
  raise result.io unless result.io.nil?
  raise result.ia unless result.ia.nil?
  return
end

#recv_scannerClose ⇒ Object 



658
659
660
661
662
663
 
# File 'lib/hbase-client/thrift/hbase.rb', line 658

def recv_scannerClose()
  result = receive_message(ScannerClose_result)
  raise result.io unless result.io.nil?
  raise result.ia unless result.ia.nil?
  return
end

#recv_scannerGet ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


624
625
626
627
628
629
630
 
# File 'lib/hbase-client/thrift/hbase.rb', line 624

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

#recv_scannerGetList ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


641
642
643
644
645
646
647
 
# File 'lib/hbase-client/thrift/hbase.rb', line 641

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

#recv_scannerOpen ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


544
545
546
547
548
549
 
# File 'lib/hbase-client/thrift/hbase.rb', line 544

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

#recv_scannerOpenTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


592
593
594
595
596
597
 
# File 'lib/hbase-client/thrift/hbase.rb', line 592

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

#recv_scannerOpenWithPrefix ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


576
577
578
579
580
581
 
# File 'lib/hbase-client/thrift/hbase.rb', line 576

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

#recv_scannerOpenWithScan ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


528
529
530
531
532
533
 
# File 'lib/hbase-client/thrift/hbase.rb', line 528

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

#recv_scannerOpenWithStop ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


560
561
562
563
564
565
 
# File 'lib/hbase-client/thrift/hbase.rb', line 560

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

#recv_scannerOpenWithStopTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


608
609
610
611
612
613
 
# File 'lib/hbase-client/thrift/hbase.rb', line 608

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

#scannerClose(id) ⇒ Object 



649
650
651
652
 
# File 'lib/hbase-client/thrift/hbase.rb', line 649

def scannerClose(id)
  send_scannerClose(id)
  recv_scannerClose()
end

#scannerGet(id) ⇒ Object 



615
616
617
618
 
# File 'lib/hbase-client/thrift/hbase.rb', line 615

def scannerGet(id)
  send_scannerGet(id)
  return recv_scannerGet()
end

#scannerGetList(id, nbRows) ⇒ Object 



632
633
634
635
 
# File 'lib/hbase-client/thrift/hbase.rb', line 632

def scannerGetList(id, nbRows)
  send_scannerGetList(id, nbRows)
  return recv_scannerGetList()
end

#scannerOpen(tableName, startRow, columns, attributes) ⇒ Object 



535
536
537
538
 
# File 'lib/hbase-client/thrift/hbase.rb', line 535

def scannerOpen(tableName, startRow, columns, attributes)
  send_scannerOpen(tableName, startRow, columns, attributes)
  return recv_scannerOpen()
end

#scannerOpenTs(tableName, startRow, columns, timestamp, attributes) ⇒ Object 



583
584
585
586
 
# File 'lib/hbase-client/thrift/hbase.rb', line 583

def scannerOpenTs(tableName, startRow, columns, timestamp, attributes)
  send_scannerOpenTs(tableName, startRow, columns, timestamp, attributes)
  return recv_scannerOpenTs()
end

#scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes) ⇒ Object 



567
568
569
570
 
# File 'lib/hbase-client/thrift/hbase.rb', line 567

def scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes)
  send_scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes)
  return recv_scannerOpenWithPrefix()
end

#scannerOpenWithScan(tableName, scan, attributes) ⇒ Object 



519
520
521
522
 
# File 'lib/hbase-client/thrift/hbase.rb', line 519

def scannerOpenWithScan(tableName, scan, attributes)
  send_scannerOpenWithScan(tableName, scan, attributes)
  return recv_scannerOpenWithScan()
end

#scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes) ⇒ Object 



551
552
553
554
 
# File 'lib/hbase-client/thrift/hbase.rb', line 551

def scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes)
  send_scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes)
  return recv_scannerOpenWithStop()
end

#scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes) ⇒ Object 



599
600
601
602
 
# File 'lib/hbase-client/thrift/hbase.rb', line 599

def scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes)
  send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes)
  return recv_scannerOpenWithStopTs()
end

#send_append(append) ⇒ Object 



702
703
704
 
# File 'lib/hbase-client/thrift/hbase.rb', line 702

def send_append(append)
  send_message('append', Append_args, :append => append)
end

#send_atomicIncrement(tableName, row, column, value) ⇒ Object 



417
418
419
 
# File 'lib/hbase-client/thrift/hbase.rb', line 417

def send_atomicIncrement(tableName, row, column, value)
  send_message('atomicIncrement', AtomicIncrement_args, :tableName => tableName, :row => row, :column => column, :value => value)
end

#send_checkAndPut(tableName, row, column, value, mput, attributes) ⇒ Object 



718
719
720
 
# File 'lib/hbase-client/thrift/hbase.rb', line 718

def send_checkAndPut(tableName, row, column, value, mput, attributes)
  send_message('checkAndPut', CheckAndPut_args, :tableName => tableName, :row => row, :column => column, :value => value, :mput => mput, :attributes => attributes)
end

#send_compact(tableNameOrRegionName) ⇒ Object 



67
68
69
 
# File 'lib/hbase-client/thrift/hbase.rb', line 67

def send_compact(tableNameOrRegionName)
  send_message('compact', Compact_args, :tableNameOrRegionName => tableNameOrRegionName)
end

#send_createTable(tableName, columnFamilies) ⇒ Object 



145
146
147
 
# File 'lib/hbase-client/thrift/hbase.rb', line 145

def send_createTable(tableName, columnFamilies)
  send_message('createTable', CreateTable_args, :tableName => tableName, :columnFamilies => columnFamilies)
end

#send_deleteAll(tableName, row, column, attributes) ⇒ Object 



434
435
436
 
# File 'lib/hbase-client/thrift/hbase.rb', line 434

def send_deleteAll(tableName, row, column, attributes)
  send_message('deleteAll', DeleteAll_args, :tableName => tableName, :row => row, :column => column, :attributes => attributes)
end

#send_deleteAllRow(tableName, row, attributes) ⇒ Object 



464
465
466
 
# File 'lib/hbase-client/thrift/hbase.rb', line 464

def send_deleteAllRow(tableName, row, attributes)
  send_message('deleteAllRow', DeleteAllRow_args, :tableName => tableName, :row => row, :attributes => attributes)
end

#send_deleteAllRowTs(tableName, row, timestamp, attributes) ⇒ Object 



509
510
511
 
# File 'lib/hbase-client/thrift/hbase.rb', line 509

def send_deleteAllRowTs(tableName, row, timestamp, attributes)
  send_message('deleteAllRowTs', DeleteAllRowTs_args, :tableName => tableName, :row => row, :timestamp => timestamp, :attributes => attributes)
end

#send_deleteAllTs(tableName, row, column, timestamp, attributes) ⇒ Object 



449
450
451
 
# File 'lib/hbase-client/thrift/hbase.rb', line 449

def send_deleteAllTs(tableName, row, column, timestamp, attributes)
  send_message('deleteAllTs', DeleteAllTs_args, :tableName => tableName, :row => row, :column => column, :timestamp => timestamp, :attributes => attributes)
end

#send_deleteTable(tableName) ⇒ Object 



162
163
164
 
# File 'lib/hbase-client/thrift/hbase.rb', line 162

def send_deleteTable(tableName)
  send_message('deleteTable', DeleteTable_args, :tableName => tableName)
end

#send_disableTable(tableName) ⇒ Object 



36
37
38
 
# File 'lib/hbase-client/thrift/hbase.rb', line 36

def send_disableTable(tableName)
  send_message('disableTable', DisableTable_args, :tableName => tableName)
end

#send_enableTable(tableName) ⇒ Object 



21
22
23
 
# File 'lib/hbase-client/thrift/hbase.rb', line 21

def send_enableTable(tableName)
  send_message('enableTable', EnableTable_args, :tableName => tableName)
end

#send_get(tableName, row, column, attributes) ⇒ Object 



177
178
179
 
# File 'lib/hbase-client/thrift/hbase.rb', line 177

def send_get(tableName, row, column, attributes)
  send_message('get', Get_args, :tableName => tableName, :row => row, :column => column, :attributes => attributes)
end

#send_getColumnDescriptors(tableName) ⇒ Object 



113
114
115
 
# File 'lib/hbase-client/thrift/hbase.rb', line 113

def send_getColumnDescriptors(tableName)
  send_message('getColumnDescriptors', GetColumnDescriptors_args, :tableName => tableName)
end

#send_getRegionInfo(row) ⇒ Object 



686
687
688
 
# File 'lib/hbase-client/thrift/hbase.rb', line 686

def send_getRegionInfo(row)
  send_message('getRegionInfo', GetRegionInfo_args, :row => row)
end

#send_getRow(tableName, row, attributes) ⇒ Object 



225
226
227
 
# File 'lib/hbase-client/thrift/hbase.rb', line 225

def send_getRow(tableName, row, attributes)
  send_message('getRow', GetRow_args, :tableName => tableName, :row => row, :attributes => attributes)
end

#send_getRowOrBefore(tableName, row, family) ⇒ Object 



670
671
672
 
# File 'lib/hbase-client/thrift/hbase.rb', line 670

def send_getRowOrBefore(tableName, row, family)
  send_message('getRowOrBefore', GetRowOrBefore_args, :tableName => tableName, :row => row, :family => family)
end

#send_getRows(tableName, rows, attributes) ⇒ Object 



289
290
291
 
# File 'lib/hbase-client/thrift/hbase.rb', line 289

def send_getRows(tableName, rows, attributes)
  send_message('getRows', GetRows_args, :tableName => tableName, :rows => rows, :attributes => attributes)
end

#send_getRowsTs(tableName, rows, timestamp, attributes) ⇒ Object 



321
322
323
 
# File 'lib/hbase-client/thrift/hbase.rb', line 321

def send_getRowsTs(tableName, rows, timestamp, attributes)
  send_message('getRowsTs', GetRowsTs_args, :tableName => tableName, :rows => rows, :timestamp => timestamp, :attributes => attributes)
end

#send_getRowsWithColumns(tableName, rows, columns, attributes) ⇒ Object 



305
306
307
 
# File 'lib/hbase-client/thrift/hbase.rb', line 305

def send_getRowsWithColumns(tableName, rows, columns, attributes)
  send_message('getRowsWithColumns', GetRowsWithColumns_args, :tableName => tableName, :rows => rows, :columns => columns, :attributes => attributes)
end

#send_getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes) ⇒ Object 



337
338
339
 
# File 'lib/hbase-client/thrift/hbase.rb', line 337

def send_getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes)
  send_message('getRowsWithColumnsTs', GetRowsWithColumnsTs_args, :tableName => tableName, :rows => rows, :columns => columns, :timestamp => timestamp, :attributes => attributes)
end

#send_getRowTs(tableName, row, timestamp, attributes) ⇒ Object 



257
258
259
 
# File 'lib/hbase-client/thrift/hbase.rb', line 257

def send_getRowTs(tableName, row, timestamp, attributes)
  send_message('getRowTs', GetRowTs_args, :tableName => tableName, :row => row, :timestamp => timestamp, :attributes => attributes)
end

#send_getRowWithColumns(tableName, row, columns, attributes) ⇒ Object 



241
242
243
 
# File 'lib/hbase-client/thrift/hbase.rb', line 241

def send_getRowWithColumns(tableName, row, columns, attributes)
  send_message('getRowWithColumns', GetRowWithColumns_args, :tableName => tableName, :row => row, :columns => columns, :attributes => attributes)
end

#send_getRowWithColumnsTs(tableName, row, columns, timestamp, attributes) ⇒ Object 



273
274
275
 
# File 'lib/hbase-client/thrift/hbase.rb', line 273

def send_getRowWithColumnsTs(tableName, row, columns, timestamp, attributes)
  send_message('getRowWithColumnsTs', GetRowWithColumnsTs_args, :tableName => tableName, :row => row, :columns => columns, :timestamp => timestamp, :attributes => attributes)
end

#send_getTableNames ⇒ Object 



97
98
99
 
# File 'lib/hbase-client/thrift/hbase.rb', line 97

def send_getTableNames()
  send_message('getTableNames', GetTableNames_args)
end

#send_getTableRegions(tableName) ⇒ Object 



129
130
131
 
# File 'lib/hbase-client/thrift/hbase.rb', line 129

def send_getTableRegions(tableName)
  send_message('getTableRegions', GetTableRegions_args, :tableName => tableName)
end

#send_getVer(tableName, row, column, numVersions, attributes) ⇒ Object 



193
194
195
 
# File 'lib/hbase-client/thrift/hbase.rb', line 193

def send_getVer(tableName, row, column, numVersions, attributes)
  send_message('getVer', GetVer_args, :tableName => tableName, :row => row, :column => column, :numVersions => numVersions, :attributes => attributes)
end

#send_getVerTs(tableName, row, column, timestamp, numVersions, attributes) ⇒ Object 



209
210
211
 
# File 'lib/hbase-client/thrift/hbase.rb', line 209

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

#send_increment(increment) ⇒ Object 



479
480
481
 
# File 'lib/hbase-client/thrift/hbase.rb', line 479

def send_increment(increment)
  send_message('increment', Increment_args, :increment => increment)
end

#send_incrementRows(increments) ⇒ Object 



494
495
496
 
# File 'lib/hbase-client/thrift/hbase.rb', line 494

def send_incrementRows(increments)
  send_message('incrementRows', IncrementRows_args, :increments => increments)
end

#send_isTableEnabled(tableName) ⇒ Object 



51
52
53
 
# File 'lib/hbase-client/thrift/hbase.rb', line 51

def send_isTableEnabled(tableName)
  send_message('isTableEnabled', IsTableEnabled_args, :tableName => tableName)
end

#send_majorCompact(tableNameOrRegionName) ⇒ Object 



82
83
84
 
# File 'lib/hbase-client/thrift/hbase.rb', line 82

def send_majorCompact(tableNameOrRegionName)
  send_message('majorCompact', MajorCompact_args, :tableNameOrRegionName => tableNameOrRegionName)
end

#send_mutateRow(tableName, row, mutations, attributes) ⇒ Object 



353
354
355
 
# File 'lib/hbase-client/thrift/hbase.rb', line 353

def send_mutateRow(tableName, row, mutations, attributes)
  send_message('mutateRow', MutateRow_args, :tableName => tableName, :row => row, :mutations => mutations, :attributes => attributes)
end

#send_mutateRows(tableName, rowBatches, attributes) ⇒ Object 



385
386
387
 
# File 'lib/hbase-client/thrift/hbase.rb', line 385

def send_mutateRows(tableName, rowBatches, attributes)
  send_message('mutateRows', MutateRows_args, :tableName => tableName, :rowBatches => rowBatches, :attributes => attributes)
end

#send_mutateRowsTs(tableName, rowBatches, timestamp, attributes) ⇒ Object 



401
402
403
 
# File 'lib/hbase-client/thrift/hbase.rb', line 401

def send_mutateRowsTs(tableName, rowBatches, timestamp, attributes)
  send_message('mutateRowsTs', MutateRowsTs_args, :tableName => tableName, :rowBatches => rowBatches, :timestamp => timestamp, :attributes => attributes)
end

#send_mutateRowTs(tableName, row, mutations, timestamp, attributes) ⇒ Object 



369
370
371
 
# File 'lib/hbase-client/thrift/hbase.rb', line 369

def send_mutateRowTs(tableName, row, mutations, timestamp, attributes)
  send_message('mutateRowTs', MutateRowTs_args, :tableName => tableName, :row => row, :mutations => mutations, :timestamp => timestamp, :attributes => attributes)
end

#send_scannerClose(id) ⇒ Object 



654
655
656
 
# File 'lib/hbase-client/thrift/hbase.rb', line 654

def send_scannerClose(id)
  send_message('scannerClose', ScannerClose_args, :id => id)
end

#send_scannerGet(id) ⇒ Object 



620
621
622
 
# File 'lib/hbase-client/thrift/hbase.rb', line 620

def send_scannerGet(id)
  send_message('scannerGet', ScannerGet_args, :id => id)
end

#send_scannerGetList(id, nbRows) ⇒ Object 



637
638
639
 
# File 'lib/hbase-client/thrift/hbase.rb', line 637

def send_scannerGetList(id, nbRows)
  send_message('scannerGetList', ScannerGetList_args, :id => id, :nbRows => nbRows)
end

#send_scannerOpen(tableName, startRow, columns, attributes) ⇒ Object 



540
541
542
 
# File 'lib/hbase-client/thrift/hbase.rb', line 540

def send_scannerOpen(tableName, startRow, columns, attributes)
  send_message('scannerOpen', ScannerOpen_args, :tableName => tableName, :startRow => startRow, :columns => columns, :attributes => attributes)
end

#send_scannerOpenTs(tableName, startRow, columns, timestamp, attributes) ⇒ Object 



588
589
590
 
# File 'lib/hbase-client/thrift/hbase.rb', line 588

def send_scannerOpenTs(tableName, startRow, columns, timestamp, attributes)
  send_message('scannerOpenTs', ScannerOpenTs_args, :tableName => tableName, :startRow => startRow, :columns => columns, :timestamp => timestamp, :attributes => attributes)
end

#send_scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes) ⇒ Object 



572
573
574
 
# File 'lib/hbase-client/thrift/hbase.rb', line 572

def send_scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes)
  send_message('scannerOpenWithPrefix', ScannerOpenWithPrefix_args, :tableName => tableName, :startAndPrefix => startAndPrefix, :columns => columns, :attributes => attributes)
end

#send_scannerOpenWithScan(tableName, scan, attributes) ⇒ Object 



524
525
526
 
# File 'lib/hbase-client/thrift/hbase.rb', line 524

def send_scannerOpenWithScan(tableName, scan, attributes)
  send_message('scannerOpenWithScan', ScannerOpenWithScan_args, :tableName => tableName, :scan => scan, :attributes => attributes)
end

#send_scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes) ⇒ Object 



556
557
558
 
# File 'lib/hbase-client/thrift/hbase.rb', line 556

def send_scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes)
  send_message('scannerOpenWithStop', ScannerOpenWithStop_args, :tableName => tableName, :startRow => startRow, :stopRow => stopRow, :columns => columns, :attributes => attributes)
end

#send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes) ⇒ Object 



604
605
606
 
# File 'lib/hbase-client/thrift/hbase.rb', line 604

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