com.supermap.services.components

类 AbstractRuntimeJobState

java.lang.Object

com.supermap.services.components.commontypes.JobState

com.supermap.services.components.AbstractRuntimeJobState

直接已知子类:

CloudRuntimeJobState

public abstract class AbstractRuntimeJobState
extends JobState

运行时的切图作业状态信息类。职责包括
1，切图任务的拆分
2, 切图子节点任务完成或失败时，切图状态的自动更新
3, 子节点状态管理等。

从以下版本开始:

6.1.3

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	AbstractRuntimeJobState.DeployTaskResult 切图任务部署结果类。
static interface	AbstractRuntimeJobState.JobStateListener 任务状态监听类。

字段概要

字段

限定符和类型	字段和说明
protected java.util.concurrent.locks.ReentrantLock	changeStateLock
protected JobBuildConfig	config
protected JobState	currentState
protected AbstractRuntimeJobState.JobStateListener	listeners
protected boolean	stopped
protected TileRegionStateManager	tileRegionStateManager

从类继承的字段 com.supermap.services.components.commontypes.JobState

analystBlankPercentage, buildingScale, completed, completedBytes, completedScale, dataPreProcessBuildConfig, dataPreProcessState, deployedCompleted, deployedTotal, deployedWorkerInfo, deployingDataWorkerInfo, elapsedTime, masterAddress, noFeaturesTileCount, pureColorTileCount, remainTime, runState, scaleConfigs, scaleInfos, speedPerSecond, startTime, tasks, tasksToRetry, tileMatrixEdgeCount, total

构造器概要

构造器

构造器和说明
AbstractRuntimeJobState(JobState value) 构造函数。

方法概要

方法

限定符和类型	方法和说明
void	addListener(AbstractRuntimeJobState.JobStateListener listener) 添加一个监听器。
JobState	addUpdateTasks(TileTask[] updateTasks) 添加单元切图任务。
protected void	delTask(java.lang.String id)
AbstractRuntimeJobState.DeployTaskResult	deployTaskToWorker(TileWorkerClient worker) 向切图子节点部署单元切图任务。
java.util.List<TileTask>	getAllTasks() 获取单元切图任务列表。
protected TileScaleInfo	getInfoByScale(double scaleDenominator) 获取切图任务比例尺下的进度。
protected ScaleBuildConfig	getScaleBuildConfigByScale(double scaleDenominator)
JobState	getState() 获取当前所有任务状态。
abstract TileTask	getTask() 获取单元任务。
TileTask	getTaskById(java.lang.String id) 通过ID，获取的单元任务。
protected WorkerBuildingInfo[]	mergeWorkerBuildingInfos(WorkerBuildingInfo[] workerBuildingInfos, WorkerBuildingInfo workerInfo)
java.util.List<java.lang.String>	notifyLostConnectionPerhaps(java.util.Map<java.lang.String,TileTask> lostConnection) 获取执行单元切图任务时断开连接的workID。
JobState	notifyWorkerDisconnected(java.lang.String workerId) 切图子节点连接失败时，将单元切图任务标记为失败 。
void	setConfig(JobBuildConfig value) 设置切图任务配置信息。
void	setTileRegionStateManager(TileRegionStateManager tileRegionStateManager) 设置切图范围状态管理器。
JobState	start() 开始切图任务。
JobState	stop() 停止切图任务。
protected void	updatElapsedTime(JobState result)
void	updateProgress(java.util.Map<java.lang.String,java.lang.Long> progress) 更新切图进度。
JobState	updateTaskFailed(TileTask task) 将单元切图任务标记为失败。
abstract JobState	updateTaskToCompleted(TileTask task) 更新当前的状态，以反映task已经完成。
abstract JobState	updateTaskToCompleted(TileTask task, TileTaskBuildResult taskBuildResult, TileWorkerInfo tileWorkerInfo) 更新当前的状态，以反映task已经完成。

