com.supermap.services.components.impl

Class DefaultJobRunner

java.lang.Object

com.supermap.services.components.impl.DefaultJobRunner

All Implemented Interfaces:

JobRunner, Disposable

Direct Known Subclasses:

CloudJobRunner

public class DefaultJobRunner
extends java.lang.Object
implements JobRunner, Disposable

Constructor Summary

Constructors

Constructor and Description
DefaultJobRunner()

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(JobRunnerListener listener) Add listener.
void	addWorker(TileWorkerClient worker) Adds the tiling node.
void	addWorkers(java.util.List<TileWorkerClient> workers2Add) Adds the tiling node.
protected TileScaleInfo	caculateTileScaleInfo(ScaleBuildConfig scaleConfig, Geometry[] regions)
void	confirmBlankRegionInfos(java.lang.String jobId) Confirms the white map range.
void	deployJobToWorker(TileWorkerClient client) Assigns a tiling task to a child node.
void	dispose() Release the resource object.
BlankTileInfo	getBlankTileInfos(double scale, int fromIndex, int toIndex) Gets the white map information.
JobBuildConfig	getJobConfig() Gets task configuration information.
java.lang.String	getRemoteWorkspacePath(JobBuildConfig jobBuildConfig) Gets the child node workspace path.
protected RuntimeJobStateBuilderFactory	getRuntimeJobStateBuilderFactory()
JobState	getState() Gets Job status.
TilesetDesc	getTilesetDesc() Get the target information for the task.
void	init(JobBuildConfig pConfig, JobState pState, JobDataDeploy dataDeploy) Initialize Runner
void	notifyJobDeployCompleted(java.lang.String workerId) Notifies the tiling master node, and the tiling job is deployed successfully at the tiling node
void	notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId) Notifies the tiling master node that a unit tiling task completed.
void	notifyTaskCompleted(java.lang.String taskId, java.lang.String workerId, TileTaskBuildResult result) Notifies the tiling master node that a unit tiling task completed.
void	notifyTaskFailed(java.lang.String taskid, java.lang.String workerId) Notifies the tiling master node that a unit tiling task failed.
void	notifyWorkerDisconnected(java.lang.String workerId) Notifies the tiling master node that a child node connection failed.
void	setDeployTaskThreadCount(int deployTaskThreadCount)
void	setTileCountPerTask(long value) Sets the number of tiles assigned to each unit's tiling task.
void	setTileRegionManager(TileRegionStateManager tileRegionStateManager) Set the Tile Area Manager.
void	start() Starts the task.
void	stop() Stops the task.
void	updateBlankRegions(double scale, java.lang.String[] invalidRegionIds, java.lang.String[] validRegionIds, java.lang.String[] noneMarkedRegionIds, boolean markAllInvalid, boolean markAllValid) Updates the white map range.
void	updateTileJob(Tile[] tiles) Updates the tiling task.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultJobRunner

public DefaultJobRunner()

Method Detail

init

public void init(JobBuildConfig pConfig,
        JobState pState,
        JobDataDeploy dataDeploy)

Description copied from interface: JobRunner

Initialize Runner

Specified by:

init in interface JobRunner

pState - can be null

addListener

public void addListener(JobRunnerListener listener)

Description copied from interface: JobRunner

Add listener.

Specified by:

addListener in interface JobRunner

deployJobToWorker

public void deployJobToWorker(TileWorkerClient client)

Description copied from interface: JobRunner

Assigns a tiling task to a child node.

Specified by:

deployJobToWorker in interface JobRunner

start

public void start()

Description copied from interface: JobRunner

Starts the task.

Specified by:

start in interface JobRunner

caculateTileScaleInfo

protected TileScaleInfo caculateTileScaleInfo(ScaleBuildConfig scaleConfig,
                                  Geometry[] regions)

addWorker

public void addWorker(TileWorkerClient worker)

Adds the tiling node.

Parameters:

worker -

Since:

8.1.1

stop

public void stop()

Description copied from interface: JobRunner

Stops the task.

Specified by:

stop in interface JobRunner

addWorkers

public void addWorkers(java.util.List<TileWorkerClient> workers2Add)

Description copied from interface: JobRunner

Adds the tiling node.

Specified by:

addWorkers in interface JobRunner

getState

public JobState getState()

Description copied from interface: JobRunner

