Serialized Form

Package com.cliftonsnyder.clutch

Class com.cliftonsnyder.clutch.Agent extends java.lang.Object implements Serializable

Serialized Fields

agentState

Agent.State agentState

a variable representing the current state of the Agent

ancestorList

java.util.List<E> ancestorList

a list of all of the ancestors of the Agent (i.e., a List of all Agents in the path from this Agent to the "root" Agent)

children

java.util.List<E> children

a List of the children of the Agent

id

java.lang.String id

an identifier for the Agent

level

int level

an integer to be used for tracking the position of the Agent

maxPeers

int maxPeers

the maximum number of peers that the Agent will be allowed

parent

Agent parent

the parent of the Agent

state

ClutchState state

contains state information about the Agent

Package com.cliftonsnyder.clutch.mr

Class com.cliftonsnyder.clutch.mr.Mapper extends Agent implements Serializable

serialVersionUID: 2491900754983849594L

Serialized Fields

currentChild

int currentChild

input

MapTaskFactory input

newAgent

boolean newAgent

newReducers

java.util.List<E> newReducers

reducer

Reducer reducer

tasksCompleted

int tasksCompleted

Class com.cliftonsnyder.clutch.mr.Reducer extends Agent implements Serializable

serialVersionUID: -5317284619705144557L

Serialized Fields

currentChild

int currentChild

mapper

Mapper mapper

newAgent

boolean newAgent

newMappers

java.util.List<E> newMappers

tasks

java.util.List<E> tasks

tasksCompleted

int tasksCompleted

Package com.cliftonsnyder.clutch.mr.task

Class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory extends java.lang.Object implements Serializable

Serialized Fields

state

ClutchState state

requests

java.util.Hashtable<K,V> requests

Class com.cliftonsnyder.clutch.mr.task.MapTask extends MRTask implements Serializable

Class com.cliftonsnyder.clutch.mr.task.MRTask extends Task implements Serializable

Serialized Fields

keyValuePairs

java.util.List<E> keyValuePairs

Class com.cliftonsnyder.clutch.mr.task.ReduceTask extends MRTask implements Serializable

Package com.cliftonsnyder.clutch.task

Class com.cliftonsnyder.clutch.task.Task extends java.lang.Object implements Serializable

Serialized Fields

lengthOffsetPairs

java.util.List<E> lengthOffsetPairs

totalLength

java.lang.Long totalLength

Class com.cliftonsnyder.clutch.task.WaitTask extends Task implements Serializable

serialVersionUID: 599135966497860029L

Package com.cliftonsnyder.clutch.util

Class com.cliftonsnyder.clutch.util.ClutchState extends java.lang.Object implements Serializable

serialVersionUID: 3206581138407918907L

Serialized Fields

agentCount

int agentCount

the number of agents that should be created

agentNode

Node agentNode

the ProActive node that will hold all of the Clutch Agents

dataNode

Node dataNode

the ProActive node that will hold all of the Clutch Agents

agentNodeName

java.lang.String agentNodeName

the name for the ProActive Node that will hold all of the Clutch Agents

dataNodeName

java.lang.String dataNodeName

the name for the ProActive Node that will hold all of the Clutch Agents

fullAgentNodeName

java.lang.String fullAgentNodeName

the full name of the ProActive Node that will hold all of the Clutch Agents (including hostname, port, etc.)

fullDataNodeName

java.lang.String fullDataNodeName

the full name of the ProActive Node that will hold all of the Clutch Agents (including hostname, port, etc.)

hostname

java.lang.String hostname

the hostname of the RMI registry in which the Clutch Agents are registered

maxPeers

int maxPeers

the maximum number of peers that will be allowed for each Clutch Agent

nodeNames

java.util.List<E> nodeNames

a list of the names of the bootstrap nodes

port

int port

the RMI port to use (10001)

props

java.util.Properties props

the Properties read from the Clutch configuration file

Package com.cliftonsnyder.test

Class com.cliftonsnyder.test.FutureMonitoringTest extends java.lang.Object implements Serializable

serialVersionUID: -5261400224131783L

Package com.cliftonsnyder.util

Class com.cliftonsnyder.util.Pair extends java.lang.Object implements Serializable

serialVersionUID: 4545813334522773880L

Serialized Fields

key

java.lang.Comparable<T> key

the key-value pair's key

value

java.lang.Object value

the key-value pair's value