Examples of org.goldenorb.JobManager

org.goldenorb.JobManager
JobManager is created by the lead OrbTracker to aid in putting jobs-in-the-queue and pulling them into jobs-in-progress. It tells the OrbTrackerMembers in the LeaderGroup to launch their partitions. Then it watches the jobs (via heart beat field in ZooKeeper) to make sure they're still running, @param < M> The class of type that JobManager will actually manage

 */
  private void leader() {
    synchronized (this) {
      leader = true;
      allocator = new ResourceAllocator(orbConf, leaderGroup.getMembers());
      jobManager = new JobManager(orbCallback, orbConf, zk, allocator, leaderGroup.getMembers());
    }
    waitLoop();
  }

View Full Code Here

TOP

Related Classes of org.goldenorb.JobManager

org.apache.hadoop.fs.FileSystem

org.apache.hadoop.io.LongWritable

org.goldenorb.conf.OrbConfiguration

org.goldenorb.event.job.JobDeathEvent

org.goldenorb.event.OrbExceptionEvent

org.goldenorb.jet.PartitionRequest

org.goldenorb.zookeeper.OrbZKFailure

org.goldenorb.zookeeper.TJTracker

java.util.Date

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.