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

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

Instance Method Summary collapse

Instance Method Details

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



350
351
352
353
# File 'lib/thrift/hbase.rb', line 350

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

#compact(tableNameOrRegionName) ⇒ Object



64
65
66
67
# File 'lib/thrift/hbase.rb', line 64

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

#createTable(tableName, columnFamilies) ⇒ Object



142
143
144
145
# File 'lib/thrift/hbase.rb', line 142

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

#deleteAll(tableName, row, column) ⇒ Object



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

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

#deleteAllRow(tableName, row) ⇒ Object



397
398
399
400
# File 'lib/thrift/hbase.rb', line 397

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

#deleteAllRowTs(tableName, row, timestamp) ⇒ Object



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

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

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



382
383
384
385
# File 'lib/thrift/hbase.rb', line 382

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

#deleteTable(tableName) ⇒ Object



159
160
161
162
# File 'lib/thrift/hbase.rb', line 159

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

#disableTable(tableName) ⇒ Object



33
34
35
36
# File 'lib/thrift/hbase.rb', line 33

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

#enableTable(tableName) ⇒ Object



18
19
20
21
# File 'lib/thrift/hbase.rb', line 18

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

#get(tableName, row, column) ⇒ Object



174
175
176
177
# File 'lib/thrift/hbase.rb', line 174

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

#getColumnDescriptors(tableName) ⇒ Object



110
111
112
113
# File 'lib/thrift/hbase.rb', line 110

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

#getRow(tableName, row) ⇒ Object



222
223
224
225
# File 'lib/thrift/hbase.rb', line 222

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

#getRowTs(tableName, row, timestamp) ⇒ Object



254
255
256
257
# File 'lib/thrift/hbase.rb', line 254

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

#getRowWithColumns(tableName, row, columns) ⇒ Object



238
239
240
241
# File 'lib/thrift/hbase.rb', line 238

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

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



270
271
272
273
# File 'lib/thrift/hbase.rb', line 270

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

#getTableNamesObject



94
95
96
97
# File 'lib/thrift/hbase.rb', line 94

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

#getTableRegions(tableName) ⇒ Object



126
127
128
129
# File 'lib/thrift/hbase.rb', line 126

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

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



190
191
192
193
# File 'lib/thrift/hbase.rb', line 190

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

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



206
207
208
209
# File 'lib/thrift/hbase.rb', line 206

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

#isTableEnabled(tableName) ⇒ Object



48
49
50
51
# File 'lib/thrift/hbase.rb', line 48

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

#majorCompact(tableNameOrRegionName) ⇒ Object



79
80
81
82
# File 'lib/thrift/hbase.rb', line 79

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

#mutateRow(tableName, row, mutations) ⇒ Object



286
287
288
289
# File 'lib/thrift/hbase.rb', line 286

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

#mutateRows(tableName, rowBatches) ⇒ Object



318
319
320
321
# File 'lib/thrift/hbase.rb', line 318

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

#mutateRowsTs(tableName, rowBatches, timestamp) ⇒ Object



334
335
336
337
# File 'lib/thrift/hbase.rb', line 334

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

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



302
303
304
305
# File 'lib/thrift/hbase.rb', line 302

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

#recv_atomicIncrementObject

Raises:

  • (::Thrift::ApplicationException)


359
360
361
362
363
364
365
# File 'lib/thrift/hbase.rb', line 359

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_compactObject



73
74
75
76
77
# File 'lib/thrift/hbase.rb', line 73

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

#recv_createTableObject



151
152
153
154
155
156
157
# File 'lib/thrift/hbase.rb', line 151

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_deleteAllObject



376
377
378
379
380
# File 'lib/thrift/hbase.rb', line 376

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

#recv_deleteAllRowObject



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

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

#recv_deleteAllRowTsObject



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

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

#recv_deleteAllTsObject



391
392
393
394
395
# File 'lib/thrift/hbase.rb', line 391

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

#recv_deleteTableObject



168
169
170
171
172
# File 'lib/thrift/hbase.rb', line 168

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

