mapreduce.js 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. /**
  2. * Licensed to the Apache Software Foundation (ASF) under one or more
  3. * contributor license agreements. See the NOTICE file distributed with this
  4. * work for additional information regarding copyright ownership. The ASF
  5. * licenses this file to you under the Apache License, Version 2.0 (the
  6. * "License"); you may not use this file except in compliance with the License.
  7. * You may obtain a copy of the License at
  8. *
  9. * http://www.apache.org/licenses/LICENSE-2.0
  10. *
  11. * Unless required by applicable law or agreed to in writing, software
  12. * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  13. * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  14. * License for the specific language governing permissions and limitations under
  15. * the License.
  16. */
  17. var App = require('app');
  18. App.MapReduceService = App.Service.extend({
  19. version: DS.attr('string'),
  20. jobHistoryServer: function () {
  21. return this.get('hostComponents').findProperty('componentName', 'HISTORYSERVER');
  22. }.property('hostComponents'),
  23. jobTracker: function () {
  24. return this.get('hostComponents').findProperty('componentName', 'JOBTRACKER');
  25. }.property('hostComponents'),
  26. taskTrackersStarted: DS.attr('number'),
  27. taskTrackersInstalled: DS.attr('number'),
  28. taskTrackersTotal: DS.attr('number'),
  29. jobTrackerStartTime: DS.attr('number'),
  30. jobTrackerHeapUsed: DS.attr('number'),
  31. jobTrackerHeapMax: DS.attr('number'),
  32. aliveTrackers: DS.hasMany('App.HostComponent'),
  33. blackListTrackers: DS.hasMany('App.HostComponent'),
  34. grayListTrackers: DS.hasMany('App.HostComponent'),
  35. mapSlots: DS.attr('number'),
  36. reduceSlots: DS.attr('number'),
  37. jobsSubmitted: DS.attr('number'),
  38. jobsCompleted: DS.attr('number'),
  39. jobsRunning: DS.attr('number'),
  40. mapSlotsOccupied: DS.attr('number'),
  41. mapSlotsReserved: DS.attr('number'),
  42. reduceSlotsOccupied: DS.attr('number'),
  43. reduceSlotsReserved: DS.attr('number'),
  44. mapsRunning: DS.attr('number'),
  45. mapsWaiting: DS.attr('number'),
  46. reducesRunning: DS.attr('number'),
  47. reducesWaiting: DS.attr('number'),
  48. trackersDecommissioned: DS.attr('number'),
  49. jobTrackerCpu: DS.attr('number'),
  50. jobTrackerRpc: DS.attr('number')
  51. });
  52. App.MapReduceService.FIXTURES = [];