public class TileTaskRunnerBase extends java.lang.Object implements TileTaskRunner, Disposable
Modifier and Type | Class and Description |
---|---|
class |
TileTaskRunnerBase.TaskStateListener |
TileTaskRunner.RunnerListener
Constructor and Description |
---|
TileTaskRunnerBase() |
Modifier and Type | Method and Description |
---|---|
void |
addListener(TileTaskRunner.RunnerListener listener)
Registers a listener to monitor changes in the execution status of the tile task, such as the start of the task, the end, and so on.
|
void |
cancel()
Cancels execution
|
void |
dispose()
Release the current task executor
|
TileTaskState |
getState(java.lang.String taskId)
Returns the state information of the tile task, including whether the current task was executed by that tangent point and whether it was completed.
|
TaskExecutingState |
getTaskExecutingState()
Returns the details of the execution status of the tile task, which is much more informative than the results from<.
|
void |
init(WorkerConfig pWorkerConfig, CheckedJobBuildConfig pJobConfig, TileStore pStore, KeyValueStore kvStore, Map pMap)
Initialization
|
static void |
restart(java.lang.Throwable e) |
void |
setJobBuildConfig(JobBuildConfig value)
Sets the configuration information of the tiling job.
|
void |
setMap(Map value)
Sets the business component for tiling.
|
void |
setMasterClient(TileMasterClient masterClient) |
void |
setStore(TileStore value)
Sets tile storage.
|
void |
setTask(TileTask task)
Sets the tile task information.
|
void |
setWorkerConfig(WorkerConfig workerConfig)
Sets the configuration of the tile node, including the number of tiling threads and the number of cutting map threads.
|
public static void restart(java.lang.Throwable e)
public TileTaskState getState(java.lang.String taskId)
Returns the state information of the tile task, including whether the current task was executed by that tangent point and whether it was completed.
getState
in interface TileTaskRunner
taskId
-public void init(WorkerConfig pWorkerConfig, CheckedJobBuildConfig pJobConfig, TileStore pStore, KeyValueStore kvStore, Map pMap)
TileTaskRunner
Initialization
init
in interface TileTaskRunner
public void addListener(TileTaskRunner.RunnerListener listener)
Registers a listener to monitor changes in the execution status of the tile task, such as the start of the task, the end, and so on.
addListener
in interface TileTaskRunner
listener
-public void setTask(TileTask task)
Sets the tile task information.
setTask
in interface TileTaskRunner
task
-public void setWorkerConfig(WorkerConfig workerConfig)
Sets the configuration of the tile node, including the number of tiling threads and the number of cutting map threads.
setWorkerConfig
in interface TileTaskRunner
workerConfig
-public TaskExecutingState getTaskExecutingState()
Returns the details of the execution status of the tile task, which is much more informative than the results from<. Including the task start time, the current speed, how many tiles have been completed.
getTaskExecutingState
in interface TileTaskRunner
public void cancel()
Cancels execution
cancel
in interface TileTaskRunner
public void setMasterClient(TileMasterClient masterClient)
setMasterClient
in interface TileTaskRunner
public void setJobBuildConfig(JobBuildConfig value)
Sets the configuration information of the tiling job.
value
-public void setStore(TileStore value)
Sets tile storage.
value
-public void setMap(Map value)
Sets the business component for tiling.
value
-public void dispose()
Release the current task executor
dispose
in interface Disposable
dispose
in interface TileTaskRunner