org.ow2.proactive.scheduler.common.job.factories

Class StaxJobFactory

java.lang.Object

org.ow2.proactive.scheduler.common.job.factories.JobFactory

org.ow2.proactive.scheduler.common.job.factories.StaxJobFactory

public class StaxJobFactory
extends JobFactory

StaxJobFactory provide an implementation of the JobFactory using StAX

Since:

ProActive Scheduling 0.9.1

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.log4j.Logger	logger
static String	MSG_UNABLE_TO_INSTANCIATE_JOB_VALIDATION_FACTORIES

Fields inherited from class org.ow2.proactive.scheduler.common.job.factories.JobFactory

ARCHIVE_DEFAULT_XMLFILE, ARCHIVE_MANIFEST_DIRECTORY, ARCHIVE_MANIFEST_FILE, ARCHIVE_MANIFEST_PROPERTY_XMLFILE, JOBFACTORY_TMPDIR_PROPERTY

Constructor Summary

Constructors

Constructor and Description
StaxJobFactory(boolean handleGlobalVariables) Create a new instance of StaxJobFactory.

Method Summary

Modifier and Type	Method and Description
Job	createJob(InputStream workflowStream)
Job	createJob(InputStream workflowStream, Map<String,String> replacementVariables, Map<String,String> replacementGenericInfos)
Job	createJob(InputStream workflowStream, Map<String,String> replacementVariables, Map<String,String> replacementGenericInfos, Scheduler scheduler, SchedulerSpaceInterface space, String sessionId)
Job	createJob(String filePath) Creates a job using the given job descriptor.
Job	createJob(String filePath, Map<String,String> replacementVariables, Map<String,String> replacementGenericInfos) Creates a job using the given job descriptor.
Job	createJob(String filePath, Map<String,String> replacementVariables, Map<String,String> replacementGenericInfos, Scheduler scheduler, SchedulerSpaceInterface space, String sessionId) Creates a job using the given job descriptor with the scheduler instance for validating jobs.
Job	createJob(URI filePath) Creates a job using the given job descriptor.
Job	createJob(URI filePath, Map<String,String> replacementVariables, Map<String,String> replacementGenericInfos) Creates a job using the given job descriptor.
protected Map<String,JobVariable>	replaceVariablesInJobVariablesMap(Map<String,JobVariable> variablesMap, Map<String,String> replacementVariables)
protected Map<String,TaskVariable>	replaceVariablesInTaskVariablesMap(Map<String,TaskVariable> variablesMap, Map<String,String> replacementVariables)

Methods inherited from class org.ow2.proactive.scheduler.common.job.factories.JobFactory

getFactory, getFactory, getFactory, getFactory

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

public static final org.apache.log4j.Logger logger

MSG_UNABLE_TO_INSTANCIATE_JOB_VALIDATION_FACTORIES

public static final String MSG_UNABLE_TO_INSTANCIATE_JOB_VALIDATION_FACTORIES

See Also:

Constant Field Values

Constructor Detail

StaxJobFactory

public StaxJobFactory(boolean handleGlobalVariables)

Create a new instance of StaxJobFactory.

Method Detail

createJob

public Job createJob(String filePath)
              throws JobCreationException

Description copied from class: JobFactory

Creates a job using the given job descriptor.

Specified by:

createJob in class JobFactory

Parameters:

filePath - the path to an XML job descriptor.

Returns:

a Job instance created with the given XML file.

Throws:

JobCreationException - if an exception occurred during job creation.

createJob

public Job createJob(String filePath,
                     Map<String,String> replacementVariables,
                     Map<String,String> replacementGenericInfos)
              throws JobCreationException

Description copied from class: JobFactory

Creates a job using the given job descriptor.

Specified by:

createJob in class JobFactory

Parameters:

filePath - the path to an XML job descriptor.

replacementVariables - map of job submission variables

replacementGenericInfos - map of job submission generic infos

Returns:

a Job instance created with the given XML file.

Throws:

JobCreationException - if an exception occurred during job creation.

createJob

public Job createJob(String filePath,
                     Map<String,String> replacementVariables,
                     Map<String,String> replacementGenericInfos,
                     Scheduler scheduler,
                     SchedulerSpaceInterface space,
                     String sessionId)
              throws JobCreationException

Description copied from class: JobFactory

Creates a job using the given job descriptor with the scheduler instance for validating jobs.

Specified by:

createJob in class JobFactory

Parameters:

filePath - the path to an XML job descriptor

replacementVariables - map of job submission variables

replacementGenericInfos - map of job submission generic infos

scheduler - the Scheduler instance for validating jobs to access third-party credentials

space - the SchedulerSpaceInterface instance for validating jobs to access data spaces files

sessionId - current session for validating jobs with CATALOG_OBJECT variables

Returns:

a Job instance created with the given XML file

Throws:

JobCreationException - if an exception occurred during job creation

createJob

public Job createJob(URI filePath)
              throws JobCreationException

Description copied from class: JobFactory

Creates a job using the given job descriptor.

Specified by:

createJob in class JobFactory

Parameters:

filePath - the path to an XML job descriptor.

Returns:

a Job instance created with the given XML file.

Throws:

JobCreationException - if an exception occurred during job creation.

createJob

public Job createJob(URI filePath,
                     Map<String,String> replacementVariables,
                     Map<String,String> replacementGenericInfos)
              throws JobCreationException

Description copied from class: JobFactory

Creates a job using the given job descriptor.

Specified by:

createJob in class JobFactory

Parameters:

filePath - the path to an XML job descriptor.

replacementVariables - map of job submission variables

replacementGenericInfos - map of job submission generic infos

Returns:

a Job instance created with the given XML file.

Throws:

JobCreationException - if an exception occurred during job creation.

createJob

public Job createJob(InputStream workflowStream)
              throws JobCreationException

Specified by:

createJob in class JobFactory

Throws:

JobCreationException

See Also:

JobFactory.createJob(String)

createJob

public Job createJob(InputStream workflowStream,
                     Map<String,String> replacementVariables,
                     Map<String,String> replacementGenericInfos)
              throws JobCreationException

Specified by:

createJob in class JobFactory

Throws:

JobCreationException

createJob

public Job createJob(InputStream workflowStream,
                     Map<String,String> replacementVariables,
                     Map<String,String> replacementGenericInfos,
                     Scheduler scheduler,
                     SchedulerSpaceInterface space,
                     String sessionId)
              throws JobCreationException

Specified by:

createJob in class JobFactory

Throws:

JobCreationException

replaceVariablesInJobVariablesMap

protected Map<String,JobVariable> replaceVariablesInJobVariablesMap(Map<String,JobVariable> variablesMap,
                                                                    Map<String,String> replacementVariables)
                                                             throws JobCreationException

Throws:

JobCreationException

replaceVariablesInTaskVariablesMap

protected Map<String,TaskVariable> replaceVariablesInTaskVariablesMap(Map<String,TaskVariable> variablesMap,
                                                                      Map<String,String> replacementVariables)
                                                               throws JobCreationException

Throws:

JobCreationException