Gets Job status. The status returned is not real-time, but it is valid. During the execution of the Job, the status of the Job may be modified concurrently. When this method is called, if another thread is modifying the state of the job, that is, modifying the JobState object's field, the method does not synchronize with the modified thread, so the state it returns is not real-time. But the status of the return is certainly a state after the completion of a modification, rather than the state of the concurrent modification (the state in the modification may be invalid), so the returned state is valid.

Specified by:

getState in interface JobRunner

Returns:

getTilesetDesc

public TilesetDesc getTilesetDesc()

Description copied from interface: JobRunner

Get the target information for the task.

Specified by:

getTilesetDesc in interface JobRunner

Returns:

setTileCountPerTask

public void setTileCountPerTask(long value)

Description copied from interface: JobRunner

Sets the number of tiles assigned to each unit's tiling task. For a unit tiling task, see TileTask.

Specified by:

setTileCountPerTask in interface JobRunner

Parameters:

value - The number of tiles.

notifyJobDeployCompleted

public void notifyJobDeployCompleted(java.lang.String workerId)

Description copied from interface: JobRunner

Notifies the tiling master node, and the tiling job is deployed successfully at the tiling node

Specified by:

notifyJobDeployCompleted in interface JobRunner

notifyTaskCompleted

public void notifyTaskCompleted(java.lang.String taskId,
                       java.lang.String workerId)

Description copied from interface: JobRunner

Notifies the tiling master node that a unit tiling task completed.

Specified by:

notifyTaskCompleted in interface JobRunner

Parameters:

taskId - The completed Unit tiling task ID.

workerId - TaskId unit tiling task where the worker exists.

notifyTaskCompleted

public void notifyTaskCompleted(java.lang.String taskId,
                       java.lang.String workerId,
                       TileTaskBuildResult result)

Description copied from interface: JobRunner

Notifies the tiling master node that a unit tiling task completed.

Specified by:

notifyTaskCompleted in interface JobRunner

notifyTaskFailed

public void notifyTaskFailed(java.lang.String taskid,
                    java.lang.String workerId)

Description copied from interface: JobRunner

Notifies the tiling master node that a unit tiling task failed.

Specified by:

notifyTaskFailed in interface JobRunner

notifyWorkerDisconnected

public void notifyWorkerDisconnected(java.lang.String workerId)

Description copied from interface: JobRunner

Notifies the tiling master node that a child node connection failed.

Specified by:

notifyWorkerDisconnected in interface JobRunner

getRemoteWorkspacePath

public java.lang.String getRemoteWorkspacePath(JobBuildConfig jobBuildConfig)

Gets the child node workspace path.

Parameters:

jobBuildConfig -

Returns:

Since:

8.1.1

getJobConfig

public JobBuildConfig getJobConfig()

Description copied from interface: JobRunner

Gets task configuration information.

Specified by:

getJobConfig in interface JobRunner

Returns:

dispose

public void dispose()

Description copied from interface: Disposable

Release the resource object.

Specified by:

dispose in interface Disposable

updateTileJob

public void updateTileJob(Tile[] tiles)

Description copied from interface: JobRunner

Updates the tiling task.

Specified by:

updateTileJob in interface JobRunner

getBlankTileInfos

public BlankTileInfo getBlankTileInfos(double scale,
                              int fromIndex,
                              int toIndex)

Description copied from interface: JobRunner

Gets the white map information.

Specified by:

getBlankTileInfos in interface JobRunner

Returns:

confirmBlankRegionInfos

public void confirmBlankRegionInfos(java.lang.String jobId)

Description copied from interface: JobRunner

Confirms the white map range.

Specified by:

confirmBlankRegionInfos in interface JobRunner

updateBlankRegions

public void updateBlankRegions(double scale,
                      java.lang.String[] invalidRegionIds,
                      java.lang.String[] validRegionIds,
                      java.lang.String[] noneMarkedRegionIds,
                      boolean markAllInvalid,
                      boolean markAllValid)

Description copied from interface: JobRunner

Updates the white map range.

Specified by:

updateBlankRegions in interface JobRunner

setTileRegionManager

public void setTileRegionManager(TileRegionStateManager tileRegionStateManager)

Description copied from interface: JobRunner

Set the Tile Area Manager.

Specified by:

setTileRegionManager in interface JobRunner

getRuntimeJobStateBuilderFactory

protected RuntimeJobStateBuilderFactory getRuntimeJobStateBuilderFactory()

setDeployTaskThreadCount

public void setDeployTaskThreadCount(int deployTaskThreadCount)