com.alibaba.schedulerx.worker.master.persistence

类 TaskDao

java.lang.Object

com.alibaba.schedulerx.worker.master.persistence.TaskDao

public class TaskDao
extends Object

作者:

xiaomeng.hxm

构造器概要

构造器

构造器和说明
TaskDao(H2ConnectionPool h2CP)

方法概要

限定符和类型	方法和说明
int	batchDeleteTasks(long jobInstanceId, List<Long> taskIds)
int	batchInsert(List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest> containers, String workerId, String workerAddr)
int	batchUpdateStatus(long jobInstanceId, int status, String workerId, String workerAddr)
int	batchUpdateStatus(long jobInstanceId, List<Long> taskIdList, int status)
void	createTable()
int	deleteByJobInstanceId(long jobInstanceId)
void	dropTable()
boolean	exist(long jobInstanceId) whether exist at least 1 record with 'job_instance_id' = jobInstance.
List<Long>	getDistinctInstanceIds()
TaskStatistics	getTaskStatistics()
int	insert(long jobId, long jobInstanceId, long taskId, String taskName, com.google.protobuf.ByteString taskBody)
List<Integer>	queryStatus(long jobInstanceId)
long	queryTaskCount(long jobInstanceId)
List<TaskSnapshot>	queryTaskList(long jobInstanceId, int status, int pageSize)
int	updateStatus(long jobInstanceId, List<Long> taskIds, int status, String workerId, String workerAddr)
int	updateStatus(long jobInstanceId, long taskId, int status, String workerAddr)
int	updateWorker(long jobInstanceId, long taskId, String workerId, String workerAddr)

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

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

构造器详细资料

TaskDao

public TaskDao(H2ConnectionPool h2CP)

方法详细资料

dropTable

public void dropTable()
               throws Exception

抛出:

Exception

createTable

public void createTable()
                 throws Exception

抛出:

Exception

insert

public int insert(long jobId,
                  long jobInstanceId,
                  long taskId,
                  String taskName,
                  com.google.protobuf.ByteString taskBody)
           throws SQLException

抛出:

SQLException

batchInsert

public int batchInsert(List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest> containers,
                       String workerId,
                       String workerAddr)
                throws SQLException

抛出:

SQLException

getTaskStatistics

public TaskStatistics getTaskStatistics()
                                 throws SQLException

抛出:

SQLException

updateStatus

public int updateStatus(long jobInstanceId,
                        long taskId,
                        int status,
                        String workerAddr)
                 throws SQLException

抛出:

SQLException

updateStatus

public int updateStatus(long jobInstanceId,
                        List<Long> taskIds,
                        int status,
                        String workerId,
                        String workerAddr)
                 throws SQLException

抛出:

SQLException

batchUpdateStatus

public int batchUpdateStatus(long jobInstanceId,
                             List<Long> taskIdList,
                             int status)
                      throws SQLException

抛出:

SQLException

getDistinctInstanceIds

public List<Long> getDistinctInstanceIds()
                                  throws SQLException

抛出:

SQLException

batchUpdateStatus

public int batchUpdateStatus(long jobInstanceId,
                             int status,
                             String workerId,
                             String workerAddr)
                      throws SQLException

抛出:

SQLException

updateWorker

public int updateWorker(long jobInstanceId,
                        long taskId,
                        String workerId,
                        String workerAddr)
                 throws SQLException

抛出:

SQLException

queryTaskList

public List<TaskSnapshot> queryTaskList(long jobInstanceId,
                                        int status,
                                        int pageSize)
                                 throws SQLException

抛出:

SQLException

queryStatus

public List<Integer> queryStatus(long jobInstanceId)
                          throws SQLException

抛出:

SQLException

queryTaskCount

public long queryTaskCount(long jobInstanceId)
                    throws SQLException

抛出:

SQLException

exist

public boolean exist(long jobInstanceId)
              throws SQLException

whether exist at least 1 record with 'job_instance_id' = jobInstance.

参数:

jobInstanceId -

返回:

true if exist, otherwise false

抛出:

SQLException

deleteByJobInstanceId

public int deleteByJobInstanceId(long jobInstanceId)
                          throws SQLException

抛出:

SQLException

batchDeleteTasks

public int batchDeleteTasks(long jobInstanceId,
                            List<Long> taskIds)
                     throws SQLException

抛出:

SQLException