beehive.util

Class Task

java.lang.Object

beehive.util.Task

All Implemented Interfaces:

Serializable

public class Task
extends Object
implements Serializable

A Task maintains information about the work the Worker is responsible for. This class is extendable and therefore can maintain more information for more complex tasks. At its core, each Task maintains at least the following

• nodeId -- The id of the node that the Worker will fetch to perform its operations
• phase -- Which phase the task is in during its lifetime. There are three phases:
  • STARTUP
  • GENERIC
  • TERMINATION
• status -- The status of the task during its lifetime
  • TASK INIT -- The task was just created
  • TASK WAITING -- The task is in the workpool waiting to be picked up
  • TASK RUNNING -- A Worker picked up the task and is executing it
  • TASK FINISHED -- The task has been validated, committed, and removed from the workpool
• target location -- Which of the workpools in the cluster this task should ideally be deposited
• affinity level -- The affinity to which this task is to be deposited to the target location. There are three levels of affinity:
  • NO AFFINITY -- Does not matter if the task is deposited at the target location
  • WEAK AFFINITY -- Deposit the task at the target location if possible
  • STRONG AFFINITY -- The task must be deposited at the target location

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
int	affinityLevel
long	initTime
String	nodeId
String	phase
int	retryCount
long	scheduleTime
int	status
String	targetLocation
String	taskId
TransactionInfo	txnInfo

Constructor Summary

Constructors

Constructor and Description
Task()
Task(String id)
Task(String id, TransactionInfo txnInfo)
Task(String id, TransactionInfo txnInfo, int affinityLevel, String location)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getNodeId()
TransactionInfo	getTxnInfo()
void	setAffinityLevel(int affinityLevel, String location)
void	setPhase(String phase)
void	setStatus(int status)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

taskId

public String taskId

nodeId

public String nodeId

txnInfo

public TransactionInfo txnInfo

phase

public String phase

affinityLevel

public int affinityLevel

targetLocation

public String targetLocation

status

public int status

retryCount

public int retryCount

initTime

public long initTime

scheduleTime

public long scheduleTime

Constructor Detail

Task

public Task()

Task

public Task(String id)

Parameters:

id - The unique identifier for this task

Task

public Task(String id,
            TransactionInfo txnInfo)

Parameters:

id - The unique identifier for this task

txnInfo - The TransactionInfo associated with this task

Task

public Task(String id,
            TransactionInfo txnInfo,
            int affinityLevel,
            String location)

Parameters:

id - The unique identifier for this task

txnInfo - The TransactionInfo associated with this task

affinityLevel - How strongly this task should be deposited to location with

• 0 being no affinity
• 1 being weak affinity
• 2 being strong affinity

location - The url of the server where this task should ideally be deposited

Method Detail

setPhase

public void setPhase(String phase)

Parameters:

phase - Can be one of the following:

• STARTUP
• GENERIC
• TERMINATION

getNodeId

public String getNodeId()

toString

public String toString()

Overrides:

toString in class Object

getTxnInfo

public TransactionInfo getTxnInfo()

setStatus

public void setStatus(int status)

Parameters:

status -

See Also:

TaskConstants

setAffinityLevel

public void setAffinityLevel(int affinityLevel,
                             String location)

Parameters:

affinityLevel - How strongly this task should be deposited to location with

• 0 being no affinity
• 1 being weak affinity
• 2 being strong affinity

location - The url of the server where this task should ideally be deposited.

equals

public boolean equals(Object o)

Overrides:

equals in class Object