Class: Apache::Hadoop::Hbase::Thrift::Hbase::Client

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

Instance Method Summary collapse

Instance Method Details

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



411
412
413
414
 
# File 'lib/adapter/hbase/hbase.rb', line 411

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

#compact(tableNameOrRegionName) ⇒ Object 



61
62
63
64
 
# File 'lib/adapter/hbase/hbase.rb', line 61

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

#createTable(tableName, columnFamilies) ⇒ Object 



139
140
141
142
 
# File 'lib/adapter/hbase/hbase.rb', line 139

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

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



428
429
430
431
 
# File 'lib/adapter/hbase/hbase.rb', line 428

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

#deleteAllRow(tableName, row, attributes) ⇒ Object 



458
459
460
461
 
# File 'lib/adapter/hbase/hbase.rb', line 458

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

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



503
504
505
506
 
# File 'lib/adapter/hbase/hbase.rb', line 503

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

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



443
444
445
446
 
# File 'lib/adapter/hbase/hbase.rb', line 443

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

#deleteTable(tableName) ⇒ Object 



156
157
158
159
 
# File 'lib/adapter/hbase/hbase.rb', line 156

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

#disableTable(tableName) ⇒ Object 



30
31
32
33
 
# File 'lib/adapter/hbase/hbase.rb', line 30

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

#enableTable(tableName) ⇒ Object 



15
16
17
18
 
# File 'lib/adapter/hbase/hbase.rb', line 15

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

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



171
172
173
174
 
# File 'lib/adapter/hbase/hbase.rb', line 171

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

#getColumnDescriptors(tableName) ⇒ Object 



107
108
109
110
 
# File 'lib/adapter/hbase/hbase.rb', line 107

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

#getRegionInfo(row) ⇒ Object 



680
681
682
683
 
# File 'lib/adapter/hbase/hbase.rb', line 680

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

#getRow(tableName, row, attributes) ⇒ Object 



219
220
221
222
 
# File 'lib/adapter/hbase/hbase.rb', line 219

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

#getRowOrBefore(tableName, row, family) ⇒ Object 



664
665
666
667
 
# File 'lib/adapter/hbase/hbase.rb', line 664

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

#getRows(tableName, rows, attributes) ⇒ Object 



283
284
285
286
 
# File 'lib/adapter/hbase/hbase.rb', line 283

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

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



315
316
317
318
 
# File 'lib/adapter/hbase/hbase.rb', line 315

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

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



299
300
301
302
 
# File 'lib/adapter/hbase/hbase.rb', line 299

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

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



331
332
333
334
 
# File 'lib/adapter/hbase/hbase.rb', line 331

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

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



251
252
253
254
 
# File 'lib/adapter/hbase/hbase.rb', line 251

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

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



235
236
237
238
 
# File 'lib/adapter/hbase/hbase.rb', line 235

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

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



267
268
269
270
 
# File 'lib/adapter/hbase/hbase.rb', line 267

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

#getTableNames ⇒ Object 



91
92
93
94
 
# File 'lib/adapter/hbase/hbase.rb', line 91

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

#getTableRegions(tableName) ⇒ Object 



123
124
125
126
 
# File 'lib/adapter/hbase/hbase.rb', line 123

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

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



187
188
189
190
 
# File 'lib/adapter/hbase/hbase.rb', line 187

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 



203
204
205
206
 
# File 'lib/adapter/hbase/hbase.rb', line 203

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

#increment(increment) ⇒ Object 



473
474
475
476
 
# File 'lib/adapter/hbase/hbase.rb', line 473

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

#incrementRows(increments) ⇒ Object 



488
489
490
491
 
# File 'lib/adapter/hbase/hbase.rb', line 488

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

#isTableEnabled(tableName) ⇒ Object 



45
46
47
48
 
# File 'lib/adapter/hbase/hbase.rb', line 45

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

#majorCompact(tableNameOrRegionName) ⇒ Object 



