public class DefaultJobRunner extends java.lang.Object implements JobRunner, Disposable
构造器和说明 |
---|
DefaultJobRunner() |
限定符和类型 | 方法和说明 |
---|---|
void |
addListener(JobRunnerListener listener)
添加监听器。
|
void |
addWorker(TileWorkerClient worker)
添加切图节点。
|
void |
addWorkers(java.util.List<TileWorkerClient> workers2Add)
添加切图节点。
|
protected TileScaleInfo |
caculateTileScaleInfo(ScaleBuildConfig scaleConfig, Geometry[] regions) |
void |
confirmBlankRegionInfos(java.lang.String jobId)
确认白图范围。
|
void |
deployJobToWorker(TileWorkerClient client)
分配切图任务给子节点。
|
void |
dispose()
释放资源对象。
|
BlankTileInfo |
getBlankTileInfos(double scale, int fromIndex, int toIndex)
获取白图信息。
|
JobBuildConfig |
getJobConfig()
获取任务配置信息。
|
java.lang.String |
getRemoteWorkspacePath(JobBuildConfig jobBuildConfig)
获取子节点工作空间路径。
|
protected RuntimeJobStateBuilderFactory |
getRuntimeJobStateBuilderFactory() |
JobState |
getState()
获取Job状态。
|
TilesetDesc |
getTilesetDesc()
获取任务的目标信息.
|
void |
init(JobBuildConfig pConfig, JobState pState, JobDataDeploy dataDeploy)
对Runner进行初始化
|
protected TileScaleInfo |
initScaleInfoByCacheBounds(Point2D leftTop, ScaleBuildConfig scaleConfig, Rectangle2D cacheBounds) |
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 |
setDeployTaskThreadCount(int deployTaskThreadCount) |
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)
更新切图任务。
|
public void init(JobBuildConfig pConfig, JobState pState, JobDataDeploy dataDeploy)
JobRunner
public void addListener(JobRunnerListener listener)
JobRunner
添加监听器。
addListener
在接口中 JobRunner
public void deployJobToWorker(TileWorkerClient client)
JobRunner
分配切图任务给子节点。
deployJobToWorker
在接口中 JobRunner
protected TileScaleInfo caculateTileScaleInfo(ScaleBuildConfig scaleConfig, Geometry[] regions)
protected TileScaleInfo initScaleInfoByCacheBounds(Point2D leftTop, ScaleBuildConfig scaleConfig, Rectangle2D cacheBounds)
public void addWorker(TileWorkerClient worker)
添加切图节点。
worker
-public void addWorkers(java.util.List<TileWorkerClient> workers2Add)
JobRunner
添加切图节点。
addWorkers
在接口中 JobRunner
public JobState getState()
JobRunner
public TilesetDesc getTilesetDesc()
JobRunner
getTilesetDesc
在接口中 JobRunner
public void setTileCountPerTask(long value)
JobRunner
设置每个单元切图任务分配的瓦片数。关于单元切图任务,请参见 TileTask
.
setTileCountPerTask
在接口中 JobRunner
value
- 瓦片数。public void notifyJobDeployCompleted(java.lang.String workerId)
JobRunner
通知切图主节点,切图作业在切图节点部署完毕
notifyJobDeployCompleted
在接口中 JobRunner
public void notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId)
JobRunner
通知切图主节点,某个单元切图任务完成。
notifyTaskCompleted
在接口中 JobRunner
taskId
- 已完成的单元切图任务ID。workerId
- taskId单元切图任务所在的Woker。public void notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId, TileTaskBuildResult result)
JobRunner
通知切图主节点,某个单元切图任务完成。
notifyTaskCompleted
在接口中 JobRunner
public void notifyTaskFailed(java.lang.String taskid, java.lang.String workerId)
JobRunner
通知切图主节点,某个单元切图任务失败。
notifyTaskFailed
在接口中 JobRunner
public void notifyWorkerDisconnected(java.lang.String workerId)
JobRunner
通知切图主节点,某个子节点连接失败。
notifyWorkerDisconnected
在接口中 JobRunner
public java.lang.String getRemoteWorkspacePath(JobBuildConfig jobBuildConfig)
获取子节点工作空间路径。
jobBuildConfig
-public JobBuildConfig getJobConfig()
JobRunner
获取任务配置信息。
getJobConfig
在接口中 JobRunner
public void updateJobConfig(JobBuildConfig config)
JobRunner
updateJobConfig
在接口中 JobRunner
public void dispose()
Disposable
释放资源对象。
dispose
在接口中 Disposable
public void updateTileJob(Tile[] tiles)
JobRunner
更新切图任务。
updateTileJob
在接口中 JobRunner
public BlankTileInfo getBlankTileInfos(double scale, int fromIndex, int toIndex)
JobRunner
获取白图信息。
getBlankTileInfos
在接口中 JobRunner
public void confirmBlankRegionInfos(java.lang.String jobId)
JobRunner
确认白图范围。
confirmBlankRegionInfos
在接口中 JobRunner
public void updateBlankRegions(double scale, java.lang.String[] invalidRegionIds, java.lang.String[] validRegionIds, java.lang.String[] noneMarkedRegionIds, boolean markAllInvalid, boolean markAllValid)
JobRunner
更新白图范围。
updateBlankRegions
在接口中 JobRunner
public void setTileRegionManager(TileRegionStateManager tileRegionStateManager)
JobRunner
设置切片区域管理器。
setTileRegionManager
在接口中 JobRunner
protected RuntimeJobStateBuilderFactory getRuntimeJobStateBuilderFactory()
public void setDeployTaskThreadCount(int deployTaskThreadCount)