List of addJob() Examples

Examples of addJob()

ch.entwine.weblounge.common.site.Module.addJob()
Adds the job to the set of jobs. @param job the job to add
ch.ethz.vs.rowa.job.ClientRequests.addJob()
com.gentics.cr.util.indexing.IndexExtension.addJob()
Adds a job to the queue @param name the name of the job to add @throws NoSuchMethodException if no job with the given name was found
com.narirelays.ems.services.TaskScheduleManagementService.addJob()
com.projity.job.Job.addJob()
com.stella.framework.scheduler.RunScheduler.addJob()
com.stella.framework.scheduler.RunSchedulerImpl.addJob()
com.twitter.ambrose.hive.reporter.EmbeddedAmbroseHiveProgressReporter.addJob()
de.phleisch.app.itsucks.core.Dispatcher.addJob()
es.emergya.scheduler.CustomScheduler.addJob()
Schedule a job execution indefinitely every repeatInterval, with the given jobKey.
Note: To start execution call method start(). @param repeatInterval miliseconds between job executions. @param jobKey A name for the job. @param jobClass Class of the job to be executed. It must have a empty constructor. @throws SchedulerException if the job can't be scheduled. @author jlrodriguez @param < T>
games.stendhal.server.entity.npc.SpeakerNPC.addJob()
gri.tasks.managers.workflows.WorkflowSubmission.addJob()
jsprit.core.problem.VehicleRoutingProblem.Builder.addJob()
org.activiti.engine.impl.asyncexecutor.AcquiredJobEntities.addJob()
org.apache.crunch.impl.mr.exec.MRExecutor.addJob()
org.apache.hadoop.mapred.PoolManager.addJob()
Add a job in the appropriate pool
org.apache.hadoop.mapred.jobcontrol.JobControl.addJob()
Add a new job. @param aJob the the new job
org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl.addJob()
Add a new controlled job. @param aJob the new controlled job
org.apache.hadoop.raid.DistBlockIntegrityMonitor.Worker.LostFileInfo.addJob()
org.apache.openejb.quartz.Scheduler.addJob()
org.apache.sling.commons.scheduler.Scheduler.addJob()
/ Schedule a time based job. Note that if a job with the same name has already been added, the old job is cancelled and this new job replaces the old job. @param name The name of the job - or null. If no name is specified it can't be cancelled. @param job The job to execute (either {@link Job} or {@link Runnable}). @param config An optional configuration object - this configuration is only passed to the job the job implements {@link Job}. @param schedulingExpression The time specification using a scheduling expression. @param canRunConcurrently Whether this job can run even if previous scheduled runs are still running. @throws IllegalArgumentException If the scheduling expression can't be parsed or if the job has not the correct type. @throws Exception If the job can't be scheduled. @deprecated Use {@link #schedule(Object,ScheduleOptions)} instead.
org.apache.sling.event.jobs.JobManager.addJob()
Add a new job If the topic is null or illegal, no job is created and null is returned. If properties are provided, all of them must be serializable. If there are non serializable objects in the properties, no job is created and null is returned. A job topic is a hierarchical name separated by dashes, each part has to start with a letter, allowed characters are letters, numbers and the underscore. The returned job object is a snapshot of the job state taken at the time of creation. Updates to the job state are not reflected and the client needs to get a new job object using the job id. If the queue for processing this job is configured to drop the job, null is returned as well. @param topic The required job topic. @param properties Optional job properties. The properties must be serializable. @return The new job - or null if the job could not be created. @since 1.2
org.quartz.Scheduler.addJob()

Add the given Job to the Scheduler - with no associated Trigger. The Job will be 'dormant' until it is scheduled with a Trigger, or Scheduler.triggerJob() is called for it.

The Job must by definition be 'durable', if it is not, SchedulerException will be thrown.
@throws SchedulerException if there is an internal Scheduler error, or if the Job is not durable, or a Job with the same name already exists, and replace is false.
org.springframework.data.mongodb.crossstore.test.Resume.addJob()

Examples of jsprit.core.problem.VehicleRoutingProblem.Builder.addJob()

        double late = Math.max(0, arrivalTime - tourAct.getTheoreticalLatestOperationStartTime())*100;
        return  waiting + late;
      }
      
    });
    VehicleRoutingProblem vrp = vrpBuilder.addJob(service).addVehicle(vehicle).build();
    
    
    VehicleRoutingAlgorithm vra = VehicleRoutingAlgorithms.readAndCreateAlgorithm(vrp, "src/test/resources/algorithmConfigWithDepartureTimeChoice.xml");
    Collection<VehicleRoutingProblemSolution> solutions = vra.searchSolutions();

View Full Code Here

Examples of jsprit.core.problem.VehicleRoutingProblem.Builder.addJob()

        double late = Math.max(0, arrivalTime - tourAct.getTheoreticalLatestOperationStartTime())*100;
        return  waiting + late;
      }
      
    });
    VehicleRoutingProblem vrp = vrpBuilder.addJob(service).addVehicle(vehicle).build();
    
    
    VehicleRoutingAlgorithm vra = VehicleRoutingAlgorithms.readAndCreateAlgorithm(vrp, "src/test/resources/algorithmConfigWithDepartureTimeChoice.xml");
    Collection<VehicleRoutingProblemSolution> solutions = vra.searchSolutions();

