com.supermap.services.components
接口 JobRunner
-
- 所有已知实现类:
- CloudJobRunner, DefaultJobRunner
public interface JobRunner切图任务容器,用于运行一个分布式切图任务。
-
-
方法概要
方法 限定符和类型 方法和说明 voidaddListener(JobRunnerListener listener)添加监听器。voidaddWorkers(java.util.List<TileWorkerClient> workers)添加切图节点。voidconfirmBlankRegionInfos(java.lang.String id)确认白图范围。voiddeployJobToWorker(TileWorkerClient client)分配切图任务给子节点。BlankTileInfogetBlankTileInfos(double scale, int fromIndex, int toIndex)获取白图信息。JobBuildConfiggetJobConfig()获取任务配置信息。JobStategetState()获取Job状态。TilesetDescgetTilesetDesc()获取任务的目标信息.voidinit(JobBuildConfig config, JobState state, JobDataDeploy dataDeploy)对Runner进行初始化voidnotifyJobDeployCompleted(java.lang.String workerId)通知切图主节点,切图作业在切图节点部署完毕voidnotifyTaskCompleted(java.lang.String taskId, java.lang.String workerId)通知切图主节点,某个单元切图任务完成。voidnotifyTaskCompleted(java.lang.String taskId, java.lang.String workerId, TileTaskBuildResult result)通知切图主节点,某个单元切图任务完成。voidnotifyTaskFailed(java.lang.String taskId, java.lang.String workerId)通知切图主节点,某个单元切图任务失败。voidnotifyWorkerDisconnected(java.lang.String workerId)通知切图主节点,某个子节点连接失败。voidsetTileCountPerTask(long value)设置每个单元切图任务分配的瓦片数。voidsetTileRegionManager(TileRegionStateManager tileRegionStateManager)设置切片区域管理器。voidstart()开始任务。voidstop()停止任务。voidupdateBlankRegions(double scale, java.lang.String[] invalidRegionIds, java.lang.String[] validRegionIds, java.lang.String[] noneMarkedRegionIds, boolean markAllInvalid, boolean markAllValid)更新白图范围。voidupdateJobConfig(JobBuildConfig config)更新任务配置voidupdateTileJob(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-
-
-