List of runJob() Examples

Examples of runJob()

com.ontology2.haruhi.Cluster.runJob()
it.eng.spagobi.engines.talend.runtime.RuntimeRepository.runJob()
Run job. @param job the job @param env the environment @throws JobNotFoundException the job not found exception @throws ContextNotFoundException the context not found exception @throws JobExecutionException the job execution exception
org.apache.cloudstack.framework.jobs.AsyncJobDispatcher.runJob()
org.apache.hadoop.mapred.JobClient.runJob()
Utility that submits a job, then polls for progress until the job is complete. @param job the job configuration. @throws IOException
org.apache.mahout.classifier.bayes.mapreduce.bayes.BayesDriver.runJob()
Run the job @param input the input pathname String @param output the output pathname String @throws ClassNotFoundException @throws InterruptedException
org.apache.mahout.classifier.bayes.mapreduce.cbayes.CBayesDriver.runJob()
Run the job @param input the input pathname String @param output the output pathname String @throws ClassNotFoundException @throws InterruptedException
org.apache.mahout.classifier.bayes.mapreduce.common.BayesFeatureDriver.runJob()
Run the job @param input the input pathname String @param output the output pathname String
org.apache.mahout.classifier.bayes.mapreduce.common.BayesTfIdfDriver.runJob()
Run the job @param input the input pathname String @param output the output pathname String @throws ClassNotFoundException
org.apache.mahout.classifier.bayes.mapreduce.common.BayesWeightSummerDriver.runJob()
Run the job @param input the input pathname String @param output the output pathname String
org.apache.mahout.math.hadoop.decomposer.DistributedLanczosSolver.runJob()
org.apache.mahout.math.hadoop.decomposer.EigenVerificationJob.runJob()
Progammatic invocation of run() @param eigenInput Output of LanczosSolver @param corpusInput Input of LanczosSolver
org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.NativeTezOper.runJob()
org.ggf.drmaa.Session.runJob()
Submit a job with attributes defined in the job template, jt. The returned job identifier is a String identical to that returned from the underlying DRM system. @param jt the job template to be used to create the job @throws DrmaaException May be one of the following:
- TryLaterException -- the DRM was temporarily unable to fulfill the request, but a retry might succeed
- DeniedByDrmException -- the DRM has rejected the job due to configuration problems either in the DRM or the job template
- InvalidJobTemplateException -- the JobTemplate instance does not belong to the current session, was not created with createJobTemplate(), or has already been deleted
- NoActiveSessionException -- the session has not yet been initialized or has already been exited
- DrmCommunicationException -- the DRMAA implementation was unable to contact the DRM
- AuthorizationException -- the executing user does not have sufficient permissions to execute the desired action
- IllegalArgumentException -- an argument is invalid
- InternalException -- an error has occured in the DRMAA implementation
@return job identifier String identical to that returned from theunderlying DRM system
org.ofbiz.service.job.JobManager.runJob()
Queues a Job to run now.

