Uses of Class
org.jppf.client.JPPFJob
Packages that use JPPFJob
Package
Description
Support for the new load-balancing of local versus remote execution on the client side.
Support for job queuing in the JPPF client.
Classes supporting submission of tasks via distributed executor services
as specified in
java.util.concurrent.Support for connection pool events,
connection status notifications,
job lifecycle events
and job queue events in the JPPF client.
Support for job persistence on the client side.
Support for job streaming.
-
Uses of JPPFJob in org.jppf.client
Methods in org.jppf.client that return JPPFJobModifier and TypeMethodDescriptionJPPFJob.addDependencies(Collection<JPPFJob> dependencies) Add the specified jobs as dependencies to this job.JPPFJob.addDependencies(JPPFJob... dependencies) Add the specified jobs as dependencies to this job.JPPFDriverJobPersistence.retrieveJob(String uuid) Retieve and rebuild the persisted job with the specified uuid.JPPFJob.setCascadeCancellation(boolean cascadeCancellation) Set whether cancellation of this job should trigger the cancellation of the jobs that depend on it.JPPFJob.setDependencyId(String id) Set this job's dependency id.JPPFJob.setDependencyId(Supplier<String> idSupplier) Set this job's dependency id from the specified id supplier.JPPFJob.setDependencyId(JobDependencyIdSupplier idSupplier) Set this job's dependency id from a dependency id supplier.JPPFJob.setGraphRoot(boolean graphRoot) Set whether this job is a root in a job dependency graph.JPPFJob.setNameAsDependencyId()Convenience method to set this job's name as dpeendency id.<T> JPPFJobJPPFJob.setPersistenceManager(JobPersistence<T> persistenceManager) Set the persistence manager that enables saving and restoring the state of this job.JPPFJob.setUuidAsDependencyId()Convenience method to set this job's uuid as dependency id.JPPFClient.submitAsync(JPPFJob job) Submit the specified job asynchronously for execution, without waiting for the job to complete.Methods in org.jppf.client that return types with arguments of type JPPFJobModifier and TypeMethodDescriptionJPPFClient.getQueuedJobs()Get the list of currently queued jobs.JPPFClient.getQueuedJobs(org.jppf.job.JobSelector selector) Get a list of currently queued jobs, filtered by aJobSelector.Methods in org.jppf.client with parameters of type JPPFJobModifier and TypeMethodDescriptionJPPFJob.addDependencies(JPPFJob... dependencies) Add the specified jobs as dependencies to this job.Compute a dependency id from the supplied job.JobManager.resubmitJob(JPPFJob job) Add an existing job back into the execution queue.List<org.jppf.node.protocol.Task<?>>Submit the specified job for execution and wait for its completion.JPPFClient.submitAsync(JPPFJob job) Submit the specified job asynchronously for execution, without waiting for the job to complete.Add a job to the execution queue.JobManager.submitJob(JPPFJob job, JobStatusListener listener) Add a task job to the execution queue.List<org.jppf.node.protocol.Task<?>>Deprecated.a job should be submittable either synchronously or asynchronously, regardless of its state.Method parameters in org.jppf.client with type arguments of type JPPFJobModifier and TypeMethodDescriptionJPPFJob.addDependencies(Collection<JPPFJob> dependencies) Add the specified jobs as dependencies to this job. -
Uses of JPPFJob in org.jppf.client.balancer
Fields in org.jppf.client.balancer declared as JPPFJobModifier and TypeFieldDescriptionprotected final JPPFJobAbstractClientJob.jobThe underlying task bundle.Methods in org.jppf.client.balancer that return JPPFJobModifier and TypeMethodDescriptionAbstractClientJob.getJob()Get the underlying task bundle.ClientTaskBundle.getJob()Get the job this job is for.Methods in org.jppf.client.balancer with parameters of type JPPFJobModifier and TypeMethodDescriptionJobManagerClient.resubmitJob(JPPFJob job) JobManagerClient.submitJob(JPPFJob job, JobStatusListener listener) Constructors in org.jppf.client.balancer with parameters of type JPPFJobModifierConstructorDescriptionprotectedAbstractClientJob(JPPFJob job) Initialized abstract client job with task bundle and list of tasks to execute.ClientJob(JPPFJob job, Collection<org.jppf.node.protocol.Task<?>> tasks) Initialized client job with task bundle and list of tasks to execute.protectedClientJob(JPPFJob job, Collection<org.jppf.node.protocol.Task<?>> tasks, ClientJob parentJob, String broadcastUUID) Initialized client job with task bundle and list of tasks to execute. -
Uses of JPPFJob in org.jppf.client.balancer.queue
Methods in org.jppf.client.balancer.queue that return types with arguments of type JPPFJobModifier and TypeMethodDescriptionJPPFPriorityQueue.getJPPFJobs()Get all theJPPFJobs currently in the queue. -
Uses of JPPFJob in org.jppf.client.concurrent
Methods in org.jppf.client.concurrent that return JPPFJobConstructors in org.jppf.client.concurrent with parameters of type JPPFJobModifierConstructorDescriptionJPPFTaskFuture(JPPFJob job, int position) Initialize this future with the specified parameters. -
Uses of JPPFJob in org.jppf.client.event
Methods in org.jppf.client.event that return JPPFJobModifier and TypeMethodDescriptionClientQueueEvent.getJob()Get the job that was added or removed.JobEvent.getJob()Get the source of this event.Methods in org.jppf.client.event that return types with arguments of type JPPFJobModifier and TypeMethodDescriptionClientQueueEvent.getQueuedJobs()Get all theJPPFJobs currently in the queue.Constructors in org.jppf.client.event with parameters of type JPPFJobModifierConstructorDescriptionClientQueueEvent(JPPFClient client, JPPFJob job, JPPFPriorityQueue queue) Initialize this event with the specified source JPPF client and Job.Initialize this event with the specified job as its source.JobEvent(JPPFJob source, org.jppf.execute.ExecutorChannel<?> channel, List<org.jppf.node.protocol.Task<?>> tasks) Initialize this event with the specified job as its source. -
Uses of JPPFJob in org.jppf.client.persistence
Methods in org.jppf.client.persistence that return JPPFJobModifier and TypeMethodDescriptionLoad a job from the persistence store given its key.Methods in org.jppf.client.persistence with parameters of type JPPFJobModifier and TypeMethodDescriptionDefaultFilePersistenceManager.computeKey(JPPFJob job) Compute the key assigned ot the specified job.JobPersistence.computeKey(JPPFJob job) Compute the key for the specified job.voidDefaultFilePersistenceManager.storeJob(String key, JPPFJob job, List<org.jppf.node.protocol.Task<?>> tasks) Store the specified job.voidStore the specified tasks of the specified job with the specified key. -
Uses of JPPFJob in org.jppf.client.utils
Methods in org.jppf.client.utils that return JPPFJobModifier and TypeMethodDescriptionprotected abstract JPPFJobAbstractJPPFJobStream.createNextJob()Create the next job in the stream, along with its tasks.AbstractJPPFJobStream.next()Get the next job in the stream.Methods in org.jppf.client.utils that return types with arguments of type JPPFJobMethods in org.jppf.client.utils with parameters of type JPPFJobModifier and TypeMethodDescriptionprotected abstract voidAbstractJPPFJobStream.processResults(JPPFJob job) Callback invoked when a job is complete.