A C D E G I J M N O P R S T

A

argumentPosition - Variable in class Result

When the results are intermediate, this field specifies which input argument (of the destination task) must be set.

C

computedBy - Variable in class Result

This field keeps track of the task that produced the results.

Consumer - interface Consumer.

This interface should be implemented by the programmer interface.

CXClassLoader - interface CXClassLoader.

This custom class loader can load classes through RMI calls, or from the local file system.

CXTask - class CXTask.

This class implements the Task interface, making the life for the application programmer much easier.

CXTask() - Constructor for class CXTask

Empty constructor

CXTask(TaskHeader) - Constructor for class CXTask

All classes that extend CXTask should include a constructor witha single TaskHeader argument.

D

depth - Variable in class Sequence

The depth of the task in the task graph

DestinationRecord - class DestinationRecord.

This class is used by the system, in order to forward properly the results to another task.

DestinationRecord() - Constructor for class DestinationRecord

destinationTask - Variable in class DestinationRecord

The destination task of the results

destinationTaskInfo - Variable in class Result

When the results are not final, this field keeps information about the destination task, i.e.

E

executeTask(TaskContainer) - Method in class CXTask

This is the only method that must be overwritten by the application programmer.

executeTask(TaskContainer) - Method in interface Task

G

getClassBytes(String) - Method in interface CXClassLoader

returns the bytes of a class which has been serialized.

getDestination() - Method in interface Task

getMissingInputArguments() - Method in class CXTask

getMissingInputArguments() - Method in interface Task

getTaskHeader() - Method in class CXTask

getTaskInfo() - Method in class CXTask

getTaskInfo() - Method in interface Task

I

inputArgumentPosition - Variable in class DestinationRecord

inputArguments - Variable in class TaskHeader

The input arguments of the current task.

isLocal - Variable in class TaskInfo

If a task is local, it means that it cannot be moved from the node in which it was created.

isProducerAllowed - Variable in class TaskInfo

If a task can be executed on a producer this field is set to true, which happens to be the default value.

isServerAllowed - Variable in class TaskInfo

If this field is set to true, a task can be executed on a Task Server.

J

jobId - Variable in class Result

The Id of the current job

jobId - Variable in class Sequence

The Id of the job

jobId - Variable in class TaskInfo

All the tasks that belong to the same task graph, share the same jobId.

M

missingInputArguments - Variable in class TaskHeader

The number of input arguments that are missing, before the task can be executed.

myTaskInfo - Variable in class TaskHeader

The properties of the current task (@see TaskInfo).

N

nodeID - Variable in class NodeInfo

nodeID is a globally unique identifier

NodeInfo - class NodeInfo.

NodeInfo class contains information about a specific node.

NodeInfo(long, String, int) - Constructor for class NodeInfo

use this constructor when you create a NodeInfo object for the first time

NodeInfo(NodeInfo) - Constructor for class NodeInfo

use this constructor when you want to create a replica of another node

numOfExecutions - Variable in class TaskInfo

It is possible to execute the same task more than once, for correctness purposes.

numOfReplicas - Variable in class TaskInfo

How many times the same task has been replicated.

O

outputArgumentPosition - Variable in class DestinationRecord

outputDestination - Variable in class TaskHeader

Used by the system for results handling.

P

position - Variable in class Sequence

Position is the child Id in the task graph, and therefore can take values for 0 up to (range-1)

putBy - Variable in class TaskInfo

The node Id that created/forwarded the task the last time.

putResults(Result, NodeInfo) - Method in interface Consumer

This method is called by the CX environment, when new results have been arrived.

putTask(TaskHeader, NodeInfo) - Method in interface TaskServer

This method is called by the consumer the very first time it wants to submit a task to the CX environment.

R

range - Variable in class Sequence

Each task can spawn (create) up to a maximum number of new tasks, that is declared through the value of this field.

registerTask(String, String) - Method in interface TaskServer

Before submitting the task, you should call this method in order for the CX environment to get the class definition of the task to be submitted.

Result - class Result.

Result is the data structure which contains the returned result(s) of a task execution.

Result(Result) - Constructor for class Result

Use this constructor when you want to replicate a "result" object.

Result(TaskInfo, Sequence, long, Object) - Constructor for class Result

Use this constructor when you want to create a Result object form scratch

results - Variable in class Result

The actual results are stored here.

rmiRegistry - Variable in class NodeInfo

this is the RMI url for the "bind" operation.

S

Sequence - class Sequence.

Each task has a unique taskId, or task sequence number.

Sequence(long) - Constructor for class Sequence

Use this constructor when you want to create a new Sequence object.

Sequence(Sequence) - Constructor for class Sequence

setArgument(int, int) - Method in interface Task

setOutputDestination(int, TaskInfo, int) - Method in interface Task

setTaskInfo(TaskInfo) - Method in class CXTask

setTaskInfo(TaskInfo) - Method in interface Task

sizeOfOutput - Variable in class TaskHeader

The anticipated number of output arguments.

sizeOfOutputProduced - Variable in class TaskHeader

The number of output arguments already produced.

storeResults(Result) - Method in interface TaskContainer

We use this method when we want to return to the container application new results.

storeTask(Task) - Method in interface TaskContainer

We use this method when we want to return to the container application new tasks.

T

Task - interface Task.

This interface is implemented by the CXTask class, and mentioned here only for .

TaskContainer - interface TaskContainer.

Each task is getting executed within a container application, that can be a Producer, a TaskServer or both.

TaskHeader - class TaskHeader.

This data structure encapsulates the information that is common in all tasks, no matter what their functionality is.

TaskHeader(TaskHeader) - Constructor for class TaskHeader

Use this constructor when you want to replicate an existing TaskHeader object.

TaskHeader(TaskInfo, int, int, int, int, DestinationRecord[]) - Constructor for class TaskHeader

Use this constructor when you want to create a new TaskHeader object.

taskId - Variable in class TaskInfo

Each task has a unique Task Id, or sequence number, that gives its position in the task graph.

TaskInfo - class TaskInfo.

This structure constains the properties of the task, i.e.

TaskInfo(long, Sequence, Sequence, int, int, long, String, int, boolean, boolean) - Constructor for class TaskInfo

Use this constructor when you want to create a new object.

TaskInfo(TaskInfo) - Constructor for class TaskInfo

Use this constructor when you want to replicated an exisitng TaskInfo object.

taskOriginator - Variable in class TaskInfo

The RMI registry of the node that originally submitted the task.

taskOriginatorType - Variable in class TaskInfo

What kind of type (i.e.

TaskServer - interface TaskServer.

taskType - Variable in class TaskInfo

The task can be one of the following types: Ready to go, when all input arguments are present Waiting, when some input arguments are missing, and therefore the task cannot be executed New task, for new tasks Completed task, for task that have been already computed.

type - Variable in class NodeInfo

There are three available types:
CXConst.consumerNode, the corresponds to consumer nodes
CXConst.producerNode, that correponds to producer nodes
CXConst.taskServerNode, that corresponds to task server nodes These constants are defined in the CXConst.

A C D E G I J M N O P R S T