| Package | Description |
|---|---|
| beehive.worker | |
| beehive.workpool |
| Modifier and Type | Field and Description |
|---|---|
java.util.HashSet<Task> |
Worker.tasksCreated |
| Modifier and Type | Method and Description |
|---|---|
void |
Worker.commitTask(Task t) |
void |
Worker.doTask(Task tsk) |
boolean |
Worker.earlyValidation(Task t,
java.util.Vector<Node> readNodes,
java.util.Vector<NodeData> readNodesData) |
| Modifier and Type | Field and Description |
|---|---|
Task |
WorkStatus.task |
| Modifier and Type | Field and Description |
|---|---|
java.util.Vector<Task> |
WorkStatus.taskList |
| Modifier and Type | Method and Description |
|---|---|
java.util.Vector<Task> |
GlobalWorkpoolImpl.buildLocalityTaskBatch(java.lang.String hostname) |
java.util.Vector<Task> |
GlobalWorkpoolImpl.buildTaskBatch(java.lang.String hostname) |
| Modifier and Type | Method and Description |
|---|---|
void |
GlobalWorkpoolImpl.addTask(Task t) |
void |
LocalWorkpoolImpl.addTask(Task t) |
void |
WorkpoolServer.addTask(Task t) |
void |
LocalWorkpoolImpl.broadcast(Task t) |
void |
LocalWorkpoolImpl.depositTask(Task t) |
void |
LocalWorkpoolImpl.removeTask(Task t) |
long |
GlobalWorkpoolImpl.reportCompletion(Task t,
java.util.HashSet<Task> tasksCreated) |
void |
LocalWorkpoolImpl.reportCompletion(Task t,
java.util.HashSet<Task> tasksCreated) |
long |
WorkpoolServer.reportCompletion(Task t,
java.util.HashSet<Task> tasksCreated) |
ValidateResponse |
LocalWorkpoolImpl.validate(Task t,
RWSetInfo rwSetInfo) |
| Modifier and Type | Method and Description |
|---|---|
void |
LocalWorkpoolImpl.addTask(java.util.Vector<Task> taskVector) |
LoadInfo |
LocalWorkpoolServer.depositTasks(java.util.Vector<Task> t) |
LoadInfo |
LocalWorkpoolImpl.depositTasks(java.util.Vector<Task> taskList) |
void |
LoadDistributor.distributeTasks(java.util.Vector<Task> tasksCreated) |
long |
GlobalWorkpoolImpl.reportCompletion(Task t,
java.util.HashSet<Task> tasksCreated) |
void |
LocalWorkpoolImpl.reportCompletion(Task t,
java.util.HashSet<Task> tasksCreated) |
long |
WorkpoolServer.reportCompletion(Task t,
java.util.HashSet<Task> tasksCreated) |
| Constructor and Description |
|---|
WorkStatus(Task t) |
| Constructor and Description |
|---|
WorkStatus(java.util.Vector<Task> taskList) |