A C D F G H I K L M N P R S T V W

A

AbstractMapTaskFactory - Class in com.cliftonsnyder.clutch.mr.task

An abstraction that handles the "messy" business of migrating MapTasks

AbstractMapTaskFactory() - Constructor for class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

addAgent(Agent) - Method in class com.cliftonsnyder.clutch.util.AgentWatcher

addChild(Agent) - Method in class com.cliftonsnyder.clutch.Agent

adds a child to the list of this Agent's children

addKeyValuePair(Pair<Comparable, Object>) - Method in class com.cliftonsnyder.clutch.mr.task.MRTask

addLengthOffsetPair(Pair<Long, Long>) - Method in class com.cliftonsnyder.clutch.task.Task

addLengthOffsetPair(Pair<Long, Long>) - Method in class com.cliftonsnyder.clutch.task.WaitTask

addNewMapper(Mapper) - Method in class com.cliftonsnyder.clutch.mr.Reducer

addNewReducer(Reducer) - Method in class com.cliftonsnyder.clutch.mr.Mapper

Agent - Class in com.cliftonsnyder.clutch

A mobile agent Object that will provide the basis for a Clutch network

Agent() - Constructor for class com.cliftonsnyder.clutch.Agent

an empty, parameterless constructor; this is necessary if this class is going to "play nice" with ProActive

Agent(ClutchState) - Constructor for class com.cliftonsnyder.clutch.Agent

constructs a new Agent object, with maxPeers maximum peers

Agent.State - Enum in com.cliftonsnyder.clutch

agentState - Variable in class com.cliftonsnyder.clutch.Agent

a variable representing the current state of the Agent

AgentWatcher - Class in com.cliftonsnyder.clutch.util

A helper class that starts Agents and then watches to see if they've completed execution or have lost their connections, restarting them in the latter case.

AgentWatcher(ClutchState) - Constructor for class com.cliftonsnyder.clutch.util.AgentWatcher

ancestorList - Variable in class com.cliftonsnyder.clutch.Agent

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)

C

children - Variable in class com.cliftonsnyder.clutch.Agent

a List of the children of the Agent

ClutchState - Class in com.cliftonsnyder.clutch.util

A helper class that maintains all of the local state and configuration information for Clutch.

ClutchState(String) - Constructor for class com.cliftonsnyder.clutch.util.ClutchState

constructor for the ClutchState object

com.cliftonsnyder.clutch - package com.cliftonsnyder.clutch

com.cliftonsnyder.clutch.mr - package com.cliftonsnyder.clutch.mr

com.cliftonsnyder.clutch.mr.task - package com.cliftonsnyder.clutch.mr.task

com.cliftonsnyder.clutch.task - package com.cliftonsnyder.clutch.task

com.cliftonsnyder.clutch.util - package com.cliftonsnyder.clutch.util

com.cliftonsnyder.test - package com.cliftonsnyder.test

com.cliftonsnyder.util - package com.cliftonsnyder.util

com.cliftonsnyder.util.test - package com.cliftonsnyder.util.test

compareTo(Object) - Method in class com.cliftonsnyder.util.Pair

completionPercentage() - Method in class com.cliftonsnyder.clutch.task.Task

createAgent(Node, Node) - Method in class com.cliftonsnyder.clutch.Agent

method to be implemented by subclasses of Agent; this is where the interesting organization of a Clutch network will take place

createAgent(Node, Node) - Method in class com.cliftonsnyder.clutch.mr.Mapper

createAgent(Node, Node) - Method in class com.cliftonsnyder.clutch.mr.Reducer

createMapTask(long, long) - Method in class com.cliftonsnyder.clutch.mr.Mapper

createMapTask() - Method in interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

createMapTask(long, long) - Method in interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

D

DEFAULT_AGENT_COUNT - Static variable in class com.cliftonsnyder.clutch.util.ClutchState

the default number of agents that should be created

DEFAULT_AGENTNODE_NAME - Static variable in class com.cliftonsnyder.clutch.util.ClutchState

the default name for the ProActive Node that will hold all of the Clutch Agents ("agentNode")

DEFAULT_DATANODE_NAME - Static variable in class com.cliftonsnyder.clutch.util.ClutchState

DEFAULT_MAXPEERS - Static variable in class com.cliftonsnyder.clutch.util.ClutchState