#recv_disableTableObject



42
43
44
45
46
# File 'lib/thrift/hbase.rb', line 42

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

#recv_enableTableObject



27
28
29
30
31
# File 'lib/thrift/hbase.rb', line 27

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

#recv_getObject

Raises:

  • (::Thrift::ApplicationException)


183
184
185
186
187
188
# File 'lib/thrift/hbase.rb', line 183

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_getColumnDescriptorsObject

Raises:

  • (::Thrift::ApplicationException)


119
120
121
122
123
124
# File 'lib/thrift/hbase.rb', line 119

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_getRowObject

Raises:

  • (::Thrift::ApplicationException)


231
232
233
234
235
236
# File 'lib/thrift/hbase.rb', line 231

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_getRowTsObject

Raises:

  • (::Thrift::ApplicationException)


263
264
265
266
267
268
# File 'lib/thrift/hbase.rb', line 263

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_getRowWithColumnsObject

Raises:

  • (::Thrift::ApplicationException)


247
248
249
250
251
252
# File 'lib/thrift/hbase.rb', line 247

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_getRowWithColumnsTsObject

Raises:

  • (::Thrift::ApplicationException)


279
280
281
282
283
284
# File 'lib/thrift/hbase.rb', line 279

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_getTableNamesObject

Raises:

  • (::Thrift::ApplicationException)


103
104
105
106
107
108
# File 'lib/thrift/hbase.rb', line 103

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_getTableRegionsObject

Raises:

  • (::Thrift::ApplicationException)


135
136
137
138
139
140
# File 'lib/thrift/hbase.rb', line 135

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_getVerObject

Raises:

  • (::Thrift::ApplicationException)


199
200
201
202
203
204
# File 'lib/thrift/hbase.rb', line 199

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_getVerTsObject

Raises:

  • (::Thrift::ApplicationException)


215
216
217
218
219
220
# File 'lib/thrift/hbase.rb', line 215

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_isTableEnabledObject

Raises:

  • (::Thrift::ApplicationException)


57
58
59
60
61
62
# File 'lib/thrift/hbase.rb', line 57

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_majorCompactObject



88
89
90
91
92
# File 'lib/thrift/hbase.rb', line 88

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

#recv_mutateRowObject



295
296
297
298
299
300
# File 'lib/thrift/hbase.rb', line 295

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_mutateRowsObject



327
328
329
330
331
332
# File 'lib/thrift/hbase.rb', line 327

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_mutateRowsTsObject



343
344
345
346
347
348
# File 'lib/thrift/hbase.rb', line 343

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_mutateRowTsObject



311
312
313
314
315
316
# File 'lib/thrift/hbase.rb', line 311

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_scannerCloseObject



550
551
552
553
554
555
# File 'lib/thrift/hbase.rb', line 550

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_scannerGetObject

Raises:

  • (::Thrift::ApplicationException)


516
517
518
519
520
521
522
# File 'lib/thrift/hbase.rb', line 516

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_scannerGetListObject

Raises:

  • (::Thrift::ApplicationException)


533
534
535
536
537
538
539
# File 'lib/thrift/hbase.rb', line 533

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_scannerOpenObject

Raises:

  • (::Thrift::ApplicationException)


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

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_scannerOpenTsObject

Raises:

  • (::Thrift::ApplicationException)


484
485
486
487
488
489
# File 'lib/thrift/hbase.rb', line 484

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_scannerOpenWithPrefixObject

Raises:

  • (::Thrift::ApplicationException)


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

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_scannerOpenWithStopObject

Raises:

  • (::Thrift::ApplicationException)


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

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_scannerOpenWithStopTsObject

Raises:

  • (::Thrift::ApplicationException)


500
501
502
503
504
505
# File 'lib/thrift/hbase.rb', line 500

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



541
542
543
544
# File 'lib/thrift/hbase.rb', line 541

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

#scannerGet(id) ⇒ Object



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

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

#scannerGetList(id, nbRows) ⇒ Object



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

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

#scannerOpen(tableName, startRow, columns) ⇒ Object