76
77
78
79
 
# File 'lib/adapter/hbase/hbase.rb', line 76

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

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



347
348
349
350
 
# File 'lib/adapter/hbase/hbase.rb', line 347

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

#mutateRows(tableName, rowBatches, attributes) ⇒ Object 



379
380
381
382
 
# File 'lib/adapter/hbase/hbase.rb', line 379

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

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



395
396
397
398
 
# File 'lib/adapter/hbase/hbase.rb', line 395

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

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



363
364
365
366
 
# File 'lib/adapter/hbase/hbase.rb', line 363

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

#recv_atomicIncrement ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


420
421
422
423
424
425
426
 
# File 'lib/adapter/hbase/hbase.rb', line 420

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_compact ⇒ Object 



70
71
72
73
74
 
# File 'lib/adapter/hbase/hbase.rb', line 70

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

#recv_createTable ⇒ Object 



148
149
150
151
152
153
154
 
# File 'lib/adapter/hbase/hbase.rb', line 148

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 



437
438
439
440
441
 
# File 'lib/adapter/hbase/hbase.rb', line 437

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

#recv_deleteAllRow ⇒ Object 



467
468
469
470
471
 
# File 'lib/adapter/hbase/hbase.rb', line 467

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

#recv_deleteAllRowTs ⇒ Object 



512
513
514
515
516
 
# File 'lib/adapter/hbase/hbase.rb', line 512

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

#recv_deleteAllTs ⇒ Object 



452
453
454
455
456
 
# File 'lib/adapter/hbase/hbase.rb', line 452

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

#recv_deleteTable ⇒ Object 



165
166
167
168
169
 
# File 'lib/adapter/hbase/hbase.rb', line 165

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

#recv_disableTable ⇒ Object 



39
40
41
42
43
 
# File 'lib/adapter/hbase/hbase.rb', line 39

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

#recv_enableTable ⇒ Object 



24
25
26
27
28
 
# File 'lib/adapter/hbase/hbase.rb', line 24

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

#recv_get ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


180
181
182
183
184
185
 
# File 'lib/adapter/hbase/hbase.rb', line 180

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) 


116
117
118
119
120
121
 
# File 'lib/adapter/hbase/hbase.rb', line 116

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) 


689
690
691
692
693
694
 
# File 'lib/adapter/hbase/hbase.rb', line 689

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) 


228
229
230
231
232
233
 
# File 'lib/adapter/hbase/hbase.rb', line 228

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) 


673
674
675
676
677
678
 
# File 'lib/adapter/hbase/hbase.rb', line 673

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) 


292
293
294
295
296
297
 
# File 'lib/adapter/hbase/hbase.rb', line 292

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) 


324
325
326
327
328
329
 
# File 'lib/adapter/hbase/hbase.rb', line 324

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) 


308
309
310
311
312
313
 
# File 'lib/adapter/hbase/hbase.rb', line 308

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) 


340
341
342
343
344
345
 
# File 'lib/adapter/hbase/hbase.rb', line 340

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) 


260
261
262
263
264
265
 
# File 'lib/adapter/hbase/hbase.rb', line 260

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) 


244
245
246
247
248
249
 
# File 'lib/adapter/hbase/hbase.rb', line 244

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) 


276
277
278
279
280
281
 
# File 'lib/adapter/hbase/hbase.rb', line 276

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) 


100
101
102
103
104
105
 
# File 'lib/adapter/hbase/hbase.rb', line 100

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) 


132
133
134
135
136
137
 
# File 'lib/adapter/hbase/hbase.rb', line 132

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) 


196
197
198
199
200
201
 
# File 'lib/adapter/hbase/hbase.rb', line 196

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) 


212
213
214
215
216
217
 
# File 'lib/adapter/hbase/hbase.rb', line 212

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 



482
483
484
485
486
 
# File 'lib/adapter/hbase/hbase.rb', line 482

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