the default value for maxPeers (2)

DEFAULT_PORT - Static variable in class com.cliftonsnyder.clutch.util.ClutchState

the default RMI port to use (10001)

dump(PrintStream) - Method in class com.cliftonsnyder.clutch.util.ClutchState

F

FutureMonitoringTest - Class in com.cliftonsnyder.test

FutureMonitoringTest() - Constructor for class com.cliftonsnyder.test.FutureMonitoringTest

G

getAgentCount() - Method in class com.cliftonsnyder.clutch.util.ClutchState

getAgentNode() - Method in class com.cliftonsnyder.clutch.util.ClutchState

getAgentState() - Method in class com.cliftonsnyder.clutch.Agent

getAncestorList() - Method in class com.cliftonsnyder.clutch.Agent

getChildren() - Method in class com.cliftonsnyder.clutch.Agent

getter for the children of this Agent

getDataNode() - Method in class com.cliftonsnyder.clutch.util.ClutchState

getHostName() - Method in class com.cliftonsnyder.clutch.Agent

retrieves the hostname of the Agent

getID() - Method in class com.cliftonsnyder.clutch.Agent

gets the ID of the Agent

getKey() - Method in class com.cliftonsnyder.util.Pair

getKeyValuePairs() - Method in class com.cliftonsnyder.clutch.mr.task.MRTask

getLength() - Method in class com.cliftonsnyder.clutch.task.Task

getLengthOffsetPairs() - Method in class com.cliftonsnyder.clutch.task.Task

getLengthOffsetPairs() - Method in class com.cliftonsnyder.clutch.task.WaitTask

getLevel() - Method in class com.cliftonsnyder.clutch.Agent

gets the position of the Agent wrt the other Agents in the system

getMapTask(long, long) - Method in class com.cliftonsnyder.clutch.mr.Mapper

getMapTask(String) - Method in class com.cliftonsnyder.clutch.mr.Mapper

getMapTask(String) - Method in class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

getMapTask(String, long, long) - Method in class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

getMapTask(String) - Method in interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

getMapTask(String, long, long) - Method in interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

getMaxPeers() - Method in class com.cliftonsnyder.clutch.util.ClutchState

getMissingLengthOffsetPairs() - Method in class com.cliftonsnyder.clutch.task.Task

getParent() - Method in class com.cliftonsnyder.clutch.Agent

getter for this Agent's parent

getProperty(String) - Method in class com.cliftonsnyder.clutch.util.ClutchState

a catchall for the properties in the configuration file for which an explicit getter does not exist

getReduceTask(long, long) - Method in class com.cliftonsnyder.clutch.mr.Mapper

getRef() - Method in class com.cliftonsnyder.clutch.Agent

gets a reference to the Agent; this method is needed when programming with ProActive, as it may be necessary to return a reference to a remote stub (as opposed to a pointed to this)

getRemoteAgent(String) - Method in class com.cliftonsnyder.clutch.util.ClutchState

getRemoteAgent() - Method in class com.cliftonsnyder.clutch.util.ClutchState

getRemoteAgentFromHost(String, String) - Method in class com.cliftonsnyder.clutch.util.ClutchState

retrieves a remote Agent from one of the bootstrap locations specified in the configuration file

getResult() - Method in class com.cliftonsnyder.clutch.task.WaitTask

getTotalLength() - Method in class com.cliftonsnyder.clutch.task.Task

getTotalLength() - Method in class com.cliftonsnyder.clutch.task.WaitTask

getValue() - Method in class com.cliftonsnyder.util.Pair

H

hasMapper() - Method in class com.cliftonsnyder.clutch.mr.Reducer

hasReducer() - Method in class com.cliftonsnyder.clutch.mr.Mapper

I

id - Variable in class com.cliftonsnyder.clutch.Agent

an identifier for the Agent

init() - Method in class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

init() - Method in interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

isNew() - Method in class com.cliftonsnyder.clutch.Agent

determines whether or not the Agent is newly created or is a current member of a Clutch network

isNew() - Method in class com.cliftonsnyder.clutch.mr.Mapper

isNew() - Method in class com.cliftonsnyder.clutch.mr.Reducer

isRoot() - Method in class com.cliftonsnyder.clutch.Agent

isWait() - Method in class com.cliftonsnyder.clutch.mr.task.ReduceTask

K