从类继承的方法 com.supermap.services.components.commontypes.JobState

equals, hashCode, setTileCountPerTask

从类继承的方法 java.lang.Object

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

字段详细资料

currentState

protected volatile JobState currentState

config

protected JobBuildConfig config

stopped

protected boolean stopped

changeStateLock

protected java.util.concurrent.locks.ReentrantLock changeStateLock

tileRegionStateManager

protected TileRegionStateManager tileRegionStateManager

listeners

protected AbstractRuntimeJobState.JobStateListener listeners

构造器详细资料

AbstractRuntimeJobState

public AbstractRuntimeJobState(JobState value)

构造函数。

参数:

value -

方法详细资料

getInfoByScale

protected TileScaleInfo getInfoByScale(double scaleDenominator)

获取切图任务比例尺下的进度。

参数:

scaleDenominator -

返回:

getState

public JobState getState()

获取当前所有任务状态。

返回:

getTaskById

public TileTask getTaskById(java.lang.String id)

通过ID，获取的单元任务。

参数:

id -

返回:

updateTaskToCompleted

public abstract JobState updateTaskToCompleted(TileTask task,
                             TileTaskBuildResult taskBuildResult,
                             TileWorkerInfo tileWorkerInfo)

更新当前的状态，以反映task已经完成。

参数:

task -

返回:

从以下版本开始:

6.1.3

updateTaskToCompleted

public abstract JobState updateTaskToCompleted(TileTask task)

更新当前的状态，以反映task已经完成。

参数:

task -

返回:

从以下版本开始:

6.1.3

updatElapsedTime

protected void updatElapsedTime(JobState result)

delTask

protected void delTask(java.lang.String id)

getTask

public abstract TileTask getTask()

获取单元任务。

参数:

id -

返回:

getScaleBuildConfigByScale

protected ScaleBuildConfig getScaleBuildConfigByScale(double scaleDenominator)

deployTaskToWorker

public AbstractRuntimeJobState.DeployTaskResult deployTaskToWorker(TileWorkerClient worker)

向切图子节点部署单元切图任务。

参数:

worker -

返回:

setConfig

public void setConfig(JobBuildConfig value)

设置切图任务配置信息。

参数:

value -

updateTaskFailed

public JobState updateTaskFailed(TileTask task)

将单元切图任务标记为失败。

参数:

task -

返回:

stop

public JobState stop()

停止切图任务。

返回:

start

public JobState start()

开始切图任务。

返回:

notifyWorkerDisconnected

public JobState notifyWorkerDisconnected(java.lang.String workerId)

切图子节点连接失败时，将单元切图任务标记为失败 。

参数:

workerId -

返回:

getAllTasks

public java.util.List<TileTask> getAllTasks()

获取单元切图任务列表。

返回:

updateProgress

public void updateProgress(java.util.Map<java.lang.String,java.lang.Long> progress)

更新切图进度。

参数:

progress -

notifyLostConnectionPerhaps

public java.util.List<java.lang.String> notifyLostConnectionPerhaps(java.util.Map<java.lang.String,TileTask> lostConnection)

获取执行单元切图任务时断开连接的workID。

参数:

lostConnection -

返回:

addListener

public void addListener(AbstractRuntimeJobState.JobStateListener listener)

添加一个监听器。

参数:

listener -

addUpdateTasks

public JobState addUpdateTasks(TileTask[] updateTasks)

添加单元切图任务。

参数:

updateTasks -

返回:

mergeWorkerBuildingInfos

protected WorkerBuildingInfo[] mergeWorkerBuildingInfos(WorkerBuildingInfo[] workerBuildingInfos,
                                            WorkerBuildingInfo workerInfo)

setTileRegionStateManager

public void setTileRegionStateManager(TileRegionStateManager tileRegionStateManager)

设置切图范围状态管理器。

参数:

tileRegionStateManager -