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