public class JobInfoImpl extends Object implements JobInfo
org.ow2.proactive.scheduler.job.InternalJob#setJobInfo(JobInfo)
.
This will automatically put the job up to date.Constructor and Description |
---|
JobInfoImpl() |
JobInfoImpl(JobId jobId,
String owner) |
JobInfoImpl(JobInfoImpl jobInfo) |
Modifier and Type | Method and Description |
---|---|
void |
clearTasksChanges() |
Map<Integer,Boolean> |
getAttachedServices()
Returns a map of attached PSA services
{ServiceId, EnableActions}
|
String |
getBucketName()
Returns the bucket name associated with this job
|
int |
getChildrenCount()
Return the number of children jobs
|
long |
getCumulatedCoreTime()
Returns the cumulated time consumed by task executions for this job
|
String |
getDescription()
Returns the description associated with this job
|
Map<String,Map<String,JobVariable>> |
getDetailedSignals()
Returns the map of signals and input variables
|
Map<String,JobVariable> |
getDetailedVariables()
Returns the variables Map with full definition
|
String |
getDomain()
Return the domain associated with the job owner
|
Map<String,ExternalEndpoint> |
getExternalEndpointUrls()
Returns a set of external endpoint urls
|
long |
getFinishedTime()
Returns the time at which the Job has finished.
|
Map<String,String> |
getGenericInformation()
Returns the generic information Map
|
long |
getInErrorTime()
Returns the time at which a Job was seen as in-error
for the last time.
|
JobId |
getJobId()
Returns an identifier that uniquely identifies the Job
within a Scheduler instance.
|
String |
getJobOwner()
Returns the name of the Job owner.
|
String |
getLabel()
Returns the label associated with this job
|
long |
getLastUpdatedTime()
Returns the time at which the last updated happened on the Job.
|
List<ClientTaskState> |
getModifiedTasks() |
int |
getNumberOfFailedTasks()
Returns the number of tasks managed by the Job
that are in a failed state due to a resource failure.
|
int |
getNumberOfFaultyTasks()
Returns the number of tasks managed by the Job
that are in a faulty state.
|
int |
getNumberOfFinishedTasks()
Returns the number of tasks managed by the Job
which are finished.
|
int |
getNumberOfInErrorTasks()
Returns the number of tasks managed by the Job
that are in an in-error state.
|
int |
getNumberOfNodes()
Returns the number of nodes used by the job since the beginning of its execution
|
int |
getNumberOfNodesInParallel()
Returns the number of nodes in parallel used by the job since the beginning of its execution
|
int |
getNumberOfPendingTasks()
Returns the number of tasks managed by the Job
which are pending.
|
int |
getNumberOfRunningTasks()
Returns the number of tasks managed by the Job
which are running.
|
Long |
getParentId()
Return the parent id of the job
|
List<String> |
getPreciousTasks()
Return the list of tasks names with precious results
|
JobPriority |
getPriority()
Returns the priority of the Job.
|
String |
getProjectName()
Returns the project name associated with this job
|
long |
getRemovedTime()
Returns the time at which the Job has been marked as removed.
|
long |
getScheduledTimeForRemoval()
Returns the scheduled time for removal.
|
Set<String> |
getSignals()
Returns the set of signals used by the job
|
Long |
getStartAt()
Return the scheduled time of the job, defined by the generic information START_AT
|
long |
getStartTime()
Returns the time at which the Job has started.
|
JobStatus |
getStatus()
Return the status of the job.
|
String |
getSubmissionMode()
Returns the portal name via the job was submitted
|
long |
getSubmittedTime()
Returns the time at which the Job was submitted.
|
Set<TaskId> |
getTasksSkipped()
Used as an argument for
SchedulerEvent.TASK_SKIPPED to
specify which tasks were skipped |
String |
getTenant()
Return the tenant associated with the job owner
|
int |
getTotalNumberOfTasks()
Returns the number of tasks managed by the Job.
|
Map<String,String> |
getVariables()
Returns the variables Map
|
Map<String,String> |
getVisualizationConnectionStrings()
Return a map of visualization connection strings
key: task name
value: connection string
|
Map<String,String> |
getVisualizationIcons()
Return a map of visualization icons
key: task name
value: icon associated with the task
|
boolean |
isResultMapPresent()
Return true if a non-empty result map is attached to this job
|
boolean |
isStarted() |
boolean |
isToBeRemoved()
Returns a boolean that indicates whether the job
is marked for removal or not.
|
void |
setAttachedServices(Map<Integer,Boolean> attachedServices) |
void |
setBucketName(String bucketName) |
void |
setChildrenCount(int childrenCount) |
void |
setCumulatedCoreTime(long cumulatedCoreTime) |
void |
setDescription(String description) |
void |
setDetailedSignals(Map<String,Map<String,JobVariable>> detailedSignals)
Sets the map of job signals and input variables
|
void |
setDetailedVariables(Map<String,JobVariable> detailedVariables) |
void |
setDomain(String domain) |
void |
setExternalEndpointUrls(Map<String,ExternalEndpoint> externalEndpointUrls) |
void |
setFinishedTime(long finishedTime) |
void |
setGenericInformation(Map<String,String> genericInformation) |
void |
setInErrorTime(long inErrorTime) |
void |
setJobId(JobId jobId) |
void |
setJobOwner(String owner) |
void |
setLabel(String label) |
void |
setLastUpdatedTime(long lastUpdatedTime) |
void |
setNumberOfFailedTasks(int numberOfFailedTasks) |
void |
setNumberOfFaultyTasks(int numberOfFaultyTasks) |
void |
setNumberOfFinishedTasks(int numberOfFinishedTasks) |
void |
setNumberOfInErrorTasks(int numberOfInErrorTasks) |
void |
setNumberOfNodes(int numberOfNodes) |
void |
setNumberOfNodesInParallel(int numberOfNodesInParallel) |
void |
setNumberOfPendingTasks(int numberOfPendingTasks) |
void |
setNumberOfRunningTasks(int numberOfRunningTasks) |
void |
setParentId(Long parentId) |
void |
setPreciousTasks(List<String> preciousTasks) |
void |
setPriority(JobPriority priority) |
void |
setProjectName(String projectName) |
void |
setRemovedTime(long removedTime) |
void |
setResultMapPresent(boolean resultMapPresent) |
void |
setScheduledTimeForRemoval(long scheduledTimeForRemoval) |
void |
setSignals(Set<String> signals)
Sets the set of job signals
|
void |
setStartAt(Long startAt) |
void |
setStartTime(long startTime) |
void |
setStatus(JobStatus status) |
void |
setSubmissionMode(String submissionMode) |
void |
setSubmittedTime(long submittedTime) |
void |
setTasksChanges(ChangedTasksInfo changesInfo,
JobState job) |
void |
setTenant(String tenant) |
void |
setToBeRemoved() |
void |
setTotalNumberOfTasks(int totalNumberOfTasks) |
void |
setVariables(Map<String,String> variables) |
void |
setVisualizationConnectionStrings(Map<String,String> visualizationConnectionStrings)
Sets the visualization connection string map
|
void |
setVisualizationIcons(Map<String,String> visualizationIcons)
Sets the visualization icons
|
String |
toString() |
public JobInfoImpl()
public JobInfoImpl(JobInfoImpl jobInfo)
public String getJobOwner()
getJobOwner
in interface JobInfo
public void setJobOwner(String owner)
public String getTenant()
JobInfo
public void setTenant(String tenant)
public String getDomain()
JobInfo
public void setDomain(String domain)
public String getProjectName()
JobInfo
getProjectName
in interface JobInfo
public void setProjectName(String projectName)
public String getDescription()
JobInfo
getDescription
in interface JobInfo
public void setDescription(String description)
public String getBucketName()
JobInfo
getBucketName
in interface JobInfo
public void setBucketName(String bucketName)
public String getLabel()
JobInfo
public void setLabel(String label)
public String getSubmissionMode()
JobInfo
getSubmissionMode
in interface JobInfo
public void setSubmissionMode(String submissionMode)
public JobId getJobId()
public void setJobId(JobId jobId)
public long getFinishedTime()
getFinishedTime
in interface JobInfo
public void setFinishedTime(long finishedTime)
public long getRemovedTime()
getRemovedTime
in interface JobInfo
public void setRemovedTime(long removedTime)
public long getStartTime()
getStartTime
in interface JobInfo
public boolean isStarted()
public void setStartTime(long startTime)
public long getInErrorTime()
getInErrorTime
in interface JobInfo
-1
.public void setInErrorTime(long inErrorTime)
public long getSubmittedTime()
getSubmittedTime
in interface JobInfo
public void setSubmittedTime(long submittedTime)
public long getLastUpdatedTime()
JobInfo
getLastUpdatedTime
in interface JobInfo
public void setLastUpdatedTime(long lastUpdatedTime)
public long getCumulatedCoreTime()
JobInfo
getCumulatedCoreTime
in interface JobInfo
public void setCumulatedCoreTime(long cumulatedCoreTime)
public int getNumberOfNodes()
JobInfo
getNumberOfNodes
in interface JobInfo
public void setNumberOfNodes(int numberOfNodes)
public int getNumberOfNodesInParallel()
JobInfo
getNumberOfNodesInParallel
in interface JobInfo
public void setNumberOfNodesInParallel(int numberOfNodesInParallel)
public int getTotalNumberOfTasks()
getTotalNumberOfTasks
in interface JobInfo
public void setTotalNumberOfTasks(int totalNumberOfTasks)
public int getNumberOfFinishedTasks()
getNumberOfFinishedTasks
in interface JobInfo
public void setNumberOfFinishedTasks(int numberOfFinishedTasks)
public int getNumberOfPendingTasks()
getNumberOfPendingTasks
in interface JobInfo
public void setNumberOfPendingTasks(int numberOfPendingTasks)
public int getNumberOfRunningTasks()
getNumberOfRunningTasks
in interface JobInfo
public void setNumberOfRunningTasks(int numberOfRunningTasks)
public int getNumberOfFailedTasks()
getNumberOfFailedTasks
in interface JobInfo
public void setNumberOfFailedTasks(int numberOfFailedTasks)
public int getNumberOfFaultyTasks()
getNumberOfFaultyTasks
in interface JobInfo
public void setNumberOfFaultyTasks(int numberOfFaultyTasks)
public int getNumberOfInErrorTasks()
getNumberOfInErrorTasks
in interface JobInfo
public void setNumberOfInErrorTasks(int numberOfInErrorTasks)
public JobPriority getPriority()
getPriority
in interface JobInfo
public void setPriority(JobPriority priority)
public JobStatus getStatus()
public void setStatus(JobStatus status)
public boolean isToBeRemoved()
isToBeRemoved
in interface JobInfo
public void setToBeRemoved()
public String toString()
toString
in class Object
Object.toString()
public void setTasksChanges(ChangedTasksInfo changesInfo, JobState job)
public void clearTasksChanges()
public List<ClientTaskState> getModifiedTasks()
public Set<TaskId> getTasksSkipped()
SchedulerEvent.TASK_SKIPPED
to
specify which tasks were skippedpublic void setScheduledTimeForRemoval(long scheduledTimeForRemoval)
public long getScheduledTimeForRemoval()
JobInfo
getScheduledTimeForRemoval
in interface JobInfo
public Map<String,String> getGenericInformation()
JobInfo
getGenericInformation
in interface JobInfo
public Map<String,String> getVariables()
JobInfo
getVariables
in interface JobInfo
public Map<String,JobVariable> getDetailedVariables()
JobInfo
getDetailedVariables
in interface JobInfo
public void setDetailedVariables(Map<String,JobVariable> detailedVariables)
public Set<String> getSignals()
JobInfo
getSignals
in interface JobInfo
public void setSignals(Set<String> signals)
JobInfo
setSignals
in interface JobInfo
public Map<String,Map<String,JobVariable>> getDetailedSignals()
JobInfo
getDetailedSignals
in interface JobInfo
public void setDetailedSignals(Map<String,Map<String,JobVariable>> detailedSignals)
JobInfo
setDetailedSignals
in interface JobInfo
public Map<String,String> getVisualizationConnectionStrings()
JobInfo
getVisualizationConnectionStrings
in interface JobInfo
public void setVisualizationConnectionStrings(Map<String,String> visualizationConnectionStrings)
JobInfo
setVisualizationConnectionStrings
in interface JobInfo
public Map<String,String> getVisualizationIcons()
JobInfo
getVisualizationIcons
in interface JobInfo
public void setVisualizationIcons(Map<String,String> visualizationIcons)
JobInfo
setVisualizationIcons
in interface JobInfo
public Map<Integer,Boolean> getAttachedServices()
JobInfo
getAttachedServices
in interface JobInfo
public Map<String,ExternalEndpoint> getExternalEndpointUrls()
JobInfo
getExternalEndpointUrls
in interface JobInfo
public void setExternalEndpointUrls(Map<String,ExternalEndpoint> externalEndpointUrls)
public boolean isResultMapPresent()
JobInfo
isResultMapPresent
in interface JobInfo
public void setResultMapPresent(boolean resultMapPresent)
public List<String> getPreciousTasks()
JobInfo
getPreciousTasks
in interface JobInfo
public Long getParentId()
JobInfo
getParentId
in interface JobInfo
public void setParentId(Long parentId)
public Long getStartAt()
JobInfo
getStartAt
in interface JobInfo
public void setStartAt(Long startAt)
public int getChildrenCount()
JobInfo
getChildrenCount
in interface JobInfo
public void setChildrenCount(int childrenCount)