public class DefaultTileMaster extends java.lang.Object implements TileMaster, ComponentContextAware
| 限定符和类型 | 类和说明 |
|---|---|
protected static class |
DefaultTileMaster.StateSaver |
| 构造器和说明 |
|---|
DefaultTileMaster()
构造函数。
|
| 限定符和类型 | 方法和说明 |
|---|---|
protected TileJob |
addJob(JobBuildConfig processed, JobState state) |
TileJob |
addJob(JobInfo jobInfo)
新建切图作业
|
boolean |
addTileWorker(TileWorkerInfo connInfo)
添加切图节点
|
void |
analystBlankTile(java.lang.String jobId)
通知具名的一个切图作业开始进行白图信息的分析
|
java.lang.String |
confirmBlanRegionInfos(java.lang.String jobId)
确认白块信息。
|
boolean |
deleteJob(java.lang.String jobID)
删除切图任务
|
void |
dispose()
释放资源。
|
BlankTileInfo |
getBlankTileInfos(java.lang.String jobId, double scale, int fromIndex, int toIndex)
返回所有的白图信息
|
TileJob |
getTileJob(java.lang.String jobID)
返回具名的一个切图作业信息
|
java.util.List<TileJob> |
getTileJobs()
返回所有切图作业信息
|
TileWorkerState |
getWorkerState(java.lang.String workerId)
返回具名的一个切图节点的状态
|
TileWorkerState[] |
getWorkerStates()
返回所有的切图节点的状态。
|
TileSourceInfo |
handleUserDefinedInfo(TileSourceInfo info)
获取TileSource 容器中的切片源信息。
|
protected JobRunner |
initJobRunner(JobBuildConfig processed, JobState state, boolean completed) |
protected TileJob |
initTileJob(JobBuildConfig processed, JobRunner runner) |
boolean |
notifyJobDeployCompleted(java.lang.String jobId, java.lang.String workerId)
通知切图主节点,切图作业在切图节点部署完毕
|
boolean |
notifyTaskCompleted(java.lang.String jobId, java.lang.String taskId, java.lang.String workerId)
通知切图主节点,某个单元切图任务已完成
|
boolean |
notifyTaskCompleted(java.lang.String jobId, java.lang.String taskId, java.lang.String workerId, TileTaskBuildResult result)
通知切图主节点,某个切图任务成功了。
|
boolean |
notifyTaskFailed(java.lang.String jobId, java.lang.String taskId, java.lang.String workerId)
通知切图主节点,某个单元切图任务失败。
|
void |
redeployJobToWorker(java.lang.String jobId, java.lang.String workerId)
当部署切图任务到worker失败时,用于重新部署。
|
void |
removeTileWorker(java.lang.String workerId)
移除切图节点
|
void |
restart(java.lang.String jobId)
重启切图作业
|
void |
setComponentContext(ComponentContext context)
设置服务组件上下文信息。
|
void |
setJobInfoPREProcessor(JobInfoPREProcessor processor)
设置切图作业预处理器
|
void |
setJobRunnerFactory(JobRunnerFactory factory)
设置切图运行器工厂
|
void |
setRestContext(RestContext value)
设置Rest上下文信息。
|
void |
setTileWorkerClientFactory(TileWorkerClientFactory value)
绑定子节点生成器。
|
void |
startJob(java.lang.String jobId)
启动切图作业
|
void |
stopJob(java.lang.String jobId)
停止切图作业
|
void |
updateBlankRegion(java.lang.String jobId, double scale, java.lang.String[] invalidRegionIds, java.lang.String[] validRegionIds, java.lang.String[] noneMarkedRegionIds, boolean markAllInvalid, boolean markAllValid)
提交一次白图信息的确认信息
|
void |
updateScheduledTimeRanges(java.lang.String jobId, java.util.List<java.lang.String> scheduledTimeRanges) |
void |
workerQuit(TileWorkerInfo conInfo)
通知切图主节点,切图节点已退出
|
public void redeployJobToWorker(java.lang.String jobId,
java.lang.String workerId)
TileMaster当部署切图任务到worker失败时,用于重新部署。
redeployJobToWorker 在接口中 TileMasterjobId - 需要重新部署的任务id。workerId - 需要重新部署到的worker的id。public void setRestContext(RestContext value)
设置Rest上下文信息。
value -public boolean addTileWorker(TileWorkerInfo connInfo)
添加切图节点
addTileWorker 在接口中 TileMasterconInfo -public void removeTileWorker(java.lang.String workerId)
移除切图节点
removeTileWorker 在接口中 TileMasterworkerId -public void workerQuit(TileWorkerInfo conInfo)
通知切图主节点,切图节点已退出
workerQuit 在接口中 TileMasterconInfo -public void stopJob(java.lang.String jobId)
停止切图作业
stopJob 在接口中 TileMasterjobId -public void startJob(java.lang.String jobId)
启动切图作业
startJob 在接口中 TileMasterjobId -public void restart(java.lang.String jobId)
重启切图作业
restart 在接口中 TileMasterjobId -public TileJob addJob(JobInfo jobInfo)
新建切图作业
addJob 在接口中 TileMasterinfo -
public void updateScheduledTimeRanges(java.lang.String jobId,
java.util.List<java.lang.String> scheduledTimeRanges)
updateScheduledTimeRanges 在接口中 TileMasterpublic TileSourceInfo handleUserDefinedInfo(TileSourceInfo info)
获取TileSource 容器中的切片源信息。
info -public void setJobInfoPREProcessor(JobInfoPREProcessor processor)
设置切图作业预处理器
setJobInfoPREProcessor 在接口中 TileMasterprocessor -public void setJobRunnerFactory(JobRunnerFactory factory)
设置切图运行器工厂
setJobRunnerFactory 在接口中 TileMasterfactory -public java.util.List<TileJob> getTileJobs()
返回所有切图作业信息
getTileJobs 在接口中 TileMasterpublic TileJob getTileJob(java.lang.String jobID)
返回具名的一个切图作业信息
getTileJob 在接口中 TileMasterjobID - 切图任务的ID
public boolean notifyJobDeployCompleted(java.lang.String jobId,
java.lang.String workerId)
通知切图主节点,切图作业在切图节点部署完毕
notifyJobDeployCompleted 在接口中 TileMasterjobId - 切图任务ID。workerId - 切图节点id
public boolean notifyTaskCompleted(java.lang.String jobId,
java.lang.String taskId,
java.lang.String workerId)
通知切图主节点,某个单元切图任务已完成
notifyTaskCompleted 在接口中 TileMasterjobId - 切图任务ID。taskId - 单元切图任务ID。有关单元切图任务,请参见 TileTask.workerId - 执行该单元任务的 TileWorker ID。
public boolean notifyTaskFailed(java.lang.String jobId,
java.lang.String taskId,
java.lang.String workerId)
通知切图主节点,某个单元切图任务失败。
notifyTaskFailed 在接口中 TileMasterjobId - 切图任务ID。taskId - 单元切图任务ID。有关单元切图任务,请参见 TileTask.workerId - 执行该单元任务的 TileWorker ID。public boolean deleteJob(java.lang.String jobID)
删除切图任务
deleteJob 在接口中 TileMasterjobID - 预删除的切图任务ID。
public boolean notifyTaskCompleted(java.lang.String jobId,
java.lang.String taskId,
java.lang.String workerId,
TileTaskBuildResult result)
通知切图主节点,某个切图任务成功了。
notifyTaskCompleted 在接口中 TileMasterjobId -taskId -workerId -result -public void analystBlankTile(java.lang.String jobId)
通知具名的一个切图作业开始进行白图信息的分析
analystBlankTile 在接口中 TileMasterjobId -public BlankTileInfo getBlankTileInfos(java.lang.String jobId, double scale, int fromIndex, int toIndex)
返回所有的白图信息
getBlankTileInfos 在接口中 TileMasterjobId -scale -fromIndex -toIndex -
public void updateBlankRegion(java.lang.String jobId,
double scale,
java.lang.String[] invalidRegionIds,
java.lang.String[] validRegionIds,
java.lang.String[] noneMarkedRegionIds,
boolean markAllInvalid,
boolean markAllValid)
提交一次白图信息的确认信息
updateBlankRegion 在接口中 TileMasterjobId -scale -invalidRegionIds -validRegionIds -noneMarkedRegionIds -markAllInvalid -markedAllValid -public java.lang.String confirmBlanRegionInfos(java.lang.String jobId)
confirmBlanRegionInfos 在接口中 TileMasterjobId -public TileWorkerState[] getWorkerStates()
返回所有的切图节点的状态。
getWorkerStates 在接口中 TileMasterpublic TileWorkerState getWorkerState(java.lang.String workerId)
返回具名的一个切图节点的状态
getWorkerState 在接口中 TileMasterworkerId -public void setTileWorkerClientFactory(TileWorkerClientFactory value)
绑定子节点生成器。
value -public void dispose()
释放资源。
dispose 在接口中 Disposablepublic void setComponentContext(ComponentContext context)
设置服务组件上下文信息。
setComponentContext 在接口中 ComponentContextAwarecontext -protected JobRunner initJobRunner(JobBuildConfig processed, JobState state, boolean completed)