List of runBulkJobs() Examples

Examples of runBulkJobs()

org.ggf.drmaa.Session.runBulkJobs()

Submit a range of parametric jobs, each with attributes defined in the job template, jt. The returned job identifiers are Strings identical to those returned from the underlying DRM system. The number of jobs submitted will be Math.floor((end - start + 1) / incr).

The JobTemplate class defines a PARAMETRIC_INDEX placeholder for use in specifying paths in the job template. This placeholder is used to represent the individual identifiers of the tasks submitted through this method.

@return job identifier Strings identical to that returned by theunderlying DRM system @param start the starting value for the loop index @param end the terminating value for the loop index @param incr the value by which to increment the loop index each iteration @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

         session.init("");
         JobTemplate jt = session.createJobTemplate();
         jt.setRemoteCommand("sleeper.sh");
         jt.setArgs(Collections.singletonList("5"));
         
         java.util.List ids = session.runBulkJobs(jt, 1, 30, 2);
         java.util.Iterator i = ids.iterator();
         
         while (i.hasNext()) {
            System.out.println("Your job has been submitted with id " + i.next());
         }

         session.init("");
         JobTemplate jt = session.createJobTemplate();
         jt.setRemoteCommand("sleeper.sh");
         jt.setArgs(Collections.singletonList("5"));
         
         List ids = session.runBulkJobs(jt, 1, 30, 2);
         Iterator i = ids.iterator();
         
         while (i.hasNext()) {
            System.out.println("Your job has been submitted with id " + i.next());
         }

         
         int start = 1;
         int end  = 30;
         int step = 2;
         
         List ids = session.runBulkJobs(jt, start, end, step);
         Iterator i = ids.iterator();
         
         while (i.hasNext()) {
            System.out.println("Your job has been submitted with id " + i.next());
         }

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.

Examples of runBulkJobs()

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

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

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