public class DataObjectCompute extends BaseCompute
| Constructor and Description |
|---|
DataObjectCompute(java.lang.String edgename,
int size) |
DataObjectCompute(java.lang.String edgename,
int dsize,
int parallel) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
execute(IMessage message)
Execute with an incoming message
|
int |
getDatasize() |
java.lang.String |
getEdgeName() |
int |
getParallel() |
void |
prepare(Config cfg,
TaskContext context)
Prepare the task to be executed
|
void |
setDatasize(int datasize) |
void |
setEdgeName(java.lang.String edgeName) |
void |
setParallel(int parallel) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitendExecutepublic DataObjectCompute(java.lang.String edgename,
int dsize,
int parallel)
public DataObjectCompute(java.lang.String edgename,
int size)
public int getDatasize()
public void setDatasize(int datasize)
public int getParallel()
public void setParallel(int parallel)
public java.lang.String getEdgeName()
public void setEdgeName(java.lang.String edgeName)
public boolean execute(IMessage message)
IComputepublic void prepare(Config cfg, TaskContext context)
INode