#recv_incrementRows ⇒ Object 



497
498
499
500
501
 
# File 'lib/adapter/hbase/hbase.rb', line 497

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

#recv_isTableEnabled ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


54
55
56
57
58
59
 
# File 'lib/adapter/hbase/hbase.rb', line 54

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 



85
86
87
88
89
 
# File 'lib/adapter/hbase/hbase.rb', line 85

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

#recv_mutateRow ⇒ Object 



356
357
358
359
360
361
 
# File 'lib/adapter/hbase/hbase.rb', line 356

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 



388
389
390
391
392
393
 
# File 'lib/adapter/hbase/hbase.rb', line 388

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 



404
405
406
407
408
409
 
# File 'lib/adapter/hbase/hbase.rb', line 404

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 



372
373
374
375
376
377
 
# File 'lib/adapter/hbase/hbase.rb', line 372

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 



657
658
659
660
661
662
 
# File 'lib/adapter/hbase/hbase.rb', line 657

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) 


623
624
625
626
627
628
629
 
# File 'lib/adapter/hbase/hbase.rb', line 623

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) 


640
641
642
643
644
645
646
 
# File 'lib/adapter/hbase/hbase.rb', line 640

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) 


543
544
545
546
547
548
 
# File 'lib/adapter/hbase/hbase.rb', line 543

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) 


591
592
593
594
595
596
 
# File 'lib/adapter/hbase/hbase.rb', line 591

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) 


575
576
577
578
579
580
 
# File 'lib/adapter/hbase/hbase.rb', line 575

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) 


527
528
529
530
531
532
 
# File 'lib/adapter/hbase/hbase.rb', line 527

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) 


559
560
561
562
563
564
 
# File 'lib/adapter/hbase/hbase.rb', line 559

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) 


607
608
609
610
611
612
 
# File 'lib/adapter/hbase/hbase.rb', line 607

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 



648
649
650
651
 
# File 'lib/adapter/hbase/hbase.rb', line 648

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

#scannerGet(id) ⇒ Object 



614
615
616
617
 
# File 'lib/adapter/hbase/hbase.rb', line 614

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

#scannerGetList(id, nbRows) ⇒ Object 



631
632
633
634
 
# File 'lib/adapter/hbase/hbase.rb', line 631

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

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



534
535
536
537
 
# File 'lib/adapter/hbase/hbase.rb', line 534

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

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



582
583
584
585
 
# File 'lib/adapter/hbase/hbase.rb', line 582

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

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



566
567
568
569
 
# File 'lib/adapter/hbase/hbase.rb', line 566

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

#scannerOpenWithScan(tableName, scan, attributes) ⇒ Object 



518
519
520
521
 
# File 'lib/adapter/hbase/hbase.rb', line 518

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

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



550
551
552
553
 
# File 'lib/adapter/hbase/hbase.rb', line 550

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 



598
599
600
601
 
# File 'lib/adapter/hbase/hbase.rb', line 598

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

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



416
417
418
 
# File 'lib/adapter/hbase/hbase.rb', line 416

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

#send_compact(tableNameOrRegionName) ⇒ Object 



66
67
68
 
# File 'lib/adapter/hbase/hbase.rb', line 66

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

#send_createTable(tableName, columnFamilies) ⇒ Object 



144
145
146
 
# File 'lib/adapter/hbase/hbase.rb', line 144

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

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



433
434
435
 
# File 'lib/adapter/hbase/hbase.rb', line 433

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 



463
464
465
 
# File 'lib/adapter/hbase/hbase.rb', line 463

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 



508
509
510
 
# File 'lib/adapter/hbase/hbase.rb', line 508

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 



448
449
450
 
# File 'lib/adapter/hbase/hbase.rb', line 448

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 



161
162
163
 
# File 'lib/adapter/hbase/hbase.rb', line 161

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

#send_disableTable(tableName) ⇒ Object 



35
36
37
 
