com.supermap.services.components
接口 JobRunner
-
- 所有已知实现类:
- CloudJobRunner, DefaultJobRunner
public interface JobRunner
切图任务容器,用于运行一个分布式切图任务。
-
-
方法概要
方法 限定符和类型 方法和说明 void
addListener(JobRunnerListener listener)
添加监听器。void
addWorkers(java.util.List<TileWorkerClient> workers)
添加切图节点。void
confirmBlankRegionInfos(java.lang.String id)
确认白图范围。void
deployJobToWorker(TileWorkerClient client)
分配切图任务给子节点。BlankTileInfo
getBlankTileInfos(double scale, int fromIndex, int toIndex)
获取白图信息。JobBuildConfig
getJobConfig()
获取任务配置信息。JobState
getState()
获取Job状态。TilesetDesc
getTilesetDesc()
获取任务的目标信息.void
init(JobBuildConfig config, JobState state, JobDataDeploy dataDeploy)
对Runner进行初始化void
notifyJobDeployCompleted(java.lang.String workerId)
通知切图主节点,切图作业在切图节点部署完毕void
notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId)
通知切图主节点,某个单元切图任务完成。void
notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId, TileTaskBuildResult result)
通知切图主节点,某个单元切图任务完成。void
notifyTaskFailed(java.lang.String taskId, java.lang.String workerId)
通知切图主节点,某个单元切图任务失败。void
notifyWorkerDisconnected(java.lang.String workerId)
通知切图主节点,某个子节点连接失败。void
setTileCountPerTask(long value)
设置每个单元切图任务分配的瓦片数。void
setTileRegionManager(TileRegionStateManager tileRegionStateManager)
设置切片区域管理器。void
start()
开始任务。void
stop()
停止任务。void
updateBlankRegions(double scale, java.lang.String[] invalidRegionIds, java.lang.String[] validRegionIds, java.lang.String[] noneMarkedRegionIds, boolean markAllInvalid, boolean markAllValid)
更新白图范围。void
updateJobConfig(JobBuildConfig config)
更新任务配置void
updateTileJob(Tile[] tiles)
更新切图任务。
-
-
-
方法详细资料
-
getJobConfig
JobBuildConfig getJobConfig()
获取任务配置信息。
- 返回:
- 从以下版本开始:
- 8.1.1
-
init
void init(JobBuildConfig config, JobState state, JobDataDeploy dataDeploy)
对Runner进行初始化- 参数:
config
-state
- 可以为null
-
start
void start()
开始任务。
- 从以下版本开始:
- 8.1.1
-
stop
void stop()
停止任务。
- 从以下版本开始:
- 8.1.1
-
addWorkers
void addWorkers(java.util.List<TileWorkerClient> workers)
添加切图节点。
- 参数:
workers
-- 从以下版本开始:
- 8.1.1
-
getState
JobState getState()
获取Job状态。 返回的状态并不是实时的,但是是有效的。 Job执行的过程中,Job的状态可能会被并发的被修改。 当调用这个方法的时候,如果有其它线程正在修改Job的状态,即修改Job所属JobState对象的字段, 这个方法不会与修改的线程同步,所以它返回的状态不是实时的。 但是返回的状态肯定是某次修改完成后的状态,而不是并发修改中的状态(修改中的状态可能是无效非法的),所以返回的状态是有效的。- 返回:
-
getTilesetDesc
TilesetDesc getTilesetDesc()
获取任务的目标信息.- 返回:
-
setTileCountPerTask
void setTileCountPerTask(long value)
设置每个单元切图任务分配的瓦片数。关于单元切图任务,请参见
TileTask
.- 参数:
value
- 瓦片数。
-
notifyJobDeployCompleted
void notifyJobDeployCompleted(java.lang.String workerId)
通知切图主节点,切图作业在切图节点部署完毕
- 参数:
jobId
-workerId
-- 从以下版本开始:
- 7.1.1
-
notifyTaskCompleted
void notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId)
通知切图主节点,某个单元切图任务完成。
- 参数:
taskId
- 已完成的单元切图任务ID。workerId
- taskId单元切图任务所在的Woker。
-
notifyTaskFailed
void notifyTaskFailed(java.lang.String taskId, java.lang.String workerId)
通知切图主节点,某个单元切图任务失败。
- 参数:
taskId
-workerId
-- 从以下版本开始:
- 8.1.1
-
notifyWorkerDisconnected
void notifyWorkerDisconnected(java.lang.String workerId)
通知切图主节点,某个子节点连接失败。
- 参数:
workerId
-- 从以下版本开始:
- 8.1.1
-
addListener
void addListener(JobRunnerListener listener)
添加监听器。
- 参数:
listener
-- 从以下版本开始:
- 8.1.1
-
notifyTaskCompleted
void notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId, TileTaskBuildResult result)
通知切图主节点,某个单元切图任务完成。
- 参数:
taskId
-workerId
-result
-- 从以下版本开始:
- 8.1.1
-
deployJobToWorker
void deployJobToWorker(TileWorkerClient client)
分配切图任务给子节点。
- 参数:
client
-- 从以下版本开始:
- 8.1.1
-
updateTileJob
void updateTileJob(Tile[] tiles)
更新切图任务。
- 参数:
tiles
-- 从以下版本开始:
- 8.1.1
-
getBlankTileInfos
BlankTileInfo getBlankTileInfos(double scale, int fromIndex, int toIndex)
获取白图信息。
- 参数:
scale
-fromIndex
-toIndex
-- 返回:
- 从以下版本开始:
- 8.1.1
-
confirmBlankRegionInfos
void confirmBlankRegionInfos(java.lang.String id)
确认白图范围。
- 参数:
id
-- 从以下版本开始:
- 8.1.1
-
updateBlankRegions
void updateBlankRegions(double scale, java.lang.String[] invalidRegionIds, java.lang.String[] validRegionIds, java.lang.String[] noneMarkedRegionIds, boolean markAllInvalid, boolean markAllValid)
更新白图范围。
- 参数:
scale
-invalidRegionIds
-validRegionIds
-noneMarkedRegionIds
-markAllInvalid
-markAllValid
-- 从以下版本开始:
- 8.1.1
-
setTileRegionManager
void setTileRegionManager(TileRegionStateManager tileRegionStateManager)
设置切片区域管理器。
- 参数:
tileRegionStateManager
-- 从以下版本开始:
- 8.1.1
-
updateJobConfig
void updateJobConfig(JobBuildConfig config)
更新任务配置- 参数:
config
-
-
-