Class: Hadoop::API::Jobtracker::Jobtracker::Client

Inherits:
HadoopServiceBase::Client show all
Includes:
Thrift::Client
Defined in:
lib/thrift/jobtracker.rb

Instance Method Summary collapse

Methods inherited from HadoopServiceBase::Client

#getAllMetrics, #getMetricsContext, #getRuntimeInfo, #getThreadDump, #getVersionInfo, #recv_getAllMetrics, #recv_getMetricsContext, #recv_getRuntimeInfo, #recv_getThreadDump, #recv_getVersionInfo, #send_getAllMetrics, #send_getMetricsContext, #send_getRuntimeInfo, #send_getThreadDump, #send_getVersionInfo

Instance Method Details

#getActiveTrackers(ctx) ⇒ Object 



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

def getActiveTrackers(ctx)
  send_getActiveTrackers(ctx)
  return recv_getActiveTrackers()
end

#getAllJobs(ctx) ⇒ Object 



140
141
142
143
 
# File 'lib/thrift/jobtracker.rb', line 140

def getAllJobs(ctx)
  send_getAllJobs(ctx)
  return recv_getAllJobs()
end

#getAllTrackers(ctx) ⇒ Object 



265
266
267
268
 
# File 'lib/thrift/jobtracker.rb', line 265

def getAllTrackers(ctx)
  send_getAllTrackers(ctx)
  return recv_getAllTrackers()
end

#getBlacklistedTrackers(ctx) ⇒ Object 



250
251
252
253
 
# File 'lib/thrift/jobtracker.rb', line 250

def getBlacklistedTrackers(ctx)
  send_getBlacklistedTrackers(ctx)
  return recv_getBlacklistedTrackers()
end

#getClusterStatus(ctx) ⇒ Object 



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

def getClusterStatus(ctx)
  send_getClusterStatus(ctx)
  return recv_getClusterStatus()
end

#getCompletedJobs(ctx) ⇒ Object 



95
96
97
98
 
# File 'lib/thrift/jobtracker.rb', line 95

def getCompletedJobs(ctx)
  send_getCompletedJobs(ctx)
  return recv_getCompletedJobs()
end

#getCurrentTime(ctx) ⇒ Object 



296
297
298
299
 
# File 'lib/thrift/jobtracker.rb', line 296

def getCurrentTime(ctx)
  send_getCurrentTime(ctx)
  return recv_getCurrentTime()
end

#getDelegationToken(ctx, renewer) ⇒ Object 



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

def getDelegationToken(ctx, renewer)
  send_getDelegationToken(ctx, renewer)
  return recv_getDelegationToken()
end

#getFailedJobs(ctx) ⇒ Object 



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

def getFailedJobs(ctx)
  send_getFailedJobs(ctx)
  return recv_getFailedJobs()
end

#getJob(ctx, jobID) ⇒ Object 



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

def getJob(ctx, jobID)
  send_getJob(ctx, jobID)
  return recv_getJob()
end

#getJobConfXML(ctx, jobID) ⇒ Object 



311
312
313
314
 
# File 'lib/thrift/jobtracker.rb', line 311

def getJobConfXML(ctx, jobID)
  send_getJobConfXML(ctx, jobID)
  return recv_getJobConfXML()
end

#getJobCounterRollups(ctx, jobID) ⇒ Object 



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

def getJobCounterRollups(ctx, jobID)
  send_getJobCounterRollups(ctx, jobID)
  return recv_getJobCounterRollups()
end

#getJobCounters(ctx, jobID) ⇒ Object 



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

def getJobCounters(ctx, jobID)
  send_getJobCounters(ctx, jobID)
  return recv_getJobCounters()
end

#getJobTrackerName(ctx) ⇒ Object 



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

def getJobTrackerName(ctx)
  send_getJobTrackerName(ctx)
  return recv_getJobTrackerName()
end

#getKilledJobs(ctx) ⇒ Object 



125
126
127
128
 
# File 'lib/thrift/jobtracker.rb', line 125

def getKilledJobs(ctx)
  send_getKilledJobs(ctx)
  return recv_getKilledJobs()
end

#getQueues(ctx) ⇒ Object 



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

def getQueues(ctx)
  send_getQueues(ctx)
  return recv_getQueues()
end

#getRunningJobs(ctx) ⇒ Object 



80
81
82
83
 
# File 'lib/thrift/jobtracker.rb', line 80

def getRunningJobs(ctx)
  send_getRunningJobs(ctx)
  return recv_getRunningJobs()
end

#getTask(ctx, taskID) ⇒ Object 



