Class: Hadoop::API::Jobtracker::Jobtracker::Processor

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

Instance Method Summary collapse

Methods inherited from HadoopServiceBase::Processor

#process_getAllMetrics, #process_getMetricsContext, #process_getRuntimeInfo, #process_getThreadDump, #process_getVersionInfo

Instance Method Details

#process_getActiveTrackers(seqid, iprot, oprot) ⇒ Object 



521
522
523
524
525
526
 
# File 'lib/thrift/jobtracker.rb', line 521

def process_getActiveTrackers(seqid, iprot, oprot)
  args = read_args(iprot, GetActiveTrackers_args)
  result = GetActiveTrackers_result.new()
  result.success = @handler.getActiveTrackers(args.ctx)
  write_result(result, oprot, 'getActiveTrackers', seqid)
end

#process_getAllJobs(seqid, iprot, oprot) ⇒ Object 



461
462
463
464
465
466
 
# File 'lib/thrift/jobtracker.rb', line 461

def process_getAllJobs(seqid, iprot, oprot)
  args = read_args(iprot, GetAllJobs_args)
  result = GetAllJobs_result.new()
  result.success = @handler.getAllJobs(args.ctx)
  write_result(result, oprot, 'getAllJobs', seqid)
end

#process_getAllTrackers(seqid, iprot, oprot) ⇒ Object 



535
536
537
538
539
540
 
# File 'lib/thrift/jobtracker.rb', line 535

def process_getAllTrackers(seqid, iprot, oprot)
  args = read_args(iprot, GetAllTrackers_args)
  result = GetAllTrackers_result.new()
  result.success = @handler.getAllTrackers(args.ctx)
  write_result(result, oprot, 'getAllTrackers', seqid)
end

#process_getBlacklistedTrackers(seqid, iprot, oprot) ⇒ Object 



528
529
530
531
532
533
 
# File 'lib/thrift/jobtracker.rb', line 528

def process_getBlacklistedTrackers(seqid, iprot, oprot)
  args = read_args(iprot, GetBlacklistedTrackers_args)
  result = GetBlacklistedTrackers_result.new()
  result.success = @handler.getBlacklistedTrackers(args.ctx)
  write_result(result, oprot, 'getBlacklistedTrackers', seqid)
end

#process_getClusterStatus(seqid, iprot, oprot) ⇒ Object 



404
405
406
407
408
409
 
# File 'lib/thrift/jobtracker.rb', line 404

def process_getClusterStatus(seqid, iprot, oprot)
  args = read_args(iprot, GetClusterStatus_args)
  result = GetClusterStatus_result.new()
  result.success = @handler.getClusterStatus(args.ctx)
  write_result(result, oprot, 'getClusterStatus', seqid)
end

#process_getCompletedJobs(seqid, iprot, oprot) ⇒ Object 



440
441
442
443
444
445
 
# File 'lib/thrift/jobtracker.rb', line 440

def process_getCompletedJobs(seqid, iprot, oprot)
  args = read_args(iprot, GetCompletedJobs_args)
  result = GetCompletedJobs_result.new()
  result.success = @handler.getCompletedJobs(args.ctx)
  write_result(result, oprot, 'getCompletedJobs', seqid)
end

#process_getCurrentTime(seqid, iprot, oprot) ⇒ Object 



553
554
555
556
557
558
 
# File 'lib/thrift/jobtracker.rb', line 553

def process_getCurrentTime(seqid, iprot, oprot)
  args = read_args(iprot, GetCurrentTime_args)
  result = GetCurrentTime_result.new()
  result.success = @handler.getCurrentTime(args.ctx)
  write_result(result, oprot, 'getCurrentTime', seqid)
end

#process_getDelegationToken(seqid, iprot, oprot) ⇒ Object 



612
613
614
615
616
617
618
619
620
621
 
# File 'lib/thrift/jobtracker.rb', line 612

def process_getDelegationToken(seqid, iprot, oprot)
  args = read_args(iprot, GetDelegationToken_args)
  result = GetDelegationToken_result.new()
  begin
    result.success = @handler.getDelegationToken(args.ctx, args.renewer)
  rescue Hadoop::API::IOException => err
    result.err = err
  end
  write_result(result, oprot, 'getDelegationToken', seqid)
end

#process_getFailedJobs(seqid, iprot, oprot) ⇒ Object 



447
448
449
450
451
452
 
# File 'lib/thrift/jobtracker.rb', line 447