Examples of org.apache.mahout.math.hadoop.decomposer.EigenVerificationJob.runJob()

                  seqFiles.toString());


    // now run the verifier to trim down the number of eigenvectors
    EigenVerificationJob verifier = new EigenVerificationJob();
    Path verifiedEigens = new Path(tmp, "verifiedeigens");
    verifier.runJob(conf, seqFiles, input.getRowPath(), verifiedEigens, false, 1.0, 0.0, numEigenVectors);
    Path cleanedEigens = verifier.getCleanedEigensPath();
    return new DistributedRowMatrix(cleanedEigens, new Path(cleanedEigens, "tmp"), numEigenVectors, input.numRows());
  }


  /**

View Full Code Here

Examples of org.apache.mahout.math.hadoop.decomposer.EigenVerificationJob.runJob()

                  seqFiles.toString());


    // now run the verifier to trim down the number of eigenvectors
    EigenVerificationJob verifier = new EigenVerificationJob();
    Path verifiedEigens = new Path(tmp, "verifiedeigens");
    verifier.runJob(conf, seqFiles, input.getRowPath(), verifiedEigens, false, 1.0, numEigenVectors);
    Path cleanedEigens = verifier.getCleanedEigensPath();
    return new DistributedRowMatrix(cleanedEigens, new Path(cleanedEigens, "tmp"), numEigenVectors, input.numRows());
  }


  /**

View Full Code Here

Examples of org.apache.mahout.math.hadoop.decomposer.EigenVerificationJob.runJob()

                  lanczosSeqFiles.toString());


    // perform a verification
    EigenVerificationJob verifier = new EigenVerificationJob();
    Path verifiedEigensPath = new Path(outputCalc, "eigenverifier");
    verifier.runJob(conf, lanczosSeqFiles, L.getRowPath(), verifiedEigensPath, true, 1.0, clusters);
    Path cleanedEigens = verifier.getCleanedEigensPath();
    DistributedRowMatrix W = new DistributedRowMatrix(cleanedEigens, new Path(cleanedEigens, "tmp"), clusters, numDims);
    W.setConf(depConf);
    DistributedRowMatrix Wtrans = W.transpose();
    //    DistributedRowMatrix Wt = W.transpose();

View Full Code Here

Examples of org.apache.mahout.math.hadoop.decomposer.EigenVerificationJob.runJob()

                  seqFiles.toString());


    // now run the verifier to trim down the number of eigenvectors
    EigenVerificationJob verifier = new EigenVerificationJob();
    Path verifiedEigens = new Path(tmp, "verifiedeigens");
    verifier.runJob(conf, seqFiles, input.getRowPath(), verifiedEigens, false, 1.0, numEigenVectors);
    Path cleanedEigens = verifier.getCleanedEigensPath();
    return new DistributedRowMatrix(cleanedEigens, new Path(cleanedEigens, "tmp"), numEigenVectors, input.numRows());
  }


  /**

View Full Code Here

Examples of org.apache.mahout.math.hadoop.decomposer.EigenVerificationJob.runJob()

      solver.runJob(conf, state, overshoot, true, lanczosSeqFiles.toString());


      // perform a verification
      EigenVerificationJob verifier = new EigenVerificationJob();
      Path verifiedEigensPath = new Path(outputCalc, "eigenverifier");
      verifier.runJob(conf, lanczosSeqFiles, L.getRowPath(), verifiedEigensPath, true, 1.0, clusters);


      Path cleanedEigens = verifier.getCleanedEigensPath();
      DistributedRowMatrix W = new DistributedRowMatrix(cleanedEigens, new Path(cleanedEigens, "tmp"), clusters,
          numDims);
      W.setConf(depConf);

View Full Code Here

Examples of org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.NativeTezOper.runJob()

            ProgressReporter reporter = new ProgressReporter(tezPlanContainer.size(), processedDAGs);
            if (tezPlan.size()==1 && tezPlan.getRoots().get(0) instanceof NativeTezOper) {
                // Native Tez Plan
                NativeTezOper nativeOper = (NativeTezOper)tezPlan.getRoots().get(0);
                tezScriptState.emitJobsSubmittedNotification(1);
                nativeOper.runJob(tezPlanContainerNode.getOperatorKey().toString());
            } else {
                TezPOPackageAnnotator pkgAnnotator = new TezPOPackageAnnotator(tezPlan);
                pkgAnnotator.visit();


                runningJob = jc.compile(tezPlanContainerNode, tezPlanContainer);

View Full Code Here

Examples of org.ggf.drmaa.Session.runJob()

         session.init("");
         JobTemplate jt = session.createJobTemplate();
         jt.setRemoteCommand("sleeper.sh");
         jt.setArgs(Collections.singletonList("5"));
         
         String id = session.runJob(jt);
         
         System.out.println("Your job has been submitted with id " + id);
         
         session.control(id, Session.TERMINATE);

View Full Code Here

Examples of org.ggf.drmaa.Session.runJob()

         session.init("");
         JobTemplate jt = session.createJobTemplate();
         jt.setRemoteCommand("sleeper.sh");
         jt.setArgs(Collections.singletonList("5"));
         
         String id = session.runJob(jt);
         
         System.out.println("Your job has been submitted with id " + id);
         
         try {
            Thread.sleep(20 * 1000);

View Full Code Here

Examples of org.ggf.drmaa.Session.runJob()

         session.init("");
         JobTemplate jt = session.createJobTemplate();
         jt.setRemoteCommand("sleeper.sh");
         jt.setArgs(Collections.singletonList("5"));
         
         String id = session.runJob(jt);
         
         System.out.println("Your job has been submitted with id " + id);
         
         session.deleteJobTemplate(jt);

View Full Code Here

Examples of org.ggf.drmaa.Session.runJob()

         session.init("");
         JobTemplate jt = session.createJobTemplate();
         jt.setRemoteCommand("sleeper.sh");
         jt.setArgs(Collections.singletonList("5"));
         
         String id = session.runJob(jt);
         
         System.out.println("Your job has been submitted with id " + id);
         
         session.deleteJobTemplate(jt);
         session.exit();

View Full Code Here

0 1 2 3 4 5

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.