Class: Apache::Hadoop::Hbase::Thrift2::THBaseService::Client

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

Instance Method Summary collapse

Instance Method Details

#append(table, tappend) ⇒ Object 



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

def append(table, tappend)
  send_append(table, tappend)
  return recv_append()
end

#checkAndDelete(table, row, family, qualifier, value, tdelete) ⇒ Object 



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

def checkAndDelete(table, row, family, qualifier, value, tdelete)
  send_checkAndDelete(table, row, family, qualifier, value, tdelete)
  return recv_checkAndDelete()
end

#checkAndPut(table, row, family, qualifier, value, tput) ⇒ Object 



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

def checkAndPut(table, row, family, qualifier, value, tput)
  send_checkAndPut(table, row, family, qualifier, value, tput)
  return recv_checkAndPut()
end

#closeScanner(scannerId) ⇒ Object 



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

def closeScanner(scannerId)
  send_closeScanner(scannerId)
  recv_closeScanner()
end

#deleteMultiple(table, tdeletes) ⇒ Object 



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

def deleteMultiple(table, tdeletes)
  send_deleteMultiple(table, tdeletes)
  return recv_deleteMultiple()
end

#deleteSingle(table, tdelete) ⇒ Object 



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

def deleteSingle(table, tdelete)
  send_deleteSingle(table, tdelete)
  recv_deleteSingle()
end

#exists(table, tget) ⇒ Object 



17
18
19
20
 
# File 'lib/hbase/t_h_base_service.rb', line 17

def exists(table, tget)
  send_exists(table, tget)
  return recv_exists()
end

#get(table, tget) ⇒ Object 



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

def get(table, tget)
  send_get(table, tget)
  return recv_get()
end

#getAllRegionLocations(table) ⇒ Object 



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

def getAllRegionLocations(table)
  send_getAllRegionLocations(table)
  return recv_getAllRegionLocations()
end

#getMultiple(table, tgets) ⇒ Object 



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

def getMultiple(table, tgets)
  send_getMultiple(table, tgets)
  return recv_getMultiple()
end

#getRegionLocation(table, row, reload) ⇒ Object 



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

def getRegionLocation(table, row, reload)
  send_getRegionLocation(table, row, reload)
  return recv_getRegionLocation()
end

#getScannerResults(table, tscan, numRows) ⇒ Object 



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

def getScannerResults(table, tscan, numRows)
  send_getScannerResults(table, tscan, numRows)
  return recv_getScannerResults()
end

#getScannerRows(scannerId, numRows) ⇒ Object 



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

def getScannerRows(scannerId, numRows)
  send_getScannerRows(scannerId, numRows)
  return recv_getScannerRows()
end

#increment(table, tincrement) ⇒ Object 



158
159
160
161
 
# File 'lib/hbase/t_h_base_service.rb', line 158

def increment(table, tincrement)
  send_increment(table, tincrement)
  return recv_increment()
end

#mutateRow(table, trowMutations) ⇒ Object 



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

def mutateRow(table, trowMutations)
  send_mutateRow(table, trowMutations)
  recv_mutateRow()
end

#openScanner(table, tscan) ⇒ Object 



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

def openScanner(table, tscan)
  send_openScanner(table, tscan)
  return recv_openScanner()
end

#put(table, tput) ⇒ Object 



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

def put(table, tput)
  send_put(table, tput)
  recv_put()
end

#putMultiple(table, tputs) ⇒ Object 



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

def putMultiple(table, tputs)
  send_putMultiple(table, tputs)
  recv_putMultiple()
end

#recv_append ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_checkAndDelete ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_checkAndPut ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


89
90
91
92
93
94
 
# File 'lib/hbase/t_h_base_service.rb', line 89

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

#recv_closeScanner ⇒ Object 



232
233
234
235
236
237
 
# File 'lib/hbase/t_h_base_service.rb', line 232

def recv_closeScanner()
  result = receive_message(CloseScanner_result)
  raise result.io unless result.io.nil?
  raise result.ia unless result.ia.nil?
  return
end

#recv_deleteMultiple ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_deleteSingle ⇒ Object 



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

def recv_deleteSingle()
  result = receive_message(DeleteSingle_result)
  raise result.io unless result.io.nil?
  return
end

#recv_exists ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_get ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_getMultiple ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


58
59
60
61
62
63
 
# File 'lib/hbase/t_h_base_service.rb', line 58

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

#recv_getRegionLocation ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_getScannerResults ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_getScannerRows ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_getScannerRows()
  result = receive_message(GetScannerRows_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, 'getScannerRows failed: unknown result')
end

#recv_increment ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_mutateRow ⇒ Object 



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

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

#recv_openScanner ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

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

#recv_put ⇒ Object 



74
75
76
77
78
 
