Uses of Class
io.parallec.core.ParallelTask

Packages that use ParallelTask

Package	Description
io.parallec.core	Main package, including most user-facing classes such as the ParallelClient, ParallelTask etc.
io.parallec.core.actor	Actors to execute parallel task and return responses.
io.parallec.core.actor.message	Actor messages.
io.parallec.core.commander.workflow	Work flow and variable replacement utilities.
io.parallec.core.task
io.parallec.core.util	Utility functions.

Uses of ParallelTask in io.parallec.core

Methods in io.parallec.core that return ParallelTask

Modifier and Type	Method and Description
ParallelTask	ParallelTaskBuilder.execute(ParallecResponseHandler handler) key function.

Uses of ParallelTask in io.parallec.core.actor

Fields in io.parallec.core.actor declared as ParallelTask

Modifier and Type	Field and Description
protected ParallelTask	ExecutionManager.task The parallel task.

Constructors in io.parallec.core.actor with parameters of type ParallelTask

Constructor and Description
ExecutionManager(ParallelTask task) Instantiates a new command manager.

Uses of ParallelTask in io.parallec.core.actor.message

Constructors in io.parallec.core.actor.message with parameters of type ParallelTask

Constructor and Description
InitialRequestToManager(ParallelTask parallelTask) Instantiates a new initial request to manager with parallel task

Uses of ParallelTask in io.parallec.core.commander.workflow

Methods in io.parallec.core.commander.workflow with parameters of type ParallelTask

Modifier and Type	Method and Description
void	InternalDataProvider.genNodeDataMap(ParallelTask task) Generate node data map.
void	VarReplacementProvider.updateRequestByAddingReplaceVarPair(ParallelTask task, java.lang.String replaceVarKey, java.lang.String replaceVarValue) GENERIC!!! HELPER FUNCION FOR REPLACEMENT update the var: DYNAMIC REPLACEMENT of VAR.
void	VarReplacementProvider.updateRequestByAddingReplaceVarPairNodeSpecific(ParallelTask task, java.util.Map<java.lang.String,StrStrMap> replacementVarMapNodeSpecific) Will change replacementVarMapNodeSpecific according to each node specifically With KEY set as NA; will not run the command ONLY if the NA is the last replacement; note in this logic; when it is not NA; will set AS True.
void	VarReplacementProvider.updateRequestWithReplacement(ParallelTask task, boolean useReplacementVarMap, java.util.Map<java.lang.String,java.lang.String> replacementVarMap, boolean useReplacementVarMapNodeSpecific, java.util.Map<java.lang.String,StrStrMap> replacementVarMapNodeSpecific) 20130916: add node specific replacement Var Map; replacementVarMap VS.

Uses of ParallelTask in io.parallec.core.task

Fields in io.parallec.core.task with type parameters of type ParallelTask

Modifier and Type	Field and Description
private java.util.concurrent.ConcurrentHashMap<java.lang.String,ParallelTask>	ParallelTaskManager.inprogressTaskMap The inprogress task map.
private java.util.Queue<ParallelTask>	ParallelTaskManager.waitQ The wait q.

Methods in io.parallec.core.task that return ParallelTask

Modifier and Type	Method and Description
ParallelTask	ParallelTaskManager.getTaskFromInProgressMap(java.lang.String jobId) Gets the task from in progress map.

Methods in io.parallec.core.task that return types with arguments of type ParallelTask

Modifier and Type	Method and Description
java.util.Map<java.lang.String,ParallelTask>	ParallelTaskManager.getInprogressTaskMap() Gets the inprogress task map.
java.util.Queue<ParallelTask>	ParallelTaskManager.getWaitQ() Gets the wait q.

Methods in io.parallec.core.task with parameters of type ParallelTask

Modifier and Type	Method and Description
void	ParallelTaskManager.addTaskToInProgressMap(java.lang.String jobId, ParallelTask task) when create new job, always add this to the queue.
ResponseFromManager	ParallelTaskManager.generateUpdateExecuteTask(ParallelTask task) key function to execute a parallel task.
boolean	ParallelTaskManager.removeTaskFromWaitQ(ParallelTask taskTobeRemoved) Removes the task from wait q.
ResponseFromManager	ParallelTaskManager.sendTaskToExecutionManager(ParallelTask task) Send parallel task to execution manager.

Constructors in io.parallec.core.task with parameters of type ParallelTask

Constructor and Description
ParallelTaskBean(ParallelTask task) Instantiates a new parallel task bean.

Uses of ParallelTask in io.parallec.core.util

Methods in io.parallec.core.util with parameters of type ParallelTask

Modifier and Type	Method and Description
static void	BeanMapper.copy(ParallelTask source, ParallelTaskBean target)