Class: Apache::Hadoop::Hbase::Thrift::Hbase::Client
- Inherits:
-
Object
- Object
- Apache::Hadoop::Hbase::Thrift::Hbase::Client
- Includes:
- Thrift::Client
- Defined in:
- lib/thrift/hbase.rb
Instance Method Summary collapse
- #atomicIncrement(tableName, row, column, value) ⇒ Object
- #compact(tableNameOrRegionName) ⇒ Object
- #createTable(tableName, columnFamilies) ⇒ Object
- #deleteAll(tableName, row, column) ⇒ Object
- #deleteAllRow(tableName, row) ⇒ Object
- #deleteAllRowTs(tableName, row, timestamp) ⇒ Object
- #deleteAllTs(tableName, row, column, timestamp) ⇒ Object
- #deleteTable(tableName) ⇒ Object
- #disableTable(tableName) ⇒ Object
- #enableTable(tableName) ⇒ Object
- #get(tableName, row, column) ⇒ Object
- #getColumnDescriptors(tableName) ⇒ Object
- #getRow(tableName, row) ⇒ Object
- #getRowTs(tableName, row, timestamp) ⇒ Object
- #getRowWithColumns(tableName, row, columns) ⇒ Object
- #getRowWithColumnsTs(tableName, row, columns, timestamp) ⇒ Object
- #getTableNames ⇒ Object
- #getTableRegions(tableName) ⇒ Object
- #getVer(tableName, row, column, numVersions) ⇒ Object
- #getVerTs(tableName, row, column, timestamp, numVersions) ⇒ Object
- #isTableEnabled(tableName) ⇒ Object
- #majorCompact(tableNameOrRegionName) ⇒ Object
- #mutateRow(tableName, row, mutations) ⇒ Object
- #mutateRows(tableName, rowBatches) ⇒ Object
- #mutateRowsTs(tableName, rowBatches, timestamp) ⇒ Object
- #mutateRowTs(tableName, row, mutations, timestamp) ⇒ Object
- #recv_atomicIncrement ⇒ Object
- #recv_compact ⇒ Object
- #recv_createTable ⇒ Object
- #recv_deleteAll ⇒ Object
- #recv_deleteAllRow ⇒ Object
- #recv_deleteAllRowTs ⇒ Object
- #recv_deleteAllTs ⇒ Object
- #recv_deleteTable ⇒ Object
- #recv_disableTable ⇒ Object
- #recv_enableTable ⇒ Object
- #recv_get ⇒ Object
- #recv_getColumnDescriptors ⇒ Object
- #recv_getRow ⇒ Object
- #recv_getRowTs ⇒ Object
- #recv_getRowWithColumns ⇒ Object
- #recv_getRowWithColumnsTs ⇒ Object
- #recv_getTableNames ⇒ Object
- #recv_getTableRegions ⇒ Object
- #recv_getVer ⇒ Object
- #recv_getVerTs ⇒ Object
- #recv_isTableEnabled ⇒ Object
- #recv_majorCompact ⇒ Object
- #recv_mutateRow ⇒ Object
- #recv_mutateRows ⇒ Object
- #recv_mutateRowsTs ⇒ Object
- #recv_mutateRowTs ⇒ Object
- #recv_scannerClose ⇒ Object
- #recv_scannerGet ⇒ Object
- #recv_scannerGetList ⇒ Object
- #recv_scannerOpen ⇒ Object
- #recv_scannerOpenTs ⇒ Object
- #recv_scannerOpenWithPrefix ⇒ Object
- #recv_scannerOpenWithStop ⇒ Object
- #recv_scannerOpenWithStopTs ⇒ Object
- #scannerClose(id) ⇒ Object
- #scannerGet(id) ⇒ Object
- #scannerGetList(id, nbRows) ⇒ Object
- #scannerOpen(tableName, startRow, columns) ⇒ Object
- #scannerOpenTs(tableName, startRow, columns, timestamp) ⇒ Object
- #scannerOpenWithPrefix(tableName, startAndPrefix, columns) ⇒ Object
- #scannerOpenWithStop(tableName, startRow, stopRow, columns) ⇒ Object
- #scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp) ⇒ Object
- #send_atomicIncrement(tableName, row, column, value) ⇒ Object
- #send_compact(tableNameOrRegionName) ⇒ Object
- #send_createTable(tableName, columnFamilies) ⇒ Object
- #send_deleteAll(tableName, row, column) ⇒ Object
- #send_deleteAllRow(tableName, row) ⇒ Object
- #send_deleteAllRowTs(tableName, row, timestamp) ⇒ Object
- #send_deleteAllTs(tableName, row, column, timestamp) ⇒ Object
- #send_deleteTable(tableName) ⇒ Object
- #send_disableTable(tableName) ⇒ Object
- #send_enableTable(tableName) ⇒ Object
- #send_get(tableName, row, column) ⇒ Object
- #send_getColumnDescriptors(tableName) ⇒ Object
- #send_getRow(tableName, row) ⇒ Object
- #send_getRowTs(tableName, row, timestamp) ⇒ Object
- #send_getRowWithColumns(tableName, row, columns) ⇒ Object
- #send_getRowWithColumnsTs(tableName, row, columns, timestamp) ⇒ Object
- #send_getTableNames ⇒ Object
- #send_getTableRegions(tableName) ⇒ Object
- #send_getVer(tableName, row, column, numVersions) ⇒ Object
- #send_getVerTs(tableName, row, column, timestamp, numVersions) ⇒ Object
- #send_isTableEnabled(tableName) ⇒ Object
- #send_majorCompact(tableNameOrRegionName) ⇒ Object
- #send_mutateRow(tableName, row, mutations) ⇒ Object
- #send_mutateRows(tableName, rowBatches) ⇒ Object
- #send_mutateRowsTs(tableName, rowBatches, timestamp) ⇒ Object
- #send_mutateRowTs(tableName, row, mutations, timestamp) ⇒ Object
- #send_scannerClose(id) ⇒ Object
- #send_scannerGet(id) ⇒ Object
- #send_scannerGetList(id, nbRows) ⇒ Object
- #send_scannerOpen(tableName, startRow, columns) ⇒ Object
- #send_scannerOpenTs(tableName, startRow, columns, timestamp) ⇒ Object
- #send_scannerOpenWithPrefix(tableName, startAndPrefix, columns) ⇒ Object
- #send_scannerOpenWithStop(tableName, startRow, stopRow, columns) ⇒ Object
- #send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp) ⇒ Object
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, ) send_deleteAllRowTs(tableName, row, ) 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, ) send_deleteAllTs(tableName, row, column, ) 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, ) send_getRowTs(tableName, row, ) 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, ) send_getRowWithColumnsTs(tableName, row, columns, ) return recv_getRowWithColumnsTs() end |
#getTableNames ⇒ Object
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, , numVersions) send_getVerTs(tableName, row, column, , 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, ) send_mutateRowsTs(tableName, rowBatches, ) 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, ) send_mutateRowTs(tableName, row, mutations, ) recv_mutateRowTs() end |
#recv_atomicIncrement ⇒ Object
359 360 361 362 363 364 365 |
# File 'lib/thrift/hbase.rb', line 359 def recv_atomicIncrement() result = (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
73 74 75 76 77 |
# File 'lib/thrift/hbase.rb', line 73 def recv_compact() result = (Compact_result) raise result.io unless result.io.nil? return end |
#recv_createTable ⇒ Object
151 152 153 154 155 156 157 |
# File 'lib/thrift/hbase.rb', line 151 def recv_createTable() result = (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
376 377 378 379 380 |
# File 'lib/thrift/hbase.rb', line 376 def recv_deleteAll() result = (DeleteAll_result) raise result.io unless result.io.nil? return end |
#recv_deleteAllRow ⇒ Object
406 407 408 409 410 |
# File 'lib/thrift/hbase.rb', line 406 def recv_deleteAllRow() result = (DeleteAllRow_result) raise result.io unless result.io.nil? return end |
#recv_deleteAllRowTs ⇒ Object
421 422 423 424 425 |
# File 'lib/thrift/hbase.rb', line 421 def recv_deleteAllRowTs() result = (DeleteAllRowTs_result) raise result.io unless result.io.nil? return end |
#recv_deleteAllTs ⇒ Object
391 392 393 394 395 |
# File 'lib/thrift/hbase.rb', line 391 def recv_deleteAllTs() result = (DeleteAllTs_result) raise result.io unless result.io.nil? return end |
#recv_deleteTable ⇒ Object
168 169 170 171 172 |
# File 'lib/thrift/hbase.rb', line 168 def recv_deleteTable() result = (DeleteTable_result) raise result.io unless result.io.nil? return end |
#recv_disableTable ⇒ Object
42 43 44 45 46 |
# File 'lib/thrift/hbase.rb', line 42 def recv_disableTable() result = (DisableTable_result) raise result.io unless result.io.nil? return end |
#recv_enableTable ⇒ Object
27 28 29 30 31 |
# File 'lib/thrift/hbase.rb', line 27 def recv_enableTable() result = (EnableTable_result) raise result.io unless result.io.nil? return end |
#recv_get ⇒ Object
183 184 185 186 187 188 |
# File 'lib/thrift/hbase.rb', line 183 def recv_get() result = (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
119 120 121 122 123 124 |
# File 'lib/thrift/hbase.rb', line 119 def recv_getColumnDescriptors() result = (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
231 232 233 234 235 236 |
# File 'lib/thrift/hbase.rb', line 231 def recv_getRow() result = (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
263 264 265 266 267 268 |
# File 'lib/thrift/hbase.rb', line 263 def recv_getRowTs() result = (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
247 248 249 250 251 252 |
# File 'lib/thrift/hbase.rb', line 247 def recv_getRowWithColumns() result = (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
279 280 281 282 283 284 |
# File 'lib/thrift/hbase.rb', line 279 def recv_getRowWithColumnsTs() result = (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
103 104 105 106 107 108 |
# File 'lib/thrift/hbase.rb', line 103 def recv_getTableNames() result = (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
135 136 137 138 139 140 |
# File 'lib/thrift/hbase.rb', line 135 def recv_getTableRegions() result = (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
199 200 201 202 203 204 |
# File 'lib/thrift/hbase.rb', line 199 def recv_getVer() result = (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
215 216 217 218 219 220 |
# File 'lib/thrift/hbase.rb', line 215 def recv_getVerTs() result = (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
57 58 59 60 61 62 |
# File 'lib/thrift/hbase.rb', line 57 def recv_isTableEnabled() result = (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
88 89 90 91 92 |
# File 'lib/thrift/hbase.rb', line 88 def recv_majorCompact() result = (MajorCompact_result) raise result.io unless result.io.nil? return end |
#recv_mutateRow ⇒ Object
295 296 297 298 299 300 |
# File 'lib/thrift/hbase.rb', line 295 def recv_mutateRow() result = (MutateRow_result) raise result.io unless result.io.nil? raise result.ia unless result.ia.nil? return end |
#recv_mutateRows ⇒ Object
327 328 329 330 331 332 |
# File 'lib/thrift/hbase.rb', line 327 def recv_mutateRows() result = (MutateRows_result) raise result.io unless result.io.nil? raise result.ia unless result.ia.nil? return end |
#recv_mutateRowsTs ⇒ Object
343 344 345 346 347 348 |
# File 'lib/thrift/hbase.rb', line 343 def recv_mutateRowsTs() result = (MutateRowsTs_result) raise result.io unless result.io.nil? raise result.ia unless result.ia.nil? return end |
#recv_mutateRowTs ⇒ Object
311 312 313 314 315 316 |
# File 'lib/thrift/hbase.rb', line 311 def recv_mutateRowTs() result = (MutateRowTs_result) raise result.io unless result.io.nil? raise result.ia unless result.ia.nil? return end |
#recv_scannerClose ⇒ Object
550 551 552 553 554 555 |
# File 'lib/thrift/hbase.rb', line 550 def recv_scannerClose() result = (ScannerClose_result) raise result.io unless result.io.nil? raise result.ia unless result.ia.nil? return end |
#recv_scannerGet ⇒ Object
516 517 518 519 520 521 522 |
# File 'lib/thrift/hbase.rb', line 516 def recv_scannerGet() result = (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
533 534 535 536 537 538 539 |
# File 'lib/thrift/hbase.rb', line 533 def recv_scannerGetList() result = (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
436 437 438 439 440 441 |
# File 'lib/thrift/hbase.rb', line 436 def recv_scannerOpen() result = (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
484 485 486 487 488 489 |
# File 'lib/thrift/hbase.rb', line 484 def recv_scannerOpenTs() result = (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
468 469 470 471 472 473 |
# File 'lib/thrift/hbase.rb', line 468 def recv_scannerOpenWithPrefix() result = (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
452 453 454 455 456 457 |
# File 'lib/thrift/hbase.rb', line 452 def recv_scannerOpenWithStop() result = (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
500 501 502 503 504 505 |
# File 'lib/thrift/hbase.rb', line 500 def recv_scannerOpenWithStopTs() result = (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, ) send_scannerOpenTs(tableName, startRow, columns, ) 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, ) send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, ) 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) ('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) ('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) ('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) ('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) ('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, ) ('deleteAllRowTs', DeleteAllRowTs_args, :tableName => tableName, :row => row, :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, ) ('deleteAllTs', DeleteAllTs_args, :tableName => tableName, :row => row, :column => column, :timestamp => ) end |
#send_deleteTable(tableName) ⇒ Object
164 165 166 |
# File 'lib/thrift/hbase.rb', line 164 def send_deleteTable(tableName) ('deleteTable', DeleteTable_args, :tableName => tableName) end |
#send_disableTable(tableName) ⇒ Object
38 39 40 |
# File 'lib/thrift/hbase.rb', line 38 def send_disableTable(tableName) ('disableTable', DisableTable_args, :tableName => tableName) end |
#send_enableTable(tableName) ⇒ Object
23 24 25 |
# File 'lib/thrift/hbase.rb', line 23 def send_enableTable(tableName) ('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) ('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) ('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) ('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, ) ('getRowTs', GetRowTs_args, :tableName => tableName, :row => row, :timestamp => ) end |
#send_getRowWithColumns(tableName, row, columns) ⇒ Object
243 244 245 |
# File 'lib/thrift/hbase.rb', line 243 def send_getRowWithColumns(tableName, row, columns) ('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, ) ('getRowWithColumnsTs', GetRowWithColumnsTs_args, :tableName => tableName, :row => row, :columns => columns, :timestamp => ) end |
#send_getTableNames ⇒ Object
99 100 101 |
# File 'lib/thrift/hbase.rb', line 99 def send_getTableNames() ('getTableNames', GetTableNames_args) end |
#send_getTableRegions(tableName) ⇒ Object
131 132 133 |
# File 'lib/thrift/hbase.rb', line 131 def send_getTableRegions(tableName) ('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) ('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, , numVersions) ('getVerTs', GetVerTs_args, :tableName => tableName, :row => row, :column => column, :timestamp => , :numVersions => numVersions) end |
#send_isTableEnabled(tableName) ⇒ Object
53 54 55 |
# File 'lib/thrift/hbase.rb', line 53 def send_isTableEnabled(tableName) ('isTableEnabled', IsTableEnabled_args, :tableName => tableName) end |
#send_majorCompact(tableNameOrRegionName) ⇒ Object
84 85 86 |
# File 'lib/thrift/hbase.rb', line 84 def send_majorCompact(tableNameOrRegionName) ('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) ('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) ('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, ) ('mutateRowsTs', MutateRowsTs_args, :tableName => tableName, :rowBatches => rowBatches, :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, ) ('mutateRowTs', MutateRowTs_args, :tableName => tableName, :row => row, :mutations => mutations, :timestamp => ) end |
#send_scannerClose(id) ⇒ Object
546 547 548 |
# File 'lib/thrift/hbase.rb', line 546 def send_scannerClose(id) ('scannerClose', ScannerClose_args, :id => id) end |
#send_scannerGet(id) ⇒ Object
512 513 514 |
# File 'lib/thrift/hbase.rb', line 512 def send_scannerGet(id) ('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) ('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) ('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, ) ('scannerOpenTs', ScannerOpenTs_args, :tableName => tableName, :startRow => startRow, :columns => columns, :timestamp => ) end |
#send_scannerOpenWithPrefix(tableName, startAndPrefix, columns) ⇒ Object
464 465 466 |
# File 'lib/thrift/hbase.rb', line 464 def send_scannerOpenWithPrefix(tableName, startAndPrefix, columns) ('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) ('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, ) ('scannerOpenWithStopTs', ScannerOpenWithStopTs_args, :tableName => tableName, :startRow => startRow, :stopRow => stopRow, :columns => columns, :timestamp => ) end |