public abstract class AbstractRuntimeJobState extends JobState
运行时的切图作业状态信息类。职责包括
1,切图任务的拆分
2, 切图子节点任务完成或失败时,切图状态的自动更新
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 |
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已经完成。
|
equals, hashCode, setTileCountPerTask
protected volatile JobState currentState
protected JobBuildConfig config
protected boolean stopped
protected java.util.concurrent.locks.ReentrantLock changeStateLock
protected TileRegionStateManager tileRegionStateManager
protected AbstractRuntimeJobState.JobStateListener listeners
public AbstractRuntimeJobState(JobState value)
构造函数。
value
-protected TileScaleInfo getInfoByScale(double scaleDenominator)
获取切图任务比例尺下的进度。
scaleDenominator
-public JobState getState()
获取当前所有任务状态。
public TileTask getTaskById(java.lang.String id)
通过ID,获取的单元任务。
id
-public abstract JobState updateTaskToCompleted(TileTask task, TileTaskBuildResult taskBuildResult, TileWorkerInfo tileWorkerInfo)
更新当前的状态,以反映task已经完成。
task
-public abstract JobState updateTaskToCompleted(TileTask task)
更新当前的状态,以反映task已经完成。
task
-protected void updatElapsedTime(JobState result)
protected void delTask(java.lang.String id)
public abstract TileTask getTask()
获取单元任务。
id
-protected ScaleBuildConfig getScaleBuildConfigByScale(double scaleDenominator)
public AbstractRuntimeJobState.DeployTaskResult deployTaskToWorker(TileWorkerClient worker)
向切图子节点部署单元切图任务。
worker
-public void setConfig(JobBuildConfig value)
设置切图任务配置信息。
value
-public JobState updateTaskFailed(TileTask task)
将单元切图任务标记为失败。
task
-public JobState stop()
停止切图任务。
public JobState start()
开始切图任务。
public JobState notifyWorkerDisconnected(java.lang.String workerId)
切图子节点连接失败时,将单元切图任务标记为失败 。
workerId
-public java.util.List<TileTask> getAllTasks()
获取单元切图任务列表。
public void updateProgress(java.util.Map<java.lang.String,java.lang.Long> progress)
更新切图进度。
progress
-public java.util.List<java.lang.String> notifyLostConnectionPerhaps(java.util.Map<java.lang.String,TileTask> lostConnection)
获取执行单元切图任务时断开连接的workID。
lostConnection
-public void addListener(AbstractRuntimeJobState.JobStateListener listener)
添加一个监听器。
listener
-public JobState addUpdateTasks(TileTask[] updateTasks)
添加单元切图任务。
updateTasks
-protected WorkerBuildingInfo[] mergeWorkerBuildingInfos(WorkerBuildingInfo[] workerBuildingInfos, WorkerBuildingInfo workerInfo)
public void setTileRegionStateManager(TileRegionStateManager tileRegionStateManager)
设置切图范围状态管理器。
tileRegionStateManager
-