Package titan.scheduler

Class Job

java.lang.Object

titan.scheduler.Job

All Implemented Interfaces:

Comparable<Job>

public class Job
extends Object
implements Comparable<Job>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Job.Status

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	affinityRequired
private List<String>	dependenciesIds
private String	id
private String	payload
private String	preferredWorkerId
private final int	priority
static final int	PRIORITY_HIGH
static final int	PRIORITY_LOW
static final int	PRIORITY_NORMAL
private int	retryCount
private Set<String>	satisfiedDeps
private final long	scheduledTime
private Job.Status	status

Constructor Summary

Constructors

Constructor	Description
Job(String payload)
Job(String payload, int priority, long delayInMs)
Job(String id, String payload, int priority, long delayInMs, List<String> dependenciesIds)

Method Summary

Modifier and Type	Method	Description
int	compareTo(Job other)
private static String	constructFilePayload(String type, String filename, String port)
static Job	fromDagString(String jobStr)
List<String>	getDependenciesIds()
String	getId()
String	getPayload()
String	getPreferredWorkerId()
int	getPriority()
int	getRetryCount()
long	getScheduledTime()
Job.Status	getStatus()
void	incrementRetry()
Boolean	isAffinityRequired()
boolean	isReady()
void	resolveDependencies(String parentId)
void	setAffinityRequired(boolean isAffinityRequired)
void	setId(String id)
void	setPayload(String payload)
void	setPreferredWorkerId(String preferredWorkerId)
void	setStatus(Job.Status status)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

PRIORITY_LOW

public static final int PRIORITY_LOW

See Also:

• Constant Field Values

PRIORITY_NORMAL

public static final int PRIORITY_NORMAL

See Also:

• Constant Field Values

PRIORITY_HIGH

public static final int PRIORITY_HIGH

See Also:

• Constant Field Values

id

private String id

payload

private String payload

retryCount

private int retryCount

status

private Job.Status status

priority

private final int priority

scheduledTime

private final long scheduledTime

dependenciesIds

private List<String> dependenciesIds

satisfiedDeps

private Set<String> satisfiedDeps

preferredWorkerId

private String preferredWorkerId

affinityRequired

private boolean affinityRequired

Constructor Details

Job

public Job(String payload)

Job

public Job(String payload,
 int priority,
 long delayInMs)

Job

public Job(String id,
 String payload,
 int priority,
 long delayInMs,
 List<String> dependenciesIds)

Method Details

setId

public void setId(String id)

setPayload

public void setPayload(String payload)

isReady

public boolean isReady()

resolveDependencies

public void resolveDependencies(String parentId)

fromDagString

public static Job fromDagString(String jobStr)

constructFilePayload

private static String constructFilePayload(String type,
 String filename,
 String port)

getDependenciesIds

public List<String> getDependenciesIds()

getScheduledTime

public long getScheduledTime()

setStatus

public void setStatus(Job.Status status)

getStatus

public Job.Status getStatus()

getPriority

public int getPriority()

incrementRetry

public void incrementRetry()

getRetryCount

public int getRetryCount()

getPayload

public String getPayload()

getId

public String getId()

compareTo

public int compareTo(Job other)

Specified by:

compareTo in interface Comparable<Job>

toString

public String toString()

Overrides:

toString in class Object

setPreferredWorkerId

public void setPreferredWorkerId(String preferredWorkerId)

getPreferredWorkerId

public String getPreferredWorkerId()

setAffinityRequired

public void setAffinityRequired(boolean isAffinityRequired)

isAffinityRequired

public Boolean isAffinityRequired()