public static class PersistentTasksCustomMetaData.Builder
extends java.lang.Object
Modifier and Type | Method | Description |
---|---|---|
<Params extends PersistentTaskParams> |
addTask(java.lang.String taskId,
java.lang.String taskName,
Params params,
PersistentTasksCustomMetaData.Assignment assignment) |
Adds a new task to the builder
|
PersistentTasksCustomMetaData |
build() |
|
long |
getLastAllocationId() |
|
boolean |
hasTask(java.lang.String taskId) |
Checks if the task is currently present in the list
|
boolean |
hasTask(java.lang.String taskId,
long allocationId) |
Checks if the task is currently present in the list and has the right allocation id
|
boolean |
isChanged() |
Returns true if any the task list was changed since the builder was created
|
PersistentTasksCustomMetaData.Builder |
reassignTask(java.lang.String taskId,
PersistentTasksCustomMetaData.Assignment assignment) |
Reassigns the task to another node
|
PersistentTasksCustomMetaData.Builder |
removeTask(java.lang.String taskId) |
Removes the task
|
PersistentTasksCustomMetaData.Builder |
updateTaskStatus(java.lang.String taskId,
Task.Status status) |
Updates the task status
|
public long getLastAllocationId()
public <Params extends PersistentTaskParams> PersistentTasksCustomMetaData.Builder addTask(java.lang.String taskId, java.lang.String taskName, Params params, PersistentTasksCustomMetaData.Assignment assignment)
After the task is added its id can be found by calling {getLastAllocationId()
} method.
public PersistentTasksCustomMetaData.Builder reassignTask(java.lang.String taskId, PersistentTasksCustomMetaData.Assignment assignment)
public PersistentTasksCustomMetaData.Builder updateTaskStatus(java.lang.String taskId, Task.Status status)
public PersistentTasksCustomMetaData.Builder removeTask(java.lang.String taskId)
public boolean hasTask(java.lang.String taskId)
public boolean hasTask(java.lang.String taskId, long allocationId)
public boolean isChanged()
public PersistentTasksCustomMetaData build()