com.alibaba.schedulerx.worker.master.persistence

接口 TaskPersistence

所有已知实现类:

H2FilePersistence, H2MemoryPersistence, H2Persistence, ServerTaskPersistence

public interface TaskPersistence

作者:

xiaomeng.hxm

方法概要

限定符和类型	方法和说明
int	batchUpdateTaskStatus(long jobInstanceId, com.alibaba.schedulerx.common.domain.TaskStatus status, String workerId, String workerAddr) update tasks status using condition {jobInstanceId, workerId, workerAddr}
com.alibaba.schedulerx.common.domain.InstanceStatus	checkInstanceStatus(long jobInstanceId) check job instance current status
void	clearTasks(long jobInstanceId) clear all tasks belong to specific job instance
void	createTask(long jobId, long jobInstanceId, long taskId, String taskName, com.google.protobuf.ByteString taskBody) create task
void	createTasks(List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest> containers, String workerId, String workerAddr) batch create container infos
void	initTable() init task table;
List<TaskInfo>	pull(long jobInstanceId, int pageSize) pull init tasks for failover retry
void	updateTaskStatues(List<com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest> taskStatusInfos) update task statues accord to list of TaskStatusInfo
int	updateTaskStatus(long jobInstanceId, List<Long> taskIds, com.alibaba.schedulerx.common.domain.TaskStatus status, String workerId, String workerAddr) update tasksk status and worker info

方法详细资料

initTable

void initTable()
        throws Exception

init task table;

抛出:

Exception

updateTaskStatus

int updateTaskStatus(long jobInstanceId,
                     List<Long> taskIds,
                     com.alibaba.schedulerx.common.domain.TaskStatus status,
                     String workerId,
                     String workerAddr)
              throws Exception

update tasksk status and worker info

参数:

jobInstanceId -

taskIds -

status -

workerId -

workerAddr -

抛出:

Exception

updateTaskStatues

void updateTaskStatues(List<com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest> taskStatusInfos)
                throws Exception

update task statues accord to list of TaskStatusInfo

参数:

taskStatusInfos - list of task status

抛出:

Exception

clearTasks

void clearTasks(long jobInstanceId)
         throws Exception

clear all tasks belong to specific job instance

参数:

jobInstanceId -

抛出:

Exception

createTask

void createTask(long jobId,
                long jobInstanceId,
                long taskId,
                String taskName,
                com.google.protobuf.ByteString taskBody)
         throws Exception

create task

参数:

jobId -

jobInstanceId -

taskId -

taskName -

taskBody -

抛出:

Exception

createTasks

void createTasks(List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest> containers,
                 String workerId,
                 String workerAddr)
          throws Exception

batch create container infos

参数:

containers - infos of container

抛出:

Exception

pull

List<TaskInfo> pull(long jobInstanceId,
                    int pageSize)
             throws Exception

pull init tasks for failover retry

参数:

jobInstanceId -

pageSize -

返回:

抛出:

Exception

checkInstanceStatus

com.alibaba.schedulerx.common.domain.InstanceStatus checkInstanceStatus(long jobInstanceId)
                                                                 throws Exception

check job instance current status

参数:

jobInstanceId -

返回:

抛出:

Exception

batchUpdateTaskStatus

int batchUpdateTaskStatus(long jobInstanceId,
                          com.alibaba.schedulerx.common.domain.TaskStatus status,
                          String workerId,
                          String workerAddr)

update tasks status using condition {jobInstanceId, workerId, workerAddr}

参数:

jobInstanceId - tasks jobInstanceId

status - status to be update

workerId - tasks workerId

workerAddr - tasks workerAddr