186
187
188
189
 
# File 'lib/thrift/jobtracker.rb', line 186

def getTask(ctx, taskID)
  send_getTask(ctx, taskID)
  return recv_getTask()
end

#getTaskList(ctx, jobID, types, states, text, count, offset) ⇒ Object 



170
171
172
173
 
# File 'lib/thrift/jobtracker.rb', line 170

def getTaskList(ctx, jobID, types, states, text, count, offset)
  send_getTaskList(ctx, jobID, types, states, text, count, offset)
  return recv_getTaskList()
end

#getTracker(ctx, name) ⇒ Object 



280
281
282
283
 
# File 'lib/thrift/jobtracker.rb', line 280

def getTracker(ctx, name)
  send_getTracker(ctx, name)
  return recv_getTracker()
end

#getUserJobCounts(ctx, user) ⇒ Object 



155
156
157
158
 
# File 'lib/thrift/jobtracker.rb', line 155

def getUserJobCounts(ctx, user)
  send_getUserJobCounts(ctx, user)
  return recv_getUserJobCounts()
end

#killJob(ctx, jobID) ⇒ Object 



327
328
329
330
 
# File 'lib/thrift/jobtracker.rb', line 327

def killJob(ctx, jobID)
  send_killJob(ctx, jobID)
  recv_killJob()
end

#killTaskAttempt(ctx, attemptID) ⇒ Object 



343
344
345
346
 
# File 'lib/thrift/jobtracker.rb', line 343

def killTaskAttempt(ctx, attemptID)
  send_killTaskAttempt(ctx, attemptID)
  recv_killTaskAttempt()
end

#recv_getActiveTrackers ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


244
245
246
247
248
 
# File 'lib/thrift/jobtracker.rb', line 244

