com.alibaba.schedulerx.worker.master.persistence

类 ServerTaskPersistence

java.lang.Object

com.alibaba.schedulerx.worker.master.persistence.ServerTaskPersistence

所有已实现的接口:

TaskPersistence

public class ServerTaskPersistence
extends Object
implements TaskPersistence

作者:

xiaomeng.hxm

构造器概要

构造器

构造器和说明
ServerTaskPersistence(String groupId)

方法概要

限定符和类型	方法和说明
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) do nothing, already create by server.
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

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

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

构造器详细资料

ServerTaskPersistence

public ServerTaskPersistence(String groupId)

方法详细资料

updateTaskStatus

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

从接口复制的说明: TaskPersistence

update tasksk status and worker info

指定者:

updateTaskStatus 在接口中 TaskPersistence

抛出:

Exception

updateTaskStatues

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

从接口复制的说明: TaskPersistence

update task statues accord to list of TaskStatusInfo

指定者:

updateTaskStatues 在接口中 TaskPersistence

参数:

taskStatusInfos - list of task status

抛出:

Exception

clearTasks

public void clearTasks(long jobInstanceId)
                throws Exception

从接口复制的说明: TaskPersistence

clear all tasks belong to specific job instance

指定者:

clearTasks 在接口中 TaskPersistence

抛出:

Exception

createTask

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

do nothing, already create by server.

指定者:

createTask 在接口中 TaskPersistence

参数:

jobId -

jobInstanceId -

taskId -

taskName -

taskBody -

抛出:

Exception

createTasks

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

从接口复制的说明: TaskPersistence

batch create container infos

指定者:

createTasks 在接口中 TaskPersistence

参数:

containers - infos of container

抛出:

Exception

pull

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

从接口复制的说明: TaskPersistence

pull init tasks for failover retry

指定者:

pull 在接口中 TaskPersistence

返回:

抛出:

Exception

checkInstanceStatus

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

从接口复制的说明: TaskPersistence

check job instance current status

指定者:

checkInstanceStatus 在接口中 TaskPersistence

返回:

抛出:

Exception

initTable

public void initTable()
               throws Exception

从接口复制的说明: TaskPersistence

init task table;

指定者:

initTable 在接口中 TaskPersistence

抛出:

Exception

batchUpdateTaskStatus

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

从接口复制的说明: TaskPersistence

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

指定者:

batchUpdateTaskStatus 在接口中 TaskPersistence

参数:

jobInstanceId - tasks jobInstanceId

status - status to be update

workerId - tasks workerId

workerAddr - tasks workerAddr