public interface ITask<RESULT>
Modifier and Type | Method and Description |
---|---|
boolean |
distributed()
是否为分布式任务.
|
Graph |
getGraph()
获取图对象.
|
LoggerUtil |
getLogger()
获取计算框架写日志对象.
|
boolean |
getStop()
获取计算框架停止值.
|
long |
getTaskId()
获取任务号.
|
java.lang.String |
getTaskName()
返回任务名.
|
TaskStage |
getTaskStage()
获取任务状态.
|
void |
init()
任务初始化阶段.
|
void |
release()
释放内存对象.
|
RESULT |
result(int limit)
返回结果.
|
void |
setStop()
设置算法任务停止
|
void init()
RESULT result(int limit)
limit
- 返回limit限制void release()
java.lang.String getTaskName()
long getTaskId()
void setStop()
boolean getStop()
TaskStage getTaskStage()
boolean distributed()
Graph getGraph()
LoggerUtil getLogger()