tech.powerjob.worker.persistence

类 TaskPersistenceService

java.lang.Object

tech.powerjob.worker.persistence.TaskPersistenceService

public class TaskPersistenceService
extends Object

任务持久化服务

从以下版本开始:

2020/3/17

作者:

tjq

构造器概要

构造器

构造器和说明
TaskPersistenceService(StoreStrategy strategy)

方法概要

限定符和类型	方法和说明
boolean	batchSave(List<TaskDO> tasks)
boolean	batchUpdateTaskStatus(Long instanceId, List<String> taskIds, TaskStatus status, String result) 批量更新 Task 状态
boolean	deleteAllSubInstanceTasks(Long instanceId, Long subInstanceId)
boolean	deleteAllTasks(Long instanceId)
List<TaskDO>	getAllTask(Long instanceId, Long subInstanceId)
List<TaskResult>	getAllTaskResult(Long instanceId, Long subInstanceId) 查询所有Task执行结果，reduce阶段 或 postProcess阶段 使用
List<TaskDO>	getAllUnFinishedTaskByAddress(Long instanceId, String address)
Optional<TaskDO>	getLastTask(Long instanceId, Long subInstanceId) 获取 MapReduce 或 Broadcast 的最后一个任务
Optional<TaskDO>	getTask(Long instanceId, String taskId) 根据主键查询 Task
List<TaskDO>	getTaskByStatus(Long instanceId, TaskStatus status, int limit) 获取指定状态的Task
Optional<TaskStatus>	getTaskStatus(Long instanceId, String taskId) 查询任务状态（只查询 status，节约 I/O 资源 -> 测试表明，在（我高端的NVMe）SSD上都效果惊人...别说一般的HDD了...磁盘I/O果然是重要瓶颈...）
Map<TaskStatus,Long>	getTaskStatusStatistics(Long instanceId, Long subInstanceId) 获取 TaskTracker 管理的子 task 状态统计信息 TaskStatus -> num
void	init()
List<TaskDO>	listAll()
boolean	save(TaskDO task)
boolean	updateLostTasks(Long instanceId, List<String> addressList, boolean retry) 更新被派发到已经失联的 ProcessorTracker 的任务，重新执行 update task_info set address = 'N/A', status = 0 where address in () and status not in (5,6) and instance_id = 277
boolean	updateTask(Long instanceId, String taskId, TaskDO updateEntity) 依靠主键更新 Task（不涉及 result 的，都可以用该方法更新）
boolean	updateTaskStatus(Long instanceId, String taskId, int status, long lastReportTime, String result) 更新任务状态

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

TaskPersistenceService

public TaskPersistenceService(StoreStrategy strategy)

方法详细资料

init

public void init()
          throws Exception

抛出:

Exception

save

public boolean save(TaskDO task)

batchSave

public boolean batchSave(List<TaskDO> tasks)

updateTask

public boolean updateTask(Long instanceId,
                          String taskId,
                          TaskDO updateEntity)

依靠主键更新 Task（不涉及 result 的，都可以用该方法更新）

updateTaskStatus

public boolean updateTaskStatus(Long instanceId,
                                String taskId,
                                int status,
                                long lastReportTime,
                                String result)

更新任务状态

updateLostTasks

public boolean updateLostTasks(Long instanceId,
                               List<String> addressList,
                               boolean retry)

更新被派发到已经失联的 ProcessorTracker 的任务，重新执行 update task_info set address = 'N/A', status = 0 where address in () and status not in (5,6) and instance_id = 277

getLastTask

public Optional<TaskDO> getLastTask(Long instanceId,
                                    Long subInstanceId)

获取 MapReduce 或 Broadcast 的最后一个任务

getAllTask

public List<TaskDO> getAllTask(Long instanceId,
                               Long subInstanceId)

getAllUnFinishedTaskByAddress

public List<TaskDO> getAllUnFinishedTaskByAddress(Long instanceId,
                                                  String address)

getTaskByStatus

public List<TaskDO> getTaskByStatus(Long instanceId,
                                    TaskStatus status,
                                    int limit)

获取指定状态的Task

getTaskStatusStatistics

public Map<TaskStatus,Long> getTaskStatusStatistics(Long instanceId,
                                                    Long subInstanceId)

获取 TaskTracker 管理的子 task 状态统计信息 TaskStatus -> num

getAllTaskResult

public List<TaskResult> getAllTaskResult(Long instanceId,
                                         Long subInstanceId)

查询所有Task执行结果，reduce阶段 或 postProcess阶段 使用

getTaskStatus

public Optional<TaskStatus> getTaskStatus(Long instanceId,
                                          String taskId)

查询任务状态（只查询 status，节约 I/O 资源 -> 测试表明，在（我高端的NVMe）SSD上都效果惊人...别说一般的HDD了...磁盘I/O果然是重要瓶颈...）

getTask

public Optional<TaskDO> getTask(Long instanceId,
                                String taskId)

根据主键查询 Task

batchUpdateTaskStatus

public boolean batchUpdateTaskStatus(Long instanceId,
                                     List<String> taskIds,
                                     TaskStatus status,
                                     String result)

批量更新 Task 状态

deleteAllTasks

public boolean deleteAllTasks(Long instanceId)

deleteAllSubInstanceTasks

public boolean deleteAllSubInstanceTasks(Long instanceId,
                                         Long subInstanceId)

listAll

public List<TaskDO> listAll()