keyValuePairs - Variable in class com.cliftonsnyder.clutch.mr.task.MRTask

L

level - Variable in class com.cliftonsnyder.clutch.Agent

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

M

main(String[]) - Static method in class com.cliftonsnyder.clutch.Agent

usage: java [jvm args] com.cliftonsnyder.clutch.Agent [config file]

main(String[]) - Static method in class com.cliftonsnyder.clutch.mr.Mapper

main(String[]) - Static method in class com.cliftonsnyder.clutch.mr.Reducer

main(String[]) - Static method in class com.cliftonsnyder.clutch.util.ClutchState

main(String[]) - Static method in class com.cliftonsnyder.test.FutureMonitoringTest

main(String[]) - Static method in class com.cliftonsnyder.util.test.PairTest

map() - Method in class com.cliftonsnyder.clutch.mr.task.MapTask

Mapper - Class in com.cliftonsnyder.clutch.mr

a mobile agent representing a mapper

Mapper() - Constructor for class com.cliftonsnyder.clutch.mr.Mapper

an empty, parameterless constructor; this is necessary if the Mapper object is to "play nice" with ProActive

Mapper(ClutchState) - Constructor for class com.cliftonsnyder.clutch.mr.Mapper

constructs a new Mapper object, with maxPeers maximum peers

MapTask - Class in com.cliftonsnyder.clutch.mr.task

An abstraction for the tasks that Mappers will perform

MapTask() - Constructor for class com.cliftonsnyder.clutch.mr.task.MapTask

MapTaskFactory - Interface in com.cliftonsnyder.clutch.mr.task

An interface representing things that create MapTasks

maxPeers - Variable in class com.cliftonsnyder.clutch.Agent

the maximum number of peers that the Agent will be allowed

merge(Task) - Method in class com.cliftonsnyder.clutch.mr.task.MRTask

merge(Task) - Method in class com.cliftonsnyder.clutch.task.Task

merge(Task) - Method in class com.cliftonsnyder.clutch.task.WaitTask

mergeLengthOffsetPairs(Task) - Method in class com.cliftonsnyder.clutch.task.Task

MRTask - Class in com.cliftonsnyder.clutch.mr.task

An abstraction for MapReduce-specific tasks (MapTask, ReduceTask)

MRTask() - Constructor for class com.cliftonsnyder.clutch.mr.task.MRTask

N

newAgent - Variable in class com.cliftonsnyder.clutch.mr.Mapper

newAgent - Variable in class com.cliftonsnyder.clutch.mr.Reducer

P

Pair<K extends java.lang.Comparable,V> - Class in com.cliftonsnyder.util

A simple generic class for handling key-value pairs

Pair() - Constructor for class com.cliftonsnyder.util.Pair

an empty, parameterless constructor; this is necessary if this class is going to "play nice" with ProActive

Pair(K, V) - Constructor for class com.cliftonsnyder.util.Pair

Creates a key-value pair

PairTest - Class in com.cliftonsnyder.util.test

A simple test class for the generic class Pair

PairTest() - Constructor for class com.cliftonsnyder.util.test.PairTest

parent - Variable in class com.cliftonsnyder.clutch.Agent

the parent of the Agent

putMapTask(MapTask) - Method in class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

putMapTask(MapTask) - Method in interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

putReduceTask(ReduceTask) - Method in class com.cliftonsnyder.clutch.mr.Reducer

R

reduce() - Method in class com.cliftonsnyder.clutch.mr.task.ReduceTask

Reducer - Class in com.cliftonsnyder.clutch.mr

a mobile agent representing a reducer

Reducer() - Constructor for class com.cliftonsnyder.clutch.mr.Reducer

an empty, parameterless constructor; this is necessary if the Reducer object is to "play nice" with ProActive

Reducer(ClutchState) - Constructor for class com.cliftonsnyder.clutch.mr.Reducer

constructs a new Reducer object, with maxPeers maximum peers

ReduceTask - Class in com.cliftonsnyder.clutch.mr.task

An abstraction for the tasks that Reducers will perform

ReduceTask() - Constructor for class com.cliftonsnyder.clutch.mr.task.ReduceTask

removeChild(String) - Method in class com.cliftonsnyder.clutch.Agent

removes a child from this Agent's List of children

removeChild(int) - Method in class com.cliftonsnyder.clutch.Agent