# File 'lib/adapter/hbase/hbase.rb', line 35

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

#send_enableTable(tableName) ⇒ Object 



20
21
22
 
# File 'lib/adapter/hbase/hbase.rb', line 20

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

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



176
177
178
 
# File 'lib/adapter/hbase/hbase.rb', line 176

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 



112
113
114
 
# File 'lib/adapter/hbase/hbase.rb', line 112

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

#send_getRegionInfo(row) ⇒ Object 



685
686
687
 
# File 'lib/adapter/hbase/hbase.rb', line 685

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

#send_getRow(tableName, row, attributes) ⇒ Object 



224
225
226
 
# File 'lib/adapter/hbase/hbase.rb', line 224

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

#send_getRowOrBefore(tableName, row, family) ⇒ Object 



669
670
671
 
# File 'lib/adapter/hbase/hbase.rb', line 669

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

#send_getRows(tableName, rows, attributes) ⇒ Object 



288
289
290
 
# File 'lib/adapter/hbase/hbase.rb', line 288

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 



320
321
322
 
# File 'lib/adapter/hbase/hbase.rb', line 320

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 



304
305
306
 
# File 'lib/adapter/hbase/hbase.rb', line 304

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 



336
337
338
 
# File 'lib/adapter/hbase/hbase.rb', line 336

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 



256
257
258
 
# File 'lib/adapter/hbase/hbase.rb', line 256

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 



240
241
242
 
# File 'lib/adapter/hbase/hbase.rb', line 240

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 



272
273
274
 
# File 'lib/adapter/hbase/hbase.rb', line 272

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 



96
97
98
 
# File 'lib/adapter/hbase/hbase.rb', line 96

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

#send_getTableRegions(tableName) ⇒ Object 



128
129
130
 
# File 'lib/adapter/hbase/hbase.rb', line 128

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

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



192
193
194
 
# File 'lib/adapter/hbase/hbase.rb', line 192

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 



208
209
210
 
# File 'lib/adapter/hbase/hbase.rb', line 208

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 



478
479
480
 
# File 'lib/adapter/hbase/hbase.rb', line 478

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

#send_incrementRows(increments) ⇒ Object 



493
494
495
 
# File 'lib/adapter/hbase/hbase.rb', line 493

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

#send_isTableEnabled(tableName) ⇒ Object 



50
51
52
 
# File 'lib/adapter/hbase/hbase.rb', line 50

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

#send_majorCompact(tableNameOrRegionName) ⇒ Object 



81
82
83
 
# File 'lib/adapter/hbase/hbase.rb', line 81

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

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



352
353
354
 
# File 'lib/adapter/hbase/hbase.rb', line 352

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 



384
385
386
 
# File 'lib/adapter/hbase/hbase.rb', line 384

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 



400
401
402
 
# File 'lib/adapter/hbase/hbase.rb', line 400

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 



368
369
370
 
# File 'lib/adapter/hbase/hbase.rb', line 368

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 



653
654
655
 
# File 'lib/adapter/hbase/hbase.rb', line 653

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

#send_scannerGet(id) ⇒ Object 



619
620
621
 
# File 'lib/adapter/hbase/hbase.rb', line 619

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

#send_scannerGetList(id, nbRows) ⇒ Object 



636
637
638
 
# File 'lib/adapter/hbase/hbase.rb', line 636

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

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



539
540
541
 
# File 'lib/adapter/hbase/hbase.rb', line 539

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 



587
588
589
 
# File 'lib/adapter/hbase/hbase.rb', line 587

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 



571
572
573
 
# File 'lib/adapter/hbase/hbase.rb', line 571

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 



523
524
525
 
# File 'lib/adapter/hbase/hbase.rb', line 523

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 



555
556
557
 
# File 'lib/adapter/hbase/hbase.rb', line 555

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 



603
604
605
 
# File 'lib/adapter/hbase/hbase.rb', line 603

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