com.alibaba.schedulerx.worker.master.persistence

类 H2Persistence

java.lang.Object

com.alibaba.schedulerx.worker.master.persistence.H2Persistence

所有已实现的接口:

TaskPersistence

直接已知子类:

H2FilePersistence, H2MemoryPersistence

public abstract class H2Persistence
extends Object
implements TaskPersistence

H2Persistence是单例模式，只在第一次初始化的时候执行initTable

作者:

xiaomeng.hxm

字段概要

字段

限定符和类型	字段和说明
protected H2ConnectionPool	h2CP
protected TaskDao	taskDao

构造器概要

构造器

构造器和说明
H2Persistence()

方法概要

限定符和类型	方法和说明
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
List<Long>	getDistinctInstanceIds() 获取h2中存留的结束但是未删除的实例
TaskStatistics	getTaskStatistics() 获取h2 task汇总统计
void	initTable() init task table;
boolean	isInited()
List<TaskInfo>	pull(long jobInstanceId, int pageSize) pull init tasks for failover retry
void	updateTaskStatues(List<com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest> taskStatusInfos) !!!
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

字段详细资料

h2CP

protected H2ConnectionPool h2CP

taskDao

protected TaskDao taskDao

构造器详细资料

H2Persistence

public H2Persistence()

方法详细资料

initTable

public void initTable()
               throws Exception

从接口复制的说明: TaskPersistence

init task table;

指定者:

initTable 在接口中 TaskPersistence

抛出:

Exception

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

!!!Attention!!! For Grid/Batch tasks, this method invoked only when finish statuses updated. In order to reduce h2 size, this method will delete all finish tasks;

指定者:

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

从接口复制的说明: TaskPersistence

create task

指定者:

createTask 在接口中 TaskPersistence

抛出:

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

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

getTaskStatistics

public TaskStatistics getTaskStatistics()
                                 throws Exception

获取h2 task汇总统计

返回:

抛出:

Exception

getDistinctInstanceIds

public List<Long> getDistinctInstanceIds()
                                  throws Exception

获取h2中存留的结束但是未删除的实例

返回:

抛出:

Exception

isInited

public boolean isInited()