public class JobSummaryImpl extends JobInfoImpl implements JobSummary, java.io.Serializable
Constructor and Description |
---|
JobSummaryImpl()
Creates a new instance of JobSummary
|
Modifier and Type | Method and Description |
---|---|
void |
addArrayPredecessor(int job_id)
Add the job id of an array predecessor
|
void |
addHardRequest(java.lang.String name,
java.lang.String value,
double uc)
Add a hard resource request to the job summary.
|
void |
addHardRequestedMasterQueue(java.lang.String qname)
Adds a hard requested master queue to the job
(see qsub -masterq).
|
void |
addHardRequestedQueue(java.lang.String qname)
Add a hard requested queue
|
void |
addPredecessor(int job_id)
Add the job id of a predecessor
|
void |
addRequest(java.lang.String name,
java.lang.String value)
Add a resource request to the job
|
void |
addRequestedArrayPredecessor(java.lang.String name)
add a requested array predecessor to the job
(array predecessor of a job can be requested with
qsub -hold_jid_ad)
|
void |
addRequestedPredecessor(java.lang.String name)
add a requested predecessor to the job
(predecessor of a job can be requested with
qsub -hold_jid)
|
void |
addSoftRequest(java.lang.String name,
java.lang.String value)
Add a soft request to the job
|
void |
addSoftRequestedMasterQueue(java.lang.String qname)
Add a soft requested master queue
(see qsub -masterq)
|
void |
addSoftRequestedQueue(java.lang.String qname)
Add a soft requested queue
|
void |
addTask(TaskSummary taskSummary)
Add a new task to the job
|
java.util.List<java.lang.Integer> |
getArrayPredecessors()
Get a list of all array predecessor job id
|
java.lang.String |
getCheckpointEnv()
Get the checkpoint environment of the job
|
int |
getCpuUsage()
Get the cpu usage of the job.
|
java.util.Date |
getDeadline()
Get the deadline of the job
|
java.lang.String |
getDepartment()
Get the department of the job
|
double |
getDlcontr()
Get the urgency value contribution that reflects the
urgency related to the jobs deadline initiation time.
|
long |
getFtickets()
Get the functional portion of the total number of tickets
assigned to the job currently.
|
java.lang.String |
getGrantedPEName()
Get the name of the granted PE
|
int |
getGrantedPESlots()
Get the number of granted PE slots
|
java.util.List<java.lang.String> |
getHardRequestedMasterQueues()
Get a list of all hard requested master queues
|
java.util.List<java.lang.String> |
getHardRequestedQueues()
Get a list of all hard requested queues
|
java.util.Set<java.lang.String> |
getHardRequestNames()
Get a set of all hard requested resources.
|
HardRequestValue |
getHardRequestValue(java.lang.String name)
Get a value of a hard requested resource
|
double |
getIoUsage()
Get the io usage of the job.
|
double |
getMemUsage()
Get the memory usage of the job.
|
double |
getNormalizedPriority()
Get the normalized priority of the job
|
double |
getNormalizedRequestedPriority()
Get the priority of the job which has been
requested by the user in normalized form
|
double |
getNormalizedTickets()
Get the normalized total number of tickets
|
double |
getNormalizedUrgency()
Get the jobs total urgency value in normalized fashion.
|
long |
getOtickets()
Get the override portion of the total number of tickets
assigned to the job currently
|
long |
getOverrideTickets()
Get the override tickets of the job
|
java.lang.String |
getParallelEnvironmentName()
Get the name of the parallel environment of the job
|
java.lang.String |
getParallelEnvironmentRange()
Get the requested PE slot range.
|
java.util.List<java.lang.Integer> |
getPredecessors()
Get a list of all predecessor job id
|
java.lang.String |
getProject()
Get the project of the job
|
java.util.List<java.lang.String> |
getRequestedArrayPredecessors()
Get a list of all requested array predecessors
|
java.util.List<java.lang.String> |
getRequestedPredecessors()
Get a list of all requested predecessors
|
java.util.Set<java.lang.String> |
getRequestNames()
Get all resources which have been requested by this job.
|
java.lang.String |
getRequestValue(java.lang.String name)
Get value of a requested resource
|
double |
getRrcontr()
Get the urgency value contribution that reflects the urgency
that is related to the jobs overall resource requirement.
|
double |
getShare()
Get the share of the total system to which the job is entitled currently.
|
int |
getSlots()
Get the number of used slots
|
java.util.List |
getSoftRequestedMasterQueues()
Get a list of all soft requested master queues
|
java.util.List<java.lang.String> |
getSoftRequestedQueues()
Get a list of all soft requested queues
|
java.util.Set<java.lang.String> |
getSoftRequestNames()
Get a set of all soft requested resources
|
java.lang.String |
getSoftRequestValue(java.lang.String name)
Get the value of a soft requested resource
|
long |
getStickets()
Get the share portion of the total number of tickets
assigned to the job currently.
|
int |
getTaskCount()
Get the number of tasks of this job
|
java.util.List<TaskSummary> |
getTaskList()
Get the list of tasks of this job
|
long |
getTickets()
Get the currently number of tickets of the job
|
double |
getUrgency()
Get the total urgency of the job
|
double |
getWtcontr()
Get the urgency value contribution that reflects the
urgency related to the jobs waiting time.
|
boolean |
hasCpuUsage()
Determine if the job has a cpu usage
|
boolean |
hasIoUsage()
Determine if the job has a io usage
|
boolean |
hasMemUsage()
Determine if the job has a memory usage
|
boolean |
isArray()
Determine if the job is an array job
|
boolean |
isQueueAssigned()
Determine if the job is assigned to a queue
|
boolean |
isRunning()
Determine if the job is running
|
boolean |
isZombie()
Determine if the job is a zombie
|
void |
setArray(boolean isArray)
Set the array job flag
|
void |
setCheckpointEnv(java.lang.String checkpointEnv)
Set the checkpoint environment of the job
|
void |
setCpuUsage(int cpuUsage)
Set the cpu usage of the job
|
void |
setDeadline(java.util.Date deadline)
Set the deadline of the job
|
void |
setDeadline(long deadline)
Set the deadline of the job
|
void |
setDepartment(java.lang.String department)
Set the department of the job
|
void |
setDlcontr(double dlcontr)
Set the urgency value contribution that reflects the
urgency related to the jobs deadline initiation time.
|
void |
setFtickets(long ftickets)
Set the functional portion of the total number of tickets
assigned to the job currently.
|
void |
setGrantedPEName(java.lang.String grantedPEName)
Set the name of the granted PE
|
void |
setGrantedPESlots(int grantedPESlots)
Set the number of granted PE slots
|
void |
setIoUsage(double ioUsage)
Set the io usage of the job.
|
void |
setMemUsage(double memUsage)
Set the memory usage of the job
|
void |
setNormalizedPriority(double nprior)
Get the normalized priority of the job
param nprior the normalized priority
|
void |
setNormalizedRequestedPriority(double nppri)
Set the priority of the job which has been requested
by the user in normalized form
|
void |
setNormalizedTickets(double ntckts)
Set the normalized total number of tickets
|
void |
setNormalizedUrgency(double nurg)
Set the jobs total urgency value in normalized fashion.
|
void |
setOtickets(long otickets)
Set the override portion of the total number of tickets
assigned to the job currently
|
void |
setOverrideTickets(long overrideTickets)
Set the override tickets of the job
|
void |
setParallelEnvironmentName(java.lang.String parallelEnvironmentName)
Set the name of the parallel environment of the job
|
void |
setParallelEnvironmentRange(java.lang.String parallelEnvironmentRange)
Set the requested PE slot range.
|
void |
setProject(java.lang.String project)
Set the project of the job
|
void |
setQueueAssigned(boolean isQueueAssigned)
Set the queue assigned falg
|
void |
setRrcontr(double rrcontr)
Set the urgency value contribution that reflects the urgency
that is related to the jobs overall resource requirement.
|
void |
setRunning(boolean isRunning)
Set the is running flag
|
void |
setShare(double share)
Set the share of the total system to which the job is entitled currently.
|
void |
setSlots(int slots)
Set the number of used slots
|
void |
setStickets(long stickets)
Set the share portion of the total number of tickets
assigned to the job currently.
|
void |
setTickets(long tickets)
Set the currently number of tickets of the job
|
void |
setUrgency(double urg)
Set the total urgency of the job
|
void |
setWtcontr(double wtcontr)
Set the urgency value contribution that reflects the
urgency related to the jobs waiting time.
|
void |
setZombie(boolean isZombie)
Set the zombie flag
|
getId, getMasterQueue, getName, getPriority, getQinstanceName, getQueue, getStartTime, getState, getSubmitTime, getTaskId, getUser, setId, setMasterQueue, setName, setPriority, setQinstanceName, setQueue, setStartTime, setStartTime, setState, setSubmitTime, setSubmitTime, setTaskId, setUser
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getId, getMasterQueue, getName, getPriority, getQinstanceName, getQueue, getStartTime, getState, getSubmitTime, getTaskId, getUser
public java.util.List<TaskSummary> getTaskList()
getTaskList
in interface JobSummary
public int getTaskCount()
getTaskCount
in interface JobSummary
public void addTask(TaskSummary taskSummary)
taskSummary
- the new taskpublic void addRequest(java.lang.String name, java.lang.String value)
name
- of the resourcevalue
- requested value of the resourcepublic java.util.Set<java.lang.String> getRequestNames()
Get all resources which have been requested by this job.
recource requsts are specified by qsub with the -l option (see man qsub).
getRequestNames
in interface JobSummary
public java.lang.String getRequestValue(java.lang.String name)
getRequestValue
in interface JobSummary
name
- name of the requested resourcepublic void addHardRequest(java.lang.String name, java.lang.String value, double uc)
name
- name of the resourcevalue
- requested valueuc
- jobs urgency contribution for this resourcepublic java.util.Set<java.lang.String> getHardRequestNames()
getHardRequestNames
in interface JobSummary
public HardRequestValue getHardRequestValue(java.lang.String name)
getHardRequestValue
in interface JobSummary
name
- name of the hard requested resourcepublic void addSoftRequest(java.lang.String name, java.lang.String value)
name
- name of the requested resourcevalue
- requested valuepublic java.util.Set<java.lang.String> getSoftRequestNames()
getSoftRequestNames
in interface JobSummary
public java.lang.String getSoftRequestValue(java.lang.String name)
getSoftRequestValue
in interface JobSummary
name
- name of the resourcepublic void addHardRequestedQueue(java.lang.String qname)
qname
- of the hard requested queuepublic java.util.List<java.lang.String> getHardRequestedQueues()
getHardRequestedQueues
in interface JobSummary
public void addSoftRequestedQueue(java.lang.String qname)
addSoftRequestedQueue
in interface JobSummary
qname
- name of the soft requested queuepublic java.util.List<java.lang.String> getSoftRequestedQueues()
getSoftRequestedQueues
in interface JobSummary
public void addHardRequestedMasterQueue(java.lang.String qname)
qname
- name of the hard requested master queuepublic java.util.List<java.lang.String> getHardRequestedMasterQueues()
getHardRequestedMasterQueues
in interface JobSummary
public void addSoftRequestedMasterQueue(java.lang.String qname)
addSoftRequestedMasterQueue
in interface JobSummary
qname
- of the soft requested master queuepublic java.util.List getSoftRequestedMasterQueues()
getSoftRequestedMasterQueues
in interface JobSummary
public void addRequestedPredecessor(java.lang.String name)
name
- of the predecessorpublic void addRequestedArrayPredecessor(java.lang.String name)
name
- of the array predecessorpublic java.util.List<java.lang.String> getRequestedPredecessors()
getRequestedPredecessors
in interface JobSummary
public java.util.List<java.lang.String> getRequestedArrayPredecessors()
getRequestedArrayPredecessors
in interface JobSummary
public void addPredecessor(int job_id)
job_id
- job id of the predecessorpublic void addArrayPredecessor(int job_id)
job_id
- job id of the array predecessorpublic java.util.List<java.lang.Integer> getPredecessors()
getPredecessors
in interface JobSummary
public java.util.List<java.lang.Integer> getArrayPredecessors()
getArrayPredecessors
in interface JobSummary
public double getNormalizedUrgency()
getNormalizedUrgency
in interface JobSummary
public void setNormalizedUrgency(double nurg)
setNormalizedUrgency
in interface JobSummary
nurg
- the normalized total urgencypublic double getUrgency()
getUrgency
in interface JobSummary
public void setUrgency(double urg)
urg
- the total urgencypublic double getNormalizedRequestedPriority()
getNormalizedRequestedPriority
in interface JobSummary
public void setNormalizedRequestedPriority(double nppri)
nppri
- requested priority in normalizedpublic double getNormalizedPriority()
getNormalizedPriority
in interface JobSummary
public void setNormalizedPriority(double nprior)
public double getNormalizedTickets()
getNormalizedTickets
in interface JobSummary
public void setNormalizedTickets(double ntckts)
ntckts
- the normalized total number of ticketspublic double getRrcontr()
getRrcontr
in interface JobSummary
public void setRrcontr(double rrcontr)
public double getWtcontr()
getWtcontr
in interface JobSummary
public void setWtcontr(double wtcontr)
wtcontr
- the urgency value contributionpublic double getDlcontr()
getDlcontr
in interface JobSummary
public void setDlcontr(double dlcontr)
dlcontr
- the urgency value contributionpublic java.lang.String getProject()
getProject
in interface JobSummary
public void setProject(java.lang.String project)
project
- project of the jobpublic java.lang.String getDepartment()
getDepartment
in interface JobSummary
public void setDepartment(java.lang.String department)
department
- the department of the jobpublic java.util.Date getDeadline()
getDeadline
in interface JobSummary
public void setDeadline(java.util.Date deadline)
deadline
- the deadline of the jobpublic void setDeadline(long deadline)
deadline
- the deadline of the job in millispublic boolean hasCpuUsage()
hasCpuUsage
in interface JobSummary
public int getCpuUsage()
0
is returnedgetCpuUsage
in interface JobSummary
hasCpuUsage
public void setCpuUsage(int cpuUsage)
cpuUsage
- the cpu usagepublic boolean hasMemUsage()
hasMemUsage
in interface JobSummary
true
if the job has a memory usagepublic double getMemUsage()
0
is returned.getMemUsage
in interface JobSummary
hasMemUsage
public void setMemUsage(double memUsage)
memUsage
- the memory usagepublic boolean hasIoUsage()
hasIoUsage
in interface JobSummary
public double getIoUsage()
0
is returned.getIoUsage
in interface JobSummary
hasIoUsage
public void setIoUsage(double ioUsage)
ioUsage
- the io usage of the jobpublic boolean isZombie()
isZombie
in interface JobSummary
false
if the job a zombiepublic void setZombie(boolean isZombie)
isZombie
- the zombie flagpublic long getOverrideTickets()
getOverrideTickets
in interface JobSummary
public void setOverrideTickets(long overrideTickets)
overrideTickets
- the override tickets of the jobpublic boolean isQueueAssigned()
isQueueAssigned
in interface JobSummary
true
if the job is assigned to a queuepublic void setQueueAssigned(boolean isQueueAssigned)
isQueueAssigned
- the queue assigned flagpublic long getTickets()
getTickets
in interface JobSummary
public void setTickets(long tickets)
tickets
- currently number of ticketspublic long getOtickets()
getOtickets
in interface JobSummary
public void setOtickets(long otickets)
otickets
- the override portion of the total number of ticketspublic long getFtickets()
getFtickets
in interface JobSummary
public void setFtickets(long ftickets)
ftickets
- the functional portion of the total number of ticketspublic long getStickets()
getStickets
in interface JobSummary
public void setStickets(long stickets)
stickets
- the share portion of the total number of ticketspublic double getShare()
getShare
in interface JobSummary
public void setShare(double share)
share
- the share of the jobpublic int getSlots()
getSlots
in interface JobSummary
public void setSlots(int slots)
setSlots
in interface JobSummary
slots
- the number of used slotspublic boolean isArray()
isArray
in interface JobSummary
true
if the job is an array jobpublic void setArray(boolean isArray)
isArray
- the array job flagpublic boolean isRunning()
isRunning
in interface JobSummary
true
of the job is runningpublic void setRunning(boolean isRunning)
isRunning
- the is running flagpublic java.lang.String getParallelEnvironmentName()
getParallelEnvironmentName
in interface JobSummary
public void setParallelEnvironmentName(java.lang.String parallelEnvironmentName)
parallelEnvironmentName
- name of the parallel environmentpublic java.lang.String getParallelEnvironmentRange()
getParallelEnvironmentRange
in interface JobSummary
public void setParallelEnvironmentRange(java.lang.String parallelEnvironmentRange)
parallelEnvironmentRange
- the requested PE slot rangepublic java.lang.String getGrantedPEName()
getGrantedPEName
in interface JobSummary
public void setGrantedPEName(java.lang.String grantedPEName)
grantedPEName
- name of the granted PEpublic int getGrantedPESlots()
getGrantedPESlots
in interface JobSummary
public void setGrantedPESlots(int grantedPESlots)
grantedPESlots
- number of granted PE slotspublic java.lang.String getCheckpointEnv()
getCheckpointEnv
in interface JobSummary
public void setCheckpointEnv(java.lang.String checkpointEnv)
checkpointEnv
- the checkpoint environment of the jobCopyright © 2007 Sun Microsystems, Inc. All rights reserved.