def process_getFailedJobs(seqid, iprot, oprot)
  args = read_args(iprot, GetFailedJobs_args)
  result = GetFailedJobs_result.new()
  result.success = @handler.getFailedJobs(args.ctx)
  write_result(result, oprot, 'getFailedJobs', seqid)
end

#process_getJob(seqid, iprot, oprot) ⇒ Object 



422
423
424
425
426
427
428
429
430
431
 
# File 'lib/thrift/jobtracker.rb', line 422

def process_getJob(seqid, iprot, oprot)
  args = read_args(iprot, GetJob_args)
  result = GetJob_result.new()
  begin
    result.success = @handler.getJob(args.ctx, args.jobID)
  rescue Hadoop::API::Jobtracker::JobNotFoundException => err
    result.err = err
  end
  write_result(result, oprot, 'getJob', seqid)
end

#process_getJobConfXML(seqid, iprot, oprot) ⇒ Object 



560
561
562
563
564
565
566
567
568
569
 
# File 'lib/thrift/jobtracker.rb', line 560

def process_getJobConfXML(seqid, iprot, oprot)
  args = read_args(iprot, GetJobConfXML_args)
  result = GetJobConfXML_result.new()
  begin
    result.success = @handler.getJobConfXML(args.ctx, args.jobID)
  rescue Hadoop::API::IOException => err
    result.err = err
  end
  write_result(result, oprot, 'getJobConfXML', seqid)
end

#process_getJobCounterRollups(seqid, iprot, oprot) ⇒ Object 



510
511
512
513
514
515
516
517
518
519
 
# File 'lib/thrift/jobtracker.rb', line 510

def process_getJobCounterRollups(seqid, iprot, oprot)
  args = read_args(iprot, GetJobCounterRollups_args)
  result = GetJobCounterRollups_result.new()
  begin
    result.success = @handler.getJobCounterRollups(args.ctx, args.jobID)
  rescue Hadoop::API::Jobtracker::JobNotFoundException => err
    result.err = err
  end
  write_result(result, oprot, 'getJobCounterRollups', seqid)
end

#process_getJobCounters(seqid, iprot, oprot) ⇒ Object 



499
500
501
502
503
504
505
506
507
508
 
# File 'lib/thrift/jobtracker.rb', line 499

def process_getJobCounters(seqid, iprot, oprot)
  args = read_args(iprot, GetJobCounters_args)
  result = GetJobCounters_result.new()
  begin
    result.success = @handler.getJobCounters(args.ctx, args.jobID)
  rescue Hadoop::API::Jobtracker::JobNotFoundException => err
    result.err = err
  end
  write_result(result, oprot, 'getJobCounters', seqid)
end

#process_getJobTrackerName(seqid, iprot, oprot) ⇒ Object 



397
398
399
400
401
402
 
# File 'lib/thrift/jobtracker.rb', line 397

def process_getJobTrackerName(seqid, iprot, oprot)
  args = read_args(iprot, GetJobTrackerName_args)
  result = GetJobTrackerName_result.new()
  result.success = @handler.getJobTrackerName(args.ctx)
  write_result(result, oprot, 'getJobTrackerName', seqid)
end

#process_getKilledJobs(seqid, iprot, oprot) ⇒ Object 



454
455
456
457
458
459
 
# File 'lib/thrift/jobtracker.rb', line 454

def process_getKilledJobs(seqid, iprot, oprot)
  args = read_args(iprot, GetKilledJobs_args)
  result = GetKilledJobs_result.new()
  result.success = @handler.getKilledJobs(args.ctx)
  write_result(result, oprot, 'getKilledJobs', seqid)
end

#process_getQueues(seqid, iprot, oprot) ⇒ Object 



411
412
413
414
415
416
417
418
419
420
 
# File 'lib/thrift/jobtracker.rb', line 411

def process_getQueues(seqid, iprot, oprot)
  args = read_args(iprot, GetQueues_args)
  result = GetQueues_result.new()
  begin
    result.success = @handler.getQueues(args.ctx)
  rescue Hadoop::API::IOException => err
    result.err = err
  end
  write_result(result, oprot, 'getQueues', seqid)
end

#process_getRunningJobs(seqid, iprot, oprot) ⇒ Object 



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

def process_getRunningJobs(seqid, iprot, oprot)
  args = read_args(iprot, GetRunningJobs_args)
  result = GetRunningJobs_result.new()
  result.success = @handler.getRunningJobs(args.ctx)
  write_result(result, oprot, 'getRunningJobs', seqid)