View Full Code Here

Examples of jsprit.core.problem.VehicleRoutingProblem.Builder.addJob()

        double late = Math.max(0, arrivalTime - tourAct.getTheoreticalLatestOperationStartTime())*100;
        return  waiting + late;
      }
      
    });
    VehicleRoutingProblem vrp = vrpBuilder.addJob(service).addJob(service2).addVehicle(vehicle).build();
    
    
    VehicleRoutingAlgorithm vra = VehicleRoutingAlgorithms.readAndCreateAlgorithm(vrp, "src/test/resources/algorithmConfigWithDepartureTimeChoice.xml");
    Collection<VehicleRoutingProblemSolution> solutions = vra.searchSolutions();

View Full Code Here

Examples of jsprit.core.problem.VehicleRoutingProblem.Builder.addJob()

        double late = Math.max(0, arrivalTime - tourAct.getTheoreticalLatestOperationStartTime())*100;
        return  waiting + late;
      }
      
    });
    VehicleRoutingProblem vrp = vrpBuilder.addJob(service).addJob(service2).addVehicle(vehicle).build();
    
    
    VehicleRoutingAlgorithm vra = VehicleRoutingAlgorithms.readAndCreateAlgorithm(vrp, "src/test/resources/algorithmConfigWithDepartureTimeChoice.xml");
    Collection<VehicleRoutingProblemSolution> solutions = vra.searchSolutions();

View Full Code Here

Examples of org.activiti.engine.impl.asyncexecutor.AcquiredJobEntities.addJob()

      .getJobEntityManager()
      .findAsyncJobsDueToExecute(new Page(0, asyncExecutor.getMaxAsyncJobsDuePerAcquisition()));
    
    for (JobEntity job: jobs) {
      lockJob(commandContext, job, asyncExecutor.getAsyncJobLockTimeInMillis());
      acquiredJobs.addJob(job);
      asyncExecutor.executeAsyncJob(job);
    }
    
    return acquiredJobs;
  }

View Full Code Here

Examples of org.apache.crunch.impl.mr.exec.MRExecutor.addJob()

    // Finally, construct the jobs from the prototypes and return.
    DotfileWriter dotfileWriter = new DotfileWriter();
    MRExecutor exec = new MRExecutor(conf, jarClass, outputs, toMaterialize);
    for (JobPrototype proto : Sets.newHashSet(assignments.values())) {
      dotfileWriter.addJobPrototype(proto);
      exec.addJob(proto.getCrunchJob(jarClass, conf, pipeline, lastJobID));
    }


    String planDotFile = dotfileWriter.buildDotfile();
    exec.setPlanDotFile(planDotFile);
    conf.set(PlanningParameters.PIPELINE_PLAN_DOTFILE, planDotFile);

View Full Code Here

Examples of org.apache.hadoop.mapred.PoolManager.addJob()

        jobTracker);


    // Check that each good pool name is permitted
    for (String goodPoolName : goodPoolNames) {
      job.conf.set(PoolManager.EXPLICIT_POOL_PROPERTY, goodPoolName);
      mgr.addJob(job);
      assertEquals("PoolManager rejected good pool name",
          goodPoolName, mgr.getPoolName(job));
    }


    // Check that each bad pool name is rejected

View Full Code Here

Examples of org.apache.hadoop.mapred.jobcontrol.JobControl.addJob()

    throws IOException {
    JobControl theControl = new JobControl("ValueAggregatorJobs");
    ArrayList dependingJobs = new ArrayList();
    JobConf aJobConf = createValueAggregatorJob(args);
    Job aJob = new Job(aJobConf, dependingJobs);
    theControl.addJob(aJob);
    return theControl;
  }


  /**
   * Create an Abacus based map/reduce job.

View Full Code Here

Examples of org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl.addJob()

      ControlledJob aboveAvgControlledJob = new ControlledJob(
          getAverageJobConf(binningOutputAbove, aboveAverageRepOutput));
      aboveAvgControlledJob.addDependingJob(binningControlledJob);


      JobControl jc = new JobControl("AverageReputation");
      jc.addJob(binningControlledJob);
      jc.addJob(belowAvgControlledJob);
      jc.addJob(aboveAvgControlledJob);


      jc.run();
      code = jc.getFailedJobList().size() == 0 ? 0 : 1;

View Full Code Here

Examples of org.apache.hadoop.raid.DistBlockIntegrityMonitor.Worker.LostFileInfo.addJob()

      List<LostFileInfo> fileInfos = new ArrayList<LostFileInfo>();


      for (String file: lostFiles) {
        LostFileInfo fileInfo = fileIndex.get(file);
        if (fileInfo != null) {
          fileInfo.addJob(jobName, priority);
        } else {
          fileInfo = new LostFileInfo(file, jobName, priority);
          fileIndex.put(file, fileInfo);
        }
        fileInfos.add(fileInfo);

View Full Code Here

0 1 2 3 4 5 6 7

TOP

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.