|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use JobInstance | |
---|---|
org.icenigrid.gridsam.core | Package containing the core interfaces defining the JobManager API. |
org.icenigrid.gridsam.core.plugin | Package containing interfaces that define the Service Provider Interface (SPI) of GridSAM. |
org.icenigrid.gridsam.core.plugin.connector.common | Package containing common implementations of the DRMConnector interface. |
org.icenigrid.gridsam.core.plugin.manager | Package containing the default implementation of the DRMConnector and JobManager abstraction. |
org.icenigrid.gridsam.core.plugin.persistence.common | Package containing the implementation classes of the job persistence interfaces. |
org.icenigrid.gridsam.core.plugin.persistence.hibernate | Package containing an implementation of the job persistence API using the Hibernate toolkit over a relational database. |
org.icenigrid.gridsam.core.support | |
org.icenigrid.gridsam.core.util | |
org.icenigrid.gridsam.integration.common |
Uses of JobInstance in org.icenigrid.gridsam.core |
---|
Subinterfaces of JobInstance in org.icenigrid.gridsam.core | |
---|---|
interface |
MutableJobInstance
Interface extending JobInstance providing mutable access to job status and other information |
Methods in org.icenigrid.gridsam.core that return JobInstance | |
---|---|
JobInstance |
JobManager.findJobInstance(java.lang.String pID)
find a job instance using the job identifier |
JobInstance[] |
JobManager.findJobInstance(java.lang.String[] pIDs)
find a job instance using the job identifier |
JobInstance |
JobManager.rerunJob(java.lang.String pJobID,
JobState startState,
org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument pDesc,
boolean pStartSuspend)
Rerun a job from a specified stage and reuse the same working directory. |
JobInstance |
JobManager.startJob(java.lang.String pID)
Start a pending job. |
JobInstance[] |
JobManager.startJob(java.lang.String[] pIDs)
Start a set of pending jobs. |
JobInstance |
JobManager.submitJob(org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument pDesc)
submit a job to this JobManager instance. |
JobInstance[] |
JobManager.submitJob(org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument[] pDesc,
boolean pSuspended)
submit a set of jobs to this JobManager instance as a bulk operation. |
JobInstance |
JobManager.submitJob(org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument pDesc,
boolean pSuspended)
submit a job to this JobManager instances |
Methods in org.icenigrid.gridsam.core with parameters of type JobInstance | |
---|---|
void |
JobInstanceChangeListener.onChange(JobInstance pInstance)
notify the state of the JobInstance has changed |
Uses of JobInstance in org.icenigrid.gridsam.core.plugin |
---|
Methods in org.icenigrid.gridsam.core.plugin with parameters of type JobInstance | |
---|---|
void |
JobManagerContext.schedule(JobInstance pJobInstance,
DRMConnector pConnector)
schedule the given DRMConnector for immediate execution in this job context for the given job |
void |
JobManagerContext.schedule(JobInstance pJobInstance,
DRMConnector pConnector,
long pRepeatInterval)
schedule the given DRMConnector for repeated execution in this job context for the given job |
void |
JobManagerContext.schedule(JobInstance pJobInstance,
DRMConnector pConnector,
java.lang.String pCronExpression)
schedule the given DRMConnector for repeated execution in this job context for the given job |
void |
JobManagerContext.schedule(JobInstance pJobInstance,
java.lang.String pConnectorName)
schedule the given named DRMConnector for immediate execution in this job context for the given job |
void |
JobManagerContext.schedule(JobInstance pJobInstance,
java.lang.String pConnectorName,
long pRepeatInterval)
schedule the given named DRMConnector for immediate execution in this job context for the given job |
void |
JobManagerContext.schedule(JobInstance pJobInstance,
java.lang.String pConnectorName,
java.lang.String pCronExpression)
schedule the given named DRMConnector for immediate execution in this job context for the given job |
Uses of JobInstance in org.icenigrid.gridsam.core.plugin.connector.common |
---|
Methods in org.icenigrid.gridsam.core.plugin.connector.common with parameters of type JobInstance | |
---|---|
static boolean |
MultiStageDRMConnector.isNeedExecution(JobInstance pInstance)
Whether this job need execution? Only the job whose last state is before the executed state is possible need execution. |
static boolean |
MultiStageDRMConnector.isNeedStageIn(JobInstance pInstance)
Whether this job need stage in? Only the job whose last state is before the staged-in state is possible need a stage-in. |
static boolean |
MultiStageDRMConnector.isNeedStageout(JobInstance pInstance)
Whether this job need stage out? Only the job whose last state is before the staged-out state is possible need stage out. |
MultiStageDRMConnector.ProgressInstruction |
MultiStageDRMConnector.ProgressCriteria.progress(JobInstance pInstance)
test whether the pipeline should progress to the next stage |
Uses of JobInstance in org.icenigrid.gridsam.core.plugin.manager |
---|
Methods in org.icenigrid.gridsam.core.plugin.manager that return JobInstance | |
---|---|
JobInstance |
DefaultJobManager.findJobInstance(java.lang.String pID)
find a job instance using the job identifier |
JobInstance[] |
DefaultJobManager.findJobInstance(java.lang.String[] pIDs)
|
JobInstance |
DefaultJobManager.rerunJob(java.lang.String pJobID,
JobState startState,
org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument pDesc,
boolean pSuspended)
rerun a job |
JobInstance |
DefaultJobManager.startJob(java.lang.String pID)
Start a pending job. |
JobInstance[] |
DefaultJobManager.startJob(java.lang.String[] pIDs)
|
JobInstance |
DefaultJobManager.submitJob(org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument pDesc)
submit a job to this JobManager instance. |
JobInstance[] |
DefaultJobManager.submitJob(org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument[] pDesc,
boolean pSuspended)
|
JobInstance |
DefaultJobManager.submitJob(org.icenigrid.schema.jsdl.y2005.m11.JobDefinitionDocument pDesc,
boolean pSuspended)
submit a job to this JobManager instances |
Methods in org.icenigrid.gridsam.core.plugin.manager with parameters of type JobInstance | |
---|---|
void |
DefaultJobManager.onChange(JobInstance pInstance)
notify the state of the JobInstance has changed |
void |
DefaultJobManagerContext.schedule(JobInstance pJobInstance,
DRMConnector pConnector)
schedule the given DRMConnector for immediate execution in this job context for the given job |
void |
DefaultJobManagerContext.schedule(JobInstance pJobInstance,
DRMConnector pConnector,
long pRepeatInterval)
schedule the given DRMConnector for repeated execution in this job context for the given job |
void |
DefaultJobManagerContext.schedule(JobInstance pJobInstance,
DRMConnector pConnector,
java.lang.String pCronExpression)
schedule the given DRMConnector for repeated execution in this job context for the given job |
void |
DefaultJobManagerContext.schedule(JobInstance pJobInstance,
java.lang.String pConnectorName)
schedule the given named DRMConnector for immediate execution in this job context for the given job |
void |
DefaultJobManagerContext.schedule(JobInstance pJobInstance,
java.lang.String pConnectorName,
long pRepeatInterval)
schedule the given named DRMConnector for immediate execution in this job context for the given job |
void |
DefaultJobManagerContext.schedule(JobInstance pJobInstance,
java.lang.String pConnectorName,
java.lang.String pCronExpression)
schedule the given named DRMConnector for immediate execution in this job context for the given job |
Uses of JobInstance in org.icenigrid.gridsam.core.plugin.persistence.common |
---|
Classes in org.icenigrid.gridsam.core.plugin.persistence.common that implement JobInstance | |
---|---|
class |
DefaultMutableJobInstance
Default implementation of MutableJobInstance |
Uses of JobInstance in org.icenigrid.gridsam.core.plugin.persistence.hibernate |
---|
Methods in org.icenigrid.gridsam.core.plugin.persistence.hibernate with parameters of type JobInstance | |
---|---|
protected void |
HibernateJobInstanceStore.notifyChange(JobInstance pInstance)
notify change to all listeners |
Uses of JobInstance in org.icenigrid.gridsam.core.support |
---|
Methods in org.icenigrid.gridsam.core.support with parameters of type JobInstance | |
---|---|
static void |
GridSAMSupport.populateJobStatus(JobInstance pJobInstance,
org.icenigrid.schema.service.gridsam.JobStatusType pJobStatusType)
populate a job status type with information from the job instance |
Uses of JobInstance in org.icenigrid.gridsam.core.util |
---|
Methods in org.icenigrid.gridsam.core.util with parameters of type JobInstance | |
---|---|
static void |
BatchUtils.deleteTempAfterFailed(JobInstance pJob)
To delete the temp dir after setting the job as failed! Just try once :) |
static org.dom4j.Element |
HPCGSupport.toJobIdentifier(JobInstance pInstance)
convert a JobInstance object to a HPCG JobStatus document. |
static org.dom4j.Element |
HPCGSupport.toJobStatus(JobInstance pInstance)
convert a JobInstance object to a HPCG JobStatus document |
Uses of JobInstance in org.icenigrid.gridsam.integration.common |
---|
Methods in org.icenigrid.gridsam.integration.common that return JobInstance | |
---|---|
protected JobInstance |
AbstractJobManagerTestCase.assertSuccessfulSubmission(java.lang.String pJSDL,
long fWait)
submit a job that is expected to reach the done stage in pWait number of milliseconds |
protected JobInstance |
AbstractJobManagerTestCase.assertTerminatedSubmission(java.lang.String pJSDL,
long fWait)
submit a job that is expected to reach the done stage in pWait number of milliseconds |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |