com.graphdbapi.task.template

Class AbstractStandAloneTask<RESULT>

java.lang.Object

com.graphdbapi.task.template.AbstractStandAloneTask<RESULT>

All Implemented Interfaces:

ITask<RESULT>

public abstract class AbstractStandAloneTask<RESULT>
extends java.lang.Object
implements ITask<RESULT>

功能描述: AbstractStandAloneTask(AST) 为单机计算框架，主要方法为compute 功能: 1.AST框架为用户分开了整体流程 2.AST框架需要用户完成核心实现方法compute

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ExecutorService	executorService
protected java.util.List<java.util.concurrent.Future<?>>	futures
protected Graph	graph
protected LoggerUtil	graphLogger
protected IdsMap	idsMap
protected boolean	isStop
protected int	limit
protected int	partSize
protected TaskStage	stage
protected TaskHandler	taskHandler
protected long	taskId

Constructor Summary

Constructors

Constructor and Description
AbstractStandAloneTask(java.lang.String taskName, Graph graph, GraphLogger graphLogger)

Method Summary

Modifier and Type	Method and Description
void	checkStop() 检查是否停止，返回异常
abstract void	compute()
boolean	distributed() 是否为分布式任务.
Graph	getGraph() 获取图对象.
int	getLimit() 返回结果限制
LoggerUtil	getLogger() 获取计算框架写日志对象.
boolean	getStop() 获取计算框架停止值.
long	getTaskId() 获取任务号.
java.lang.String	getTaskName() 返回任务名.
TaskStage	getTaskStage() 获取任务状态.
abstract void	init() 任务初始化阶段.
boolean	isRunningOrThrow() 检查任务异常
protected void	parallelExecute(java.util.List<java.util.concurrent.Future<?>> futures) 获取并行执行的任务
abstract void	release() 释放内存对象.
abstract RESULT	result(int webLimit) 返回结果.
void	setStop() 设置算法任务停止

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

taskId

protected long taskId

stage

protected TaskStage stage

graph

protected Graph graph

graphLogger

protected final LoggerUtil graphLogger

taskHandler

protected final TaskHandler taskHandler

limit

protected int limit

futures

protected java.util.List<java.util.concurrent.Future<?>> futures

executorService

protected java.util.concurrent.ExecutorService executorService

partSize

protected final int partSize

isStop

protected boolean isStop

idsMap

protected final IdsMap idsMap

Constructor Detail

AbstractStandAloneTask

public AbstractStandAloneTask(java.lang.String taskName,
                              Graph graph,
                              GraphLogger graphLogger)

Method Detail

compute

public abstract void compute()
                      throws java.lang.Exception

Throws:

java.lang.Exception

result

public abstract RESULT result(int webLimit)

Description copied from interface: ITask

返回结果.

Specified by:

result in interface ITask<RESULT>

Parameters:

webLimit - 返回limit限制

Returns:

计算结果.

init

public abstract void init()

Description copied from interface: ITask

任务初始化阶段.

Specified by:

init in interface ITask<RESULT>

release

public abstract void release()

Description copied from interface: ITask

释放内存对象.

Specified by:

release in interface ITask<RESULT>

checkStop

public void checkStop()

检查是否停止，返回异常

getTaskName

public java.lang.String getTaskName()

Description copied from interface: ITask

返回任务名.

Specified by:

getTaskName in interface ITask<RESULT>

Returns:

任务名.

getTaskId

public long getTaskId()

Description copied from interface: ITask

获取任务号.

Specified by:

getTaskId in interface ITask<RESULT>

Returns:

任务号.

getStop

public boolean getStop()

Description copied from interface: ITask

获取计算框架停止值.

Specified by:

getStop in interface ITask<RESULT>

Returns:

计算框架停止值.

getTaskStage

public TaskStage getTaskStage()

Description copied from interface: ITask

获取任务状态.

Specified by:

getTaskStage in interface ITask<RESULT>

Returns:

任务状态.

distributed

public final boolean distributed()

Description copied from interface: ITask

是否为分布式任务.

Specified by:

distributed in interface ITask<RESULT>

Returns:

true: 分布式任务; false: 单机任务.

getGraph

public Graph getGraph()

Description copied from interface: ITask

获取图对象.

Specified by:

getGraph in interface ITask<RESULT>

Returns:

图对象.

getLogger

public LoggerUtil getLogger()

Description copied from interface: ITask

获取计算框架写日志对象.

Specified by:

getLogger in interface ITask<RESULT>

Returns:

日志对象.

parallelExecute

protected void parallelExecute(java.util.List<java.util.concurrent.Future<?>> futures)

获取并行执行的任务

Parameters:

futures - call任务集合

setStop

public final void setStop()

Description copied from interface: ITask

设置算法任务停止

Specified by:

setStop in interface ITask<RESULT>

isRunningOrThrow

public boolean isRunningOrThrow()

检查任务异常

Returns:

返回停止异常

getLimit

public final int getLimit()

返回结果限制

Returns:

结果输了上限