com.supermap.services.components.impl
Class DefaultTileWorker
- java.lang.Object
-
- com.supermap.services.components.impl.DefaultTileWorker
-
- All Implemented Interfaces:
- Disposable, TileWorker
public class DefaultTileWorker extends java.lang.Object implements TileWorker, Disposable
Tiling sub node
- Since:
- 8.1.1
-
-
Nested Class Summary
Nested Classes Modifier and Type Class and Description static interfaceDefaultTileWorker.JobDeployedCallBack
-
Constructor Summary
Constructors Constructor and Description DefaultTileWorker()The Constructor.DefaultTileWorker(DefaultTileTaskRunnerFactory runnerfactory, DefaultTileStoreFactory storeFactory, MapBuilder mapBuilder, TileMasterClientFactory tileMasterClientFactory)The Constructor.DefaultTileWorker(RestContext restContext)The Constructor.
-
Method Summary
Methods Modifier and Type Method and Description JobExecutingStatesaddTask(TileTask task)Adds Unit tiling Task.booleandeployData(ProviderConnInfo[] providerConnectionInfos, java.lang.String masterAddress, boolean readOnly, java.lang.String id, FileVerificationMode verificationMode)Deploys the tiling data.booleandeployJob(JobBuildConfig pConfig)Deploys the task, after receiving the task, after the parameter check, start the asynchronous deployment, immediately returnvoiddispose()Release the resource object.booleandoDeployJob(JobBuildConfig pConfig, DefaultTileWorker.JobDeployedCallBack callback)Starts the deployment task.JobExecutingStatesgetJobExecutingStates()Gets the tiling task status.protected static KeyValueStoregetKeyValueStore(TileSourceInfo storeConfig)TileTaskStategetTaskState(java.lang.String tileTaskId)Gets the unit tile task status.protected voidinsureKvStoreExist(JobBuildConfig pJobConfig)booleannotifyJobCompleted(java.lang.String jobId)Notifies the TileWorker node that the tiling task has been completed and can turn off some of the resources (eg thread, memory pool, etc.) for the application.voidsetDataManager(WorkerDataManager value)Setup Manager.voidsetMapBuilder(MapBuilder value)Sets MapBuilder.voidsetMaster(TileMaster value)Setting tiling master node.voidsetRealspaceBuilder(RealspaceBuilder value)Sets RealspaceBuildervoidsetRestContext(RestContext value)Sets the Rest context information.booleanstopDeployData(java.lang.String[] masterSideIds)Notifies the TileWorker node to stop downloading data.JobExecutingStateswhatAreYouDoing()Gets the tiling task status.
-
-
-
Constructor Detail
-
DefaultTileWorker
public DefaultTileWorker()
The Constructor.
-
DefaultTileWorker
public DefaultTileWorker(RestContext restContext)
The Constructor.
- Parameters:
restContext-
-
DefaultTileWorker
public DefaultTileWorker(DefaultTileTaskRunnerFactory runnerfactory, DefaultTileStoreFactory storeFactory, MapBuilder mapBuilder, TileMasterClientFactory tileMasterClientFactory)
The Constructor.
- Parameters:
runnerfactory-storeFactory-mapBuilder-tileMasterClientFactory-
-
-
Method Detail
-
setDataManager
public void setDataManager(WorkerDataManager value)
Setup Manager.
- Parameters:
value-
-
deployData
public boolean deployData(ProviderConnInfo[] providerConnectionInfos, java.lang.String masterAddress, boolean readOnly, java.lang.String id, FileVerificationMode verificationMode) throws java.io.IOException
Description copied from interface:TileWorkerDeploys the tiling data.
- Specified by:
deployDatain interfaceTileWorker- Returns:
- Throws:
java.io.IOException
-
stopDeployData
public boolean stopDeployData(java.lang.String[] masterSideIds)
Description copied from interface:TileWorkerNotifies the TileWorker node to stop downloading data.
- Specified by:
stopDeployDatain interfaceTileWorker- Returns:
-
deployJob
public boolean deployJob(JobBuildConfig pConfig)
Deploys the task, after receiving the task, after the parameter check, start the asynchronous deployment, immediately return
- Specified by:
deployJobin interfaceTileWorker- Parameters:
pConfig-- Returns:
-
doDeployJob
public boolean doDeployJob(JobBuildConfig pConfig, DefaultTileWorker.JobDeployedCallBack callback)
Starts the deployment task.
- Parameters:
pConfig-callback-- Returns:
-
addTask
public JobExecutingStates addTask(TileTask task)
Description copied from interface:TileWorkerAdds Unit tiling Task.
- Specified by:
addTaskin interfaceTileWorker- Returns:
-
whatAreYouDoing
public JobExecutingStates whatAreYouDoing()
Description copied from interface:TileWorkerGets the tiling task status.
- Specified by:
whatAreYouDoingin interfaceTileWorker- Returns:
-
getTaskState
public TileTaskState getTaskState(java.lang.String tileTaskId)
Description copied from interface:TileWorkerGets the unit tile task status.
- Specified by:
getTaskStatein interfaceTileWorker- Returns:
-
dispose
public void dispose()
Description copied from interface:DisposableRelease the resource object.
- Specified by:
disposein interfaceDisposable
-
setMapBuilder
public void setMapBuilder(MapBuilder value)
Sets MapBuilder.
- Parameters:
value-
-
setRealspaceBuilder
public void setRealspaceBuilder(RealspaceBuilder value)
Sets RealspaceBuilder
- Parameters:
value-
-
setRestContext
public void setRestContext(RestContext value)
Sets the Rest context information.
- Parameters:
value-
-
getJobExecutingStates
public JobExecutingStates getJobExecutingStates()
Gets the tiling task status.
- Returns:
- Since:
- 8.1.1
-
insureKvStoreExist
protected void insureKvStoreExist(JobBuildConfig pJobConfig)
-
getKeyValueStore
protected static KeyValueStore getKeyValueStore(TileSourceInfo storeConfig)
-
setMaster
public void setMaster(TileMaster value)
Setting tiling master node.
- Parameters:
value-- Since:
- 8.1.1
-
notifyJobCompleted
public boolean notifyJobCompleted(java.lang.String jobId)
Description copied from interface:TileWorkerNotifies the TileWorker node that the tiling task has been completed and can turn off some of the resources (eg thread, memory pool, etc.) for the application. The method is called byTileMaster- Specified by:
notifyJobCompletedin interfaceTileWorker- Returns:
-
-