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
-
-
-
-
字段详细资料
-
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
-
-
-