public class LocalTileWorkerClient extends java.lang.Object implements TileWorkerClient
TileWorkerClient.ConnectTileWorkerException, TileWorkerClient.WorkerConnectionStateListener| Constructor and Description |
|---|
LocalTileWorkerClient() |
| Modifier and Type | Method and Description |
|---|---|
void |
addListener(TileWorkerClient.WorkerConnectionStateListener listener) |
void |
addTask(TileTask task) |
CompConnInfo |
deployData(JobBuildConfig config, JobDeployingInfo deployingInfo)
Deploy data.
|
void |
deployJob(JobBuildConfig config) |
java.lang.String |
getId() |
TileWorkerInfo |
getInfo() |
TileWorkerState |
getState() |
TileTaskState |
getTaskState(java.lang.String taskId) |
TileWorker |
getTileWorker() |
boolean |
notifyJobCompleted(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.
|
boolean |
notifyJobTaskComplete(java.lang.String jobId, java.lang.String taskID)
Notify the TileWorker node that the tile task has been completed
|
void |
quit() |
void |
removeListener(TileWorkerClient.WorkerConnectionStateListener listener) |
void |
setConnectionInfo(TileWorkerInfo workerInfo)
Sets the connection information.
|
void |
setTileWorker(TileWorker value) |
public TileWorker getTileWorker()
public void setTileWorker(TileWorker value)
public TileWorkerState getState()
getState in interface TileWorkerClientpublic void addListener(TileWorkerClient.WorkerConnectionStateListener listener)
addListener in interface TileWorkerClientlistener -public void deployJob(JobBuildConfig config) throws TileWorkerClient.ConnectTileWorkerException
deployJob in interface TileWorkerClientconfig -ConnectTileWorkerExceptionTileWorkerClient.ConnectTileWorkerExceptionpublic CompConnInfo deployData(JobBuildConfig config, JobDeployingInfo deployingInfo)
TileWorkerClientDeploy data.
deployData in interface TileWorkerClientconfig - the configuration informationpublic void addTask(TileTask task) throws TileWorkerClient.ConnectTileWorkerException
addTask in interface TileWorkerClienttask -ConnectTileWorkerExceptionTileWorkerClient.ConnectTileWorkerExceptionpublic TileWorkerInfo getInfo()
getInfo in interface TileWorkerClientpublic java.lang.String getId()
getId in interface TileWorkerClientpublic TileTaskState getTaskState(java.lang.String taskId)
getTaskState in interface TileWorkerClienttaskId -public void quit()
quit in interface TileWorkerClientpublic void removeListener(TileWorkerClient.WorkerConnectionStateListener listener)
removeListener in interface TileWorkerClientlistener -public void setConnectionInfo(TileWorkerInfo workerInfo)
TileWorkerClientSets the connection information.
setConnectionInfo in interface TileWorkerClientworkerInfo - the connection informationpublic boolean notifyJobCompleted(java.lang.String jobId)
TileWorkerClientTileMasternotifyJobCompleted in interface TileWorkerClient
public boolean notifyJobTaskComplete(java.lang.String jobId,
java.lang.String taskID)
TileWorkerClientNotify the TileWorker node that the tile task has been completed
notifyJobTaskComplete in interface TileWorkerClient