run() - Method in class com.cliftonsnyder.clutch.mr.Mapper

run() - Method in class com.cliftonsnyder.clutch.mr.Reducer

run() - Method in class com.cliftonsnyder.clutch.util.AgentWatcher

S

setAgentState(Agent.State) - Method in class com.cliftonsnyder.clutch.Agent

setAncestorList(List<Agent>) - Method in class com.cliftonsnyder.clutch.Agent

setID(String) - Method in class com.cliftonsnyder.clutch.Agent

setter for the Agent's id

setInputFactory(MapTaskFactory) - Method in class com.cliftonsnyder.clutch.mr.Mapper

setKey(K) - Method in class com.cliftonsnyder.util.Pair

setKeyValuePairs(List<Pair<Comparable, Object>>) - Method in class com.cliftonsnyder.clutch.mr.task.MRTask

setLengthOffsetPairs(List<Pair<Long, Long>>) - Method in class com.cliftonsnyder.clutch.task.Task

setLengthOffsetPairs(List<Pair<Long, Long>>) - Method in class com.cliftonsnyder.clutch.task.WaitTask

setLevel(int) - Method in class com.cliftonsnyder.clutch.Agent

setter for the Agent's level

setMapper(Mapper) - Method in class com.cliftonsnyder.clutch.mr.Reducer

setMaxPeers(int) - Method in class com.cliftonsnyder.clutch.Agent

sets the maximum number of peers that an Agent is allowed to have

setNew(boolean) - Method in class com.cliftonsnyder.clutch.mr.Mapper

setNew(boolean) - Method in class com.cliftonsnyder.clutch.mr.Reducer

setParent(Agent) - Method in class com.cliftonsnyder.clutch.Agent

setter for the Agent's parent

setReducer(Reducer) - Method in class com.cliftonsnyder.clutch.mr.Mapper

setState(ClutchState) - Method in class com.cliftonsnyder.clutch.Agent

sets the state information for the Agent

setState(ClutchState) - Method in class com.cliftonsnyder.clutch.mr.Mapper

setState(ClutchState) - Method in class com.cliftonsnyder.clutch.mr.Reducer

setState(ClutchState) - Method in class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

setState(ClutchState) - Method in interface com.cliftonsnyder.clutch.mr.task.MapTaskFactory

setTotalLength(long) - Method in class com.cliftonsnyder.clutch.task.Task

setTotalLength(long) - Method in class com.cliftonsnyder.clutch.task.WaitTask

setValue(V) - Method in class com.cliftonsnyder.util.Pair

shutdown() - Method in class com.cliftonsnyder.clutch.Agent

shut down the Agent

shutdown() - Method in class com.cliftonsnyder.clutch.mr.Mapper

shutdown() - Method in class com.cliftonsnyder.clutch.mr.Reducer

state - Variable in class com.cliftonsnyder.clutch.Agent

contains state information about the Agent

state - Variable in class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

status() - Method in class com.cliftonsnyder.clutch.Agent

gives a String representation of the current status of the Agent

status() - Method in class com.cliftonsnyder.clutch.mr.Mapper

status() - Method in class com.cliftonsnyder.clutch.mr.Reducer

T

Task - Class in com.cliftonsnyder.clutch.task

An abstraction for the tasks that Clutch Agents will perform

Task() - Constructor for class com.cliftonsnyder.clutch.task.Task

test(int) - Method in class com.cliftonsnyder.clutch.mr.Mapper

test() - Method in class com.cliftonsnyder.test.FutureMonitoringTest

toString() - Method in class com.cliftonsnyder.clutch.Agent

toString() - Method in class com.cliftonsnyder.clutch.mr.Reducer

toString() - Method in class com.cliftonsnyder.clutch.mr.task.AbstractMapTaskFactory

toString() - Method in class com.cliftonsnyder.util.Pair

V

valueOf(String) - Static method in enum com.cliftonsnyder.clutch.Agent.State

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.cliftonsnyder.clutch.Agent.State

Returns an array containing the constants of this enum type, in the order they are declared.

W

WaitTask - Class in com.cliftonsnyder.clutch.task

A "special" Task which signifies that the Agent still has data to process, but doesn't currently have any new tasks to give

WaitTask() - Constructor for class com.cliftonsnyder.clutch.task.WaitTask

A C D F G H I K L M N P R S T V W