end

#process_getTask(seqid, iprot, oprot) ⇒ Object 



486
487
488
489
490
491
492
493
494
495
496
497
 
# File 'lib/thrift/jobtracker.rb', line 486

def process_getTask(seqid, iprot, oprot)
  args = read_args(iprot, GetTask_args)
  result = GetTask_result.new()
  begin
    result.success = @handler.getTask(args.ctx, args.taskID)
  rescue Hadoop::API::Jobtracker::JobNotFoundException => jnf
    result.jnf = jnf
  rescue Hadoop::API::Jobtracker::TaskNotFoundException => tnf
    result.tnf = tnf
  end
  write_result(result, oprot, 'getTask', seqid)
end

#process_getTaskList(seqid, iprot, oprot) ⇒ Object 



475
476
477
478
479
480
481
482
483
484
 
# File 'lib/thrift/jobtracker.rb', line 475

def process_getTaskList(seqid, iprot, oprot)
  args = read_args(iprot, GetTaskList_args)
  result = GetTaskList_result.new()
  begin
    result.success = @handler.getTaskList(args.ctx, args.jobID, args.types, args.states, args.text, args.count, args.offset)
  rescue Hadoop::API::Jobtracker::JobNotFoundException => err
    result.err = err
  end
  write_result(result, oprot, 'getTaskList', seqid)
end

#process_getTracker(seqid, iprot, oprot) ⇒ Object 



542
543
544
545
546
547
548
549
550
551
 
# File 'lib/thrift/jobtracker.rb', line 542

def process_getTracker(seqid, iprot, oprot)
  args = read_args(iprot, GetTracker_args)
  result = GetTracker_result.new()
  begin
    result.success = @handler.getTracker(args.ctx, args.name)
  rescue Hadoop::API::Jobtracker::TaskTrackerNotFoundException => tne
    result.tne = tne
  end
  write_result(result, oprot, 'getTracker', seqid)
end

#process_getUserJobCounts(seqid, iprot, oprot) ⇒ Object 



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

def process_getUserJobCounts(seqid, iprot, oprot)
  args = read_args(iprot, GetUserJobCounts_args)
  result = GetUserJobCounts_result.new()
  result.success = @handler.getUserJobCounts(args.ctx, args.user)
  write_result(result, oprot, 'getUserJobCounts', seqid)
end

#process_killJob(seqid, iprot, oprot) ⇒ Object 



571
572
573
574
575
576
577
578
579
580
581
582
 
# File 'lib/thrift/jobtracker.rb', line 571

def process_killJob(seqid, iprot, oprot)
  args = read_args(iprot, KillJob_args)
  result = KillJob_result.new()
  begin
    @handler.killJob(args.ctx, args.jobID)
  rescue Hadoop::API::IOException => err
    result.err = err
  rescue Hadoop::API::Jobtracker::JobNotFoundException => jne
    result.jne = jne
  end
  write_result(result, oprot, 'killJob', seqid)
end

#process_killTaskAttempt(seqid, iprot, oprot) ⇒ Object 



584
585
586
587
588
589
590
591
592
593
594
595
596
597
 
# File 'lib/thrift/jobtracker.rb', line 584

def process_killTaskAttempt(seqid, iprot, oprot)
  args = read_args(iprot, KillTaskAttempt_args)
  result = KillTaskAttempt_result.new()
  begin
    @handler.killTaskAttempt(args.ctx, args.attemptID)
  rescue Hadoop::API::IOException => err
    result.err = err
  rescue Hadoop::API::Jobtracker::TaskAttemptNotFoundException => tne
    result.tne = tne
  rescue Hadoop::API::Jobtracker::JobNotFoundException => jne
    result.jne = jne
  end
  write_result(result, oprot, 'killTaskAttempt', seqid)
end

#process_setJobPriority(seqid, iprot, oprot) ⇒ Object 



599
600
601
602
603
604
605
606
607
608
609
610
 
# File 'lib/thrift/jobtracker.rb', line 599

def process_setJobPriority(seqid, iprot, oprot)
  args = read_args(iprot, SetJobPriority_args)
  result = SetJobPriority_result.new()
  begin
    @handler.setJobPriority(args.ctx, args.jobID, args.priority)
  rescue Hadoop::API::IOException => err
    result.err = err
  rescue Hadoop::API::Jobtracker::JobNotFoundException => jne
    result.jne = jne
  end
  write_result(result, oprot, 'setJobPriority', seqid)
end