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

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

Instance Method Summary collapse

Instance Method Details

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



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

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/massive_record/thrift/hbase.rb', line 61

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

#createTable(tableName, columnFamilies) ⇒ Object 



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

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

#deleteAll(tableName, row, column) ⇒ Object 



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

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

#deleteAllRow(tableName, row) ⇒ Object 



394
395
396
397
 
# File 'lib/massive_record/thrift/hbase.rb', line 394

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

#deleteAllRowTs(tableName, row, timestamp) ⇒ Object 



409
410
411
412
 
# File 'lib/massive_record/thrift/hbase.rb', line 409

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

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



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

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

#deleteTable(tableName) ⇒ Object 



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

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

#disableTable(tableName) ⇒ Object 



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

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

#enableTable(tableName) ⇒ Object 



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

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

#get(tableName, row, column) ⇒ Object 



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

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

#getColumnDescriptors(tableName) ⇒ Object 



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

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

#getRow(tableName, row) ⇒ Object 



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

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

#getRowTs(tableName, row, timestamp) ⇒ Object 



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

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

#getRowWithColumns(tableName, row, columns) ⇒ Object 



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

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

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



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

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

#getTableNames ⇒ Object 



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

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

#getTableRegions(tableName) ⇒ Object 



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

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

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



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

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

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



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

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

#isTableEnabled(tableName) ⇒ Object 



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

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

#majorCompact(tableNameOrRegionName) ⇒ Object 



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

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

#mutateRow(tableName, row, mutations) ⇒ Object 



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

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

#mutateRows(tableName, rowBatches) ⇒ Object 



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

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

#mutateRowsTs(tableName, rowBatches, timestamp) ⇒ Object 



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

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

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



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

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

#recv_atomicIncrement ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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/massive_record/thrift/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/massive_record/thrift/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 



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

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

#recv_deleteAllRow ⇒ Object 



403
404
405
406
407
 
# File 'lib/massive_record/thrift/hbase.rb', line 403

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

#recv_deleteAllRowTs ⇒ Object 



418
419
420
421
422
 
# File 'lib/massive_record/thrift/hbase.rb', line 418

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

#recv_deleteAllTs ⇒ Object 



388
389
390
391
392
 
# File 'lib/massive_record/thrift/hbase.rb', line 388

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/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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_getRow ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


228
229
230
231
232
233
 
# File 'lib/massive_record/thrift/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_getRowTs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


260
261
262
263
264
265
 
# File 'lib/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/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_isTableEnabled ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


54
55
56
57
58
59
 
# File 'lib/massive_record/thrift/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/massive_record/thrift/hbase.rb', line 85

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

#recv_mutateRow ⇒ Object 



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

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 



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

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 



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

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 



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

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 



547
548
549
550
551
552
 
# File 'lib/massive_record/thrift/hbase.rb', line 547

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) 


513
514
515
516
517
518
519
 
# File 'lib/massive_record/thrift/hbase.rb', line 513

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) 


530
531
532
533
534
535
536
 
# File 'lib/massive_record/thrift/hbase.rb', line 530

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) 


433
434
435
436
437
438
 
# File 'lib/massive_record/thrift/hbase.rb', line 433

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) 


481
482
483
484
485
486
 
# File 'lib/massive_record/thrift/hbase.rb', line 481

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) 


465
466
467
468
469
470
 
# File 'lib/massive_record/thrift/hbase.rb', line 465

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

Raises:

  • (::Thrift::ApplicationException) 


449
450
451
452
453
454
 
# File 'lib/massive_record/thrift/hbase.rb', line 449

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) 


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

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 



538
539
540
541
 
# File 'lib/massive_record/thrift/hbase.rb', line 538

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

#scannerGet(id) ⇒ Object 



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

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

#scannerGetList(id, nbRows) ⇒ Object 



521
522
523
524
 
# File 'lib/massive_record/thrift/hbase.rb', line 521

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

#scannerOpen(tableName, startRow, columns) ⇒ Object 



424
425
426
427
 
# File 'lib/massive_record/thrift/hbase.rb', line 424

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

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



472
473
474
475
 
# File 'lib/massive_record/thrift/hbase.rb', line 472

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

#scannerOpenWithPrefix(tableName, startAndPrefix, columns) ⇒ Object 



456
457
458
459
 
# File 'lib/massive_record/thrift/hbase.rb', line 456

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

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



440
441
442
443
 
# File 'lib/massive_record/thrift/hbase.rb', line 440

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

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



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

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

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



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

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/massive_record/thrift/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/massive_record/thrift/hbase.rb', line 144

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

#send_deleteAll(tableName, row, column) ⇒ Object 



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

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

#send_deleteAllRow(tableName, row) ⇒ Object 



399
400
401
 
# File 'lib/massive_record/thrift/hbase.rb', line 399

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

#send_deleteAllRowTs(tableName, row, timestamp) ⇒ Object 



414
415
416
 
# File 'lib/massive_record/thrift/hbase.rb', line 414

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

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



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

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

#send_deleteTable(tableName) ⇒ Object 



161
162
163
 
# File 'lib/massive_record/thrift/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/massive_record/thrift/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/massive_record/thrift/hbase.rb', line 20

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

#send_get(tableName, row, column) ⇒ Object 



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

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

#send_getColumnDescriptors(tableName) ⇒ Object 



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

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

#send_getRow(tableName, row) ⇒ Object 



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

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

#send_getRowTs(tableName, row, timestamp) ⇒ Object 



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

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

#send_getRowWithColumns(tableName, row, columns) ⇒ Object 



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

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

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



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

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

#send_getTableNames ⇒ Object 



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

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

#send_getTableRegions(tableName) ⇒ Object 



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

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

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



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

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

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



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

def send_getVerTs(tableName, row, column, timestamp, numVersions)
  send_message('getVerTs', GetVerTs_args, :tableName => tableName, :row => row, :column => column, :timestamp => timestamp, :numVersions => numVersions)
end

#send_isTableEnabled(tableName) ⇒ Object 



50
51
52
 
# File 'lib/massive_record/thrift/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/massive_record/thrift/hbase.rb', line 81

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

#send_mutateRow(tableName, row, mutations) ⇒ Object 



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

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

#send_mutateRows(tableName, rowBatches) ⇒ Object 



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

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

#send_mutateRowsTs(tableName, rowBatches, timestamp) ⇒ Object 



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

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

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



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

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

#send_scannerClose(id) ⇒ Object 



543
544
545
 
# File 'lib/massive_record/thrift/hbase.rb', line 543

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

#send_scannerGet(id) ⇒ Object 



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

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

#send_scannerGetList(id, nbRows) ⇒ Object 



526
527
528
 
# File 'lib/massive_record/thrift/hbase.rb', line 526

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

#send_scannerOpen(tableName, startRow, columns) ⇒ Object 



429
430
431
 
# File 'lib/massive_record/thrift/hbase.rb', line 429

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

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



477
478
479
 
# File 'lib/massive_record/thrift/hbase.rb', line 477

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

#send_scannerOpenWithPrefix(tableName, startAndPrefix, columns) ⇒ Object 



461
462
463
 
# File 'lib/massive_record/thrift/hbase.rb', line 461

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

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



445
446
447
 
# File 'lib/massive_record/thrift/hbase.rb', line 445

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

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



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

def send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp)
  send_message('scannerOpenWithStopTs', ScannerOpenWithStopTs_args, :tableName => tableName, :startRow => startRow, :stopRow => stopRow, :columns => columns, :timestamp => timestamp)
end