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, wait
endExecute
public 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)
ICompute
public void prepare(Config cfg, TaskContext context)
INode