427
428
429
430
# File 'lib/thrift/hbase.rb', line 427

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

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



475
476
477
478
# File 'lib/thrift/hbase.rb', line 475

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

#scannerOpenWithPrefix(tableName, startAndPrefix, columns) ⇒ Object



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

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

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



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

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

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



491
492
493
494
# File 'lib/thrift/hbase.rb', line 491

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



355
356
357
# File 'lib/thrift/hbase.rb', line 355

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



69
70
71
# File 'lib/thrift/hbase.rb', line 69

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

#send_createTable(tableName, columnFamilies) ⇒ Object



147
148
149
# File 'lib/thrift/hbase.rb', line 147

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

#send_deleteAll(tableName, row, column) ⇒ Object



372
373
374
# File 'lib/thrift/hbase.rb', line 372

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

#send_deleteAllRow(tableName, row) ⇒ Object



402
403
404
# File 'lib/thrift/hbase.rb', line 402

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

#send_deleteAllRowTs(tableName, row, timestamp) ⇒ Object



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

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



387
388
389
# File 'lib/thrift/hbase.rb', line 387

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



164
165
166
# File 'lib/thrift/hbase.rb', line 164

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

#send_disableTable(tableName) ⇒ Object



38
39
40
# File 'lib/thrift/hbase.rb', line 38

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

#send_enableTable(tableName) ⇒ Object



23
24
25
# File 'lib/thrift/hbase.rb', line 23

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

#send_get(tableName, row, column) ⇒ Object



179
180
181
# File 'lib/thrift/hbase.rb', line 179

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

#send_getColumnDescriptors(tableName) ⇒ Object



115
116
117
# File 'lib/thrift/hbase.rb', line 115

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

#send_getRow(tableName, row) ⇒ Object



227
228
229
# File 'lib/thrift/hbase.rb', line 227

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

#send_getRowTs(tableName, row, timestamp) ⇒ Object



259
260
261
# File 'lib/thrift/hbase.rb', line 259

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

#send_getRowWithColumns(tableName, row, columns) ⇒ Object



243
244
245
# File 'lib/thrift/hbase.rb', line 243

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



275
276
277
# File 'lib/thrift/hbase.rb', line 275

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

#send_getTableNamesObject



99
100
101
# File 'lib/thrift/hbase.rb', line 99

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

#send_getTableRegions(tableName) ⇒ Object



131
132
133
# File 'lib/thrift/hbase.rb', line 131

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

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



195
196
197
# File 'lib/thrift/hbase.rb', line 195

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



211
212
213
# File 'lib/thrift/hbase.rb', line 211

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



53
54
55
# File 'lib/thrift/hbase.rb', line 53

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

#send_majorCompact(tableNameOrRegionName) ⇒ Object



84
85
86
# File 'lib/thrift/hbase.rb', line 84

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

#send_mutateRow(tableName, row, mutations) ⇒ Object



291
292
293
# File 'lib/thrift/hbase.rb', line 291

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

#send_mutateRows(tableName, rowBatches) ⇒ Object



323
324
325
# File 'lib/thrift/hbase.rb', line 323

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

#send_mutateRowsTs(tableName, rowBatches, timestamp) ⇒ Object



339
340
341
# File 'lib/thrift/hbase.rb', line 339

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



307
308
309
# File 'lib/thrift/hbase.rb', line 307

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



546
547
548
# File 'lib/thrift/hbase.rb', line 546

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

#send_scannerGet(id) ⇒ Object



512
513
514
# File 'lib/thrift/hbase.rb', line 512

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

#send_scannerGetList(id, nbRows) ⇒ Object



529
530
531
# File 'lib/thrift/hbase.rb', line 529

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

#send_scannerOpen(tableName, startRow, columns) ⇒ Object



432
433
434
# File 'lib/thrift/hbase.rb', line 432

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



480
481
482
# File 'lib/thrift/hbase.rb', line 480

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



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

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



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

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



496
497
498
# File 'lib/thrift/hbase.rb', line 496

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