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 TileWorkerClient
public void addListener(TileWorkerClient.WorkerConnectionStateListener listener)
addListener
in interface TileWorkerClient
listener
-public void deployJob(JobBuildConfig config) throws TileWorkerClient.ConnectTileWorkerException
deployJob
in interface TileWorkerClient
config
-ConnectTileWorkerException
TileWorkerClient.ConnectTileWorkerException
public CompConnInfo deployData(JobBuildConfig config, JobDeployingInfo deployingInfo)
TileWorkerClient
Deploy data.
deployData
in interface TileWorkerClient
config
- the configuration informationpublic void addTask(TileTask task) throws TileWorkerClient.ConnectTileWorkerException
addTask
in interface TileWorkerClient
task
-ConnectTileWorkerException
TileWorkerClient.ConnectTileWorkerException
public TileWorkerInfo getInfo()
getInfo
in interface TileWorkerClient
public java.lang.String getId()
getId
in interface TileWorkerClient
public TileTaskState getTaskState(java.lang.String taskId)
getTaskState
in interface TileWorkerClient
taskId
-public void quit()
quit
in interface TileWorkerClient
public void removeListener(TileWorkerClient.WorkerConnectionStateListener listener)
removeListener
in interface TileWorkerClient
listener
-public void setConnectionInfo(TileWorkerInfo workerInfo)
TileWorkerClient
Sets the connection information.
setConnectionInfo
in interface TileWorkerClient
workerInfo
- the connection informationpublic boolean notifyJobCompleted(java.lang.String jobId)
TileWorkerClient
TileMaster
notifyJobCompleted
in interface TileWorkerClient
public boolean notifyJobTaskComplete(java.lang.String jobId, java.lang.String taskID)
TileWorkerClient
Notify the TileWorker node that the tile task has been completed
notifyJobTaskComplete
in interface TileWorkerClient