def recv_getActiveTrackers()
  result = receive_message(GetActiveTrackers_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getActiveTrackers failed: unknown result')
end

#recv_getAllJobs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


149
150
151
152
153
 
# File 'lib/thrift/jobtracker.rb', line 149

def recv_getAllJobs()
  result = receive_message(GetAllJobs_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getAllJobs failed: unknown result')
end

#recv_getAllTrackers ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


274
275
276
277
278
 
# File 'lib/thrift/jobtracker.rb', line 274

def recv_getAllTrackers()
  result = receive_message(GetAllTrackers_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getAllTrackers failed: unknown result')
end

#recv_getBlacklistedTrackers ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


259
260
261
262
263
 
# File 'lib/thrift/jobtracker.rb', line 259

def recv_getBlacklistedTrackers()
  result = receive_message(GetBlacklistedTrackers_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getBlacklistedTrackers failed: unknown result')
end

#recv_getClusterStatus ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_getClusterStatus()
  result = receive_message(GetClusterStatus_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getClusterStatus failed: unknown result')
end

#recv_getCompletedJobs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_getCompletedJobs()
  result = receive_message(GetCompletedJobs_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getCompletedJobs failed: unknown result')
end

#recv_getCurrentTime ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


305
306
307
308
309
 
# File 'lib/thrift/jobtracker.rb', line 305

def recv_getCurrentTime()
  result = receive_message(GetCurrentTime_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getCurrentTime failed: unknown result')
end

#recv_getDelegationToken ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


385
386
387
388
389
390
 
# File 'lib/thrift/jobtracker.rb', line 385

def recv_getDelegationToken()
  result = receive_message(GetDelegationToken_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getDelegationToken failed: unknown result')
end

#recv_getFailedJobs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_getFailedJobs()
  result = receive_message(GetFailedJobs_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getFailedJobs failed: unknown result')
end

#recv_getJob ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_getJob()
  result = receive_message(GetJob_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getJob failed: unknown result')
end

#recv_getJobConfXML ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


320
321
322
323
324
325
 
# File 'lib/thrift/jobtracker.rb', line 320

def recv_getJobConfXML()
  result = receive_message(GetJobConfXML_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getJobConfXML failed: unknown result')
end

#recv_getJobCounterRollups ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


228
229
230
231
232
233
 
# File 'lib/thrift/jobtracker.rb', line 228

def recv_getJobCounterRollups()
  result = receive_message(GetJobCounterRollups_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getJobCounterRollups failed: unknown result')
end

#recv_getJobCounters ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


212
213
214
215
216
217
 
# File 'lib/thrift/jobtracker.rb', line 212

def recv_getJobCounters()
  result = receive_message(GetJobCounters_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getJobCounters failed: unknown result')
end

#recv_getJobTrackerName ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_getJobTrackerName()
  result = receive_message(GetJobTrackerName_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getJobTrackerName failed: unknown result')
end

#recv_getKilledJobs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


134
135
136
137
138
 
# File 'lib/thrift/jobtracker.rb', line 134

def recv_getKilledJobs()
  result = receive_message(GetKilledJobs_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getKilledJobs failed: unknown result')
end

#recv_getQueues ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_getQueues()
  result = receive_message(GetQueues_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getQueues failed: unknown result')
end

#recv_getRunningJobs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


89
90
91
92
93
 
# File 'lib/thrift/jobtracker.rb', line 89

def recv_getRunningJobs()
  result = receive_message(GetRunningJobs_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRunningJobs failed: unknown result')
end

#recv_getTask ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


195
196
197
198
199
200
201
 
# File 'lib/thrift/jobtracker.rb', line 195

def recv_getTask()
  result = receive_message(GetTask_result)
  return result.success unless result.success.nil?
  raise result.jnf unless result.jnf.nil?
  raise result.tnf unless result.tnf.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTask failed: unknown result')
end

#recv_getTaskList ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


179
180
181
182
183
184
 
# File 'lib/thrift/jobtracker.rb', line 179

def recv_getTaskList()
  result = receive_message(GetTaskList_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTaskList failed: unknown result')
end

#recv_getTracker ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


289
290
291
292
293
294
 
# File 'lib/thrift/jobtracker.rb', line 289

def recv_getTracker()
  result = receive_message(GetTracker_result)
  return result.success unless result.success.nil?
  raise result.tne unless result.tne.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTracker failed: unknown result')
end

#recv_getUserJobCounts ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


164
165
166
167
168
 
# File 'lib/thrift/jobtracker.rb', line 164

def recv_getUserJobCounts()
  result = receive_message(GetUserJobCounts_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getUserJobCounts failed: unknown result')
end

#recv_killJob ⇒ Object 



336
337
338
339
340
341
 
# File 'lib/thrift/jobtracker.rb', line 336

def recv_killJob()
  result = receive_message(KillJob_result)
  raise result.err unless result.err.nil?
  raise result.jne unless result.jne.nil?
  return
end

#recv_killTaskAttempt ⇒ Object 



352
353
354
355
356
357
358
 
# File 'lib/thrift/jobtracker.rb', line 352

def recv_killTaskAttempt()
  result = receive_message(KillTaskAttempt_result)
  raise result.err unless result.err.nil?
  raise result.tne unless result.tne.nil?
  raise result.jne unless result.jne.nil?
  return
end

#recv_setJobPriority ⇒ Object 



369
370
371
372
373
374
 
# File 'lib/thrift/jobtracker.rb', line 369

def recv_setJobPriority()
  result = receive_message(SetJobPriority_result)
  raise result.err unless result.err.nil?
  raise result.jne unless result.jne.nil?
  return
end

#send_getActiveTrackers(ctx) ⇒ Object 



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

def send_getActiveTrackers(ctx)
  send_message('getActiveTrackers', GetActiveTrackers_args, :ctx => ctx)
end

#send_getAllJobs(ctx) ⇒ Object 



145
146
147
 
# File 'lib/thrift/jobtracker.rb', line 145

def send_getAllJobs(ctx)
  send_message('getAllJobs', GetAllJobs_args, :ctx => ctx)
end

#send_getAllTrackers(ctx) ⇒ Object 



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

def send_getAllTrackers(ctx)
  send_message('getAllTrackers', GetAllTrackers_args, :ctx => ctx)
end

#send_getBlacklistedTrackers(ctx) ⇒ Object 



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

def send_getBlacklistedTrackers(ctx)
  send_message('getBlacklistedTrackers', GetBlacklistedTrackers_args, :ctx => ctx)
end

#send_getClusterStatus(ctx) ⇒ Object 



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

def send_getClusterStatus(ctx)
  send_message('getClusterStatus', GetClusterStatus_args, :ctx => ctx)
end

#send_getCompletedJobs(ctx) ⇒ Object 



100
101
102
 
# File 'lib/thrift/jobtracker.rb', line 100

def send_getCompletedJobs(ctx)
  send_message('getCompletedJobs', GetCompletedJobs_args, :ctx => ctx)
end

#send_getCurrentTime(ctx) ⇒ Object 



301
302
303
 
# File 'lib/thrift/jobtracker.rb', line 301

def send_getCurrentTime(ctx)
  send_message('getCurrentTime', GetCurrentTime_args, :ctx => ctx)
end

#send_getDelegationToken(ctx, renewer) ⇒ Object 



381
382
383
 
# File 'lib/thrift/jobtracker.rb', line 381

def send_getDelegationToken(ctx, renewer)
  send_message('getDelegationToken', GetDelegationToken_args, :ctx => ctx, :renewer => renewer)
end

#send_getFailedJobs(ctx) ⇒ Object 



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

def send_getFailedJobs(ctx)
  send_message('getFailedJobs', GetFailedJobs_args, :ctx => ctx)
end

#send_getJob(ctx, jobID) ⇒ Object 



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

def send_getJob(ctx, jobID)
  send_message('getJob', GetJob_args, :ctx => ctx, :jobID => jobID)
end

#send_getJobConfXML(ctx, jobID) ⇒ Object 



316
317
318
 
# File 'lib/thrift/jobtracker.rb', line 316

def send_getJobConfXML(ctx, jobID)
  send_message('getJobConfXML', GetJobConfXML_args, :ctx => ctx, :jobID => jobID)
end

#send_getJobCounterRollups(ctx, jobID) ⇒ Object 



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

def send_getJobCounterRollups(ctx, jobID)
  send_message('getJobCounterRollups', GetJobCounterRollups_args, :ctx => ctx, :jobID => jobID)
end

#send_getJobCounters(ctx, jobID) ⇒ Object 



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

def send_getJobCounters(ctx, jobID)
  send_message('getJobCounters', GetJobCounters_args, :ctx => ctx, :jobID => jobID)
end

#send_getJobTrackerName(ctx) ⇒ Object 



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

def send_getJobTrackerName(ctx)
  send_message('getJobTrackerName', GetJobTrackerName_args, :ctx => ctx)
end

#send_getKilledJobs(ctx) ⇒ Object 



130
131
132
 
# File 'lib/thrift/jobtracker.rb', line 130

def send_getKilledJobs(ctx)
  send_message('getKilledJobs', GetKilledJobs_args, :ctx => ctx)
end

#send_getQueues(ctx) ⇒ Object 



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

def send_getQueues(ctx)
  send_message('getQueues', GetQueues_args, :ctx => ctx)
end

#send_getRunningJobs(ctx) ⇒ Object 



85
86
87
 
# File 'lib/thrift/jobtracker.rb', line 85

def send_getRunningJobs(ctx)
  send_message('getRunningJobs', GetRunningJobs_args, :ctx => ctx)
end

#send_getTask(ctx, taskID) ⇒ Object 



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

def send_getTask(ctx, taskID)
  send_message('getTask', GetTask_args, :ctx => ctx, :taskID => taskID)
end

#send_getTaskList(ctx, jobID, types, states, text, count, offset) ⇒ Object 



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

def send_getTaskList(ctx, jobID, types, states, text, count, offset)
  send_message('getTaskList', GetTaskList_args, :ctx => ctx, :jobID => jobID, :types => types, :states => states, :text => text, :count => count, :offset => offset)
end

#send_getTracker(ctx, name) ⇒ Object 



285
286
287
 
# File 'lib/thrift/jobtracker.rb', line 285

def send_getTracker(ctx, name)
  send_message('getTracker', GetTracker_args, :ctx => ctx, :name => name)
end

#send_getUserJobCounts(ctx, user) ⇒ Object 



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

def send_getUserJobCounts(ctx, user)
  send_message('getUserJobCounts', GetUserJobCounts_args, :ctx => ctx, :user => user)
end

#send_killJob(ctx, jobID) ⇒ Object 



332
333
334
 
# File 'lib/thrift/jobtracker.rb', line 332

def send_killJob(ctx, jobID)
  send_message('killJob', KillJob_args, :ctx => ctx, :jobID => jobID)
end

#send_killTaskAttempt(ctx, attemptID) ⇒ Object 



348
349
350
 
# File 'lib/thrift/jobtracker.rb', line 348

def send_killTaskAttempt(ctx, attemptID)
  send_message('killTaskAttempt', KillTaskAttempt_args, :ctx => ctx, :attemptID => attemptID)
end

#send_setJobPriority(ctx, jobID, priority) ⇒ Object 



365
366
367
 
# File 'lib/thrift/jobtracker.rb', line 365

def send_setJobPriority(ctx, jobID, priority)
  send_message('setJobPriority', SetJobPriority_args, :ctx => ctx, :jobID => jobID, :priority => priority)
end

#setJobPriority(ctx, jobID, priority) ⇒ Object 



360
361
362
363
 
# File 'lib/thrift/jobtracker.rb', line 360

def setJobPriority(ctx, jobID, priority)
  send_setJobPriority(ctx, jobID, priority)
  recv_setJobPriority()
end