|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hama.bsp.GroomServerStatus
public class GroomServerStatus
A GroomServerStatus is a BSP primitive. Keeps info on a BSPMaster. The BSPMaster maintains a set of the most recent GroomServerStatus objects for each unique GroomServer it knows about.
Field Summary | |
---|---|
static org.apache.commons.logging.Log |
LOG
|
Constructor Summary | |
---|---|
GroomServerStatus()
|
|
GroomServerStatus(java.lang.String groomName,
java.lang.String peerName,
java.util.List<org.apache.hama.bsp.TaskStatus> taskReports,
int failures,
int maxTasks)
|
|
GroomServerStatus(java.lang.String groomName,
java.lang.String peerName,
java.util.List<org.apache.hama.bsp.TaskStatus> taskReports,
int failures,
int maxTasks,
java.lang.String rpc)
|
Method Summary | |
---|---|
int |
countTasks()
Return the current MapTask count |
boolean |
equals(java.lang.Object o)
|
int |
getFailures()
|
java.lang.String |
getGroomName()
|
long |
getLastSeen()
|
int |
getMaxTasks()
|
java.lang.String |
getPeerName()
The host (and port) from where the groom server can be reached. |
java.lang.String |
getRpcServer()
|
java.util.List<org.apache.hama.bsp.TaskStatus> |
getTaskReports()
Get the current tasks at the GroomServer. |
int |
hashCode()
For BSPMaster to distinguish between different GroomServers, because BSPMaster stores using GroomServerStatus as key. |
void |
readFields(java.io.DataInput in)
|
void |
setLastSeen(long lastSeen)
|
java.util.Iterator<org.apache.hama.bsp.TaskStatus> |
taskReports()
|
void |
write(java.io.DataOutput out)
|
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final org.apache.commons.logging.Log LOG
Constructor Detail |
---|
public GroomServerStatus()
public GroomServerStatus(java.lang.String groomName, java.lang.String peerName, java.util.List<org.apache.hama.bsp.TaskStatus> taskReports, int failures, int maxTasks)
public GroomServerStatus(java.lang.String groomName, java.lang.String peerName, java.util.List<org.apache.hama.bsp.TaskStatus> taskReports, int failures, int maxTasks, java.lang.String rpc)
Method Detail |
---|
public java.lang.String getGroomName()
public java.lang.String getPeerName()
public java.lang.String getRpcServer()
public java.util.List<org.apache.hama.bsp.TaskStatus> getTaskReports()
TaskStatus
object.
TaskStatus
representing the current tasks at the
GroomServer.public int getFailures()
public long getLastSeen()
public void setLastSeen(long lastSeen)
public int getMaxTasks()
public int countTasks()
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface org.apache.hadoop.io.Writable
java.io.IOException
public void write(java.io.DataOutput out) throws java.io.IOException
write
in interface org.apache.hadoop.io.Writable
java.io.IOException
public java.util.Iterator<org.apache.hama.bsp.TaskStatus> taskReports()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |