Uses of Class
org.jppf.client.balancer.ClientJob
Packages that use ClientJob
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.
Support for connection pool events,
connection status notifications,
job lifecycle events
and job queue events in the JPPF client.
-
Uses of ClientJob in org.jppf.client
Method parameters in org.jppf.client with type arguments of type ClientJobModifier and TypeMethodDescriptionvoidAbstractGenericClient.bundleAdded(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidAbstractGenericClient.bundleAdded(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidAbstractGenericClient.bundleRemoved(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidAbstractGenericClient.bundleRemoved(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) protected voidAbstractGenericClient.fireQueueEvent(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> qEvent, boolean jobAdded) Notify all client queue listeners that a queue event has occurred.protected voidAbstractGenericClient.fireQueueEvent(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> qEvent, boolean jobAdded) Notify all client queue listeners that a queue event has occurred.Constructor parameters in org.jppf.client with type arguments of type ClientJobModifierConstructorDescriptionJPPFContextClient(org.jppf.queue.JPPFQueue<ClientJob, ClientJob, ClientTaskBundle> queue) Default initializer.JPPFContextClient(org.jppf.queue.JPPFQueue<ClientJob, ClientJob, ClientTaskBundle> queue) Default initializer. -
Uses of ClientJob in org.jppf.client.balancer
Fields in org.jppf.client.balancer declared as ClientJobModifier and TypeFieldDescriptionprotected ClientJobAbstractClientJob.parentJobInstance of parent broadcast job.Methods in org.jppf.client.balancer that return ClientJobModifier and TypeMethodDescriptionClientJob.createBroadcastJob(String broadcastUUID) Make a copy of this client job wrapper.ClientTaskBundle.getClientJob()Get the client job this job is for.Methods in org.jppf.client.balancer with parameters of type ClientJobModifier and TypeMethodDescriptionprotected voidClientJob.broadcastCompleted(ClientJob broadcastJob) Called to notify that the execution of broadcast job has completed.protected voidClientJob.broadcastDispatched(ClientJob broadcastJob) Called when all or part of broadcast job is dispatched to a driver.Constructors in org.jppf.client.balancer with parameters of type ClientJobModifierConstructorDescriptionprotectedClientJob(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.ClientTaskBundle(ClientJob job, Collection<org.jppf.node.protocol.Task<?>> tasks) Initialize this task bundle and set its build number. -
Uses of ClientJob in org.jppf.client.balancer.queue
Methods in org.jppf.client.balancer.queue that return ClientJobModifier and TypeMethodDescriptionAdd an object to the queue, and notify all listeners about it.JPPFPriorityQueue.removeBundle(ClientJob job) Methods in org.jppf.client.balancer.queue with parameters of type ClientJobModifier and TypeMethodDescriptionAdd an object to the queue, and notify all listeners about it.protected intGet the bundle size to use for bundle size tuning.JPPFPriorityQueue.nextBundle(ClientJob job, int nbTasks, org.jppf.execute.ExecutorChannel<ClientTaskBundle> channel) JPPFPriorityQueue.removeBundle(ClientJob job) protected voidHandle requeue of the specified job. -
Uses of ClientJob in org.jppf.client.event
Method parameters in org.jppf.client.event with type arguments of type ClientJobModifier and TypeMethodDescriptionvoidClientQueueEventDispatcher.bundleAdded(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidClientQueueEventDispatcher.bundleAdded(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidClientQueueEventDispatcher.bundleRemoved(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidClientQueueEventDispatcher.bundleRemoved(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event)