# File 'lib/hbase/t_h_base_service.rb', line 74

def recv_put()
  result = receive_message(Put_result)
  raise result.io unless result.io.nil?
  return
end

#recv_putMultiple ⇒ Object 



105
106
107
108
109
 
# File 'lib/hbase/t_h_base_service.rb', line 105

def recv_putMultiple()
  result = receive_message(PutMultiple_result)
  raise result.io unless result.io.nil?
  return
end

#send_append(table, tappend) ⇒ Object 



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

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

#send_checkAndDelete(table, row, family, qualifier, value, tdelete) ⇒ Object 



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

def send_checkAndDelete(table, row, family, qualifier, value, tdelete)
  send_message('checkAndDelete', CheckAndDelete_args, :table => table, :row => row, :family => family, :qualifier => qualifier, :value => value, :tdelete => tdelete)
end

#send_checkAndPut(table, row, family, qualifier, value, tput) ⇒ Object 



85
86
87
 
# File 'lib/hbase/t_h_base_service.rb', line 85

def send_checkAndPut(table, row, family, qualifier, value, tput)
  send_message('checkAndPut', CheckAndPut_args, :table => table, :row => row, :family => family, :qualifier => qualifier, :value => value, :tput => tput)
end

#send_closeScanner(scannerId) ⇒ Object 



228
229
230
 
# File 'lib/hbase/t_h_base_service.rb', line 228

def send_closeScanner(scannerId)
  send_message('closeScanner', CloseScanner_args, :scannerId => scannerId)
end

#send_deleteMultiple(table, tdeletes) ⇒ Object 



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

def send_deleteMultiple(table, tdeletes)
  send_message('deleteMultiple', DeleteMultiple_args, :table => table, :tdeletes => tdeletes)
end

#send_deleteSingle(table, tdelete) ⇒ Object 



116
117
118
 
# File 'lib/hbase/t_h_base_service.rb', line 116

def send_deleteSingle(table, tdelete)
  send_message('deleteSingle', DeleteSingle_args, :table => table, :tdelete => tdelete)
end

#send_exists(table, tget) ⇒ Object 



22
23
24
 
# File 'lib/hbase/t_h_base_service.rb', line 22

def send_exists(table, tget)
  send_message('exists', Exists_args, :table => table, :tget => tget)
end

#send_get(table, tget) ⇒ Object 



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

def send_get(table, tget)
  send_message('get', Get_args, :table => table, :tget => tget)
end

#send_getAllRegionLocations(table) ⇒ Object 



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

def send_getAllRegionLocations(table)
  send_message('getAllRegionLocations', GetAllRegionLocations_args, :table => table)
end

#send_getMultiple(table, tgets) ⇒ Object 



54
55
56
 
# File 'lib/hbase/t_h_base_service.rb', line 54

def send_getMultiple(table, tgets)
  send_message('getMultiple', GetMultiple_args, :table => table, :tgets => tgets)
end

#send_getRegionLocation(table, row, reload) ⇒ Object 



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

def send_getRegionLocation(table, row, reload)
  send_message('getRegionLocation', GetRegionLocation_args, :table => table, :row => row, :reload => reload)
end

#send_getScannerResults(table, tscan, numRows) ⇒ Object 



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

def send_getScannerResults(table, tscan, numRows)
  send_message('getScannerResults', GetScannerResults_args, :table => table, :tscan => tscan, :numRows => numRows)
end

#send_getScannerRows(scannerId, numRows) ⇒ Object 



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

def send_getScannerRows(scannerId, numRows)
  send_message('getScannerRows', GetScannerRows_args, :scannerId => scannerId, :numRows => numRows)
end

#send_increment(table, tincrement) ⇒ Object 



163
164
165
 
# File 'lib/hbase/t_h_base_service.rb', line 163

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

#send_mutateRow(table, trowMutations) ⇒ Object 



244
245
246
 
# File 'lib/hbase/t_h_base_service.rb', line 244

def send_mutateRow(table, trowMutations)
  send_message('mutateRow', MutateRow_args, :table => table, :trowMutations => trowMutations)
end

#send_openScanner(table, tscan) ⇒ Object 



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

def send_openScanner(table, tscan)
  send_message('openScanner', OpenScanner_args, :table => table, :tscan => tscan)
end

#send_put(table, tput) ⇒ Object 



70
71
72
 
# File 'lib/hbase/t_h_base_service.rb', line 70

def send_put(table, tput)
  send_message('put', Put_args, :table => table, :tput => tput)
end

#send_putMultiple(table, tputs) ⇒ Object 



101
102
103
 
# File 'lib/hbase/t_h_base_service.rb', line 101

def send_putMultiple(table, tputs)
  send_message('putMultiple', PutMultiple_args, :table => table, :tputs => tputs)
end