xin.bluesky.leiothrix.server.storage

类 TaskStorage

java.lang.Object

xin.bluesky.leiothrix.server.storage.TaskStorage

public class TaskStorage
extends Object

作者:

张轲

字段概要

字段

限定符和类型	字段和说明
static String	NAME_CONFIG_FILE
static String	NAME_JAR
static String	NAME_MAIN_CLASS
static String	NAME_RESOURCE_ENOUGH
static String	NAME_STATISTICS
static String	NAME_STATISTICS_TASK_FINISHED_TIME
static String	NAME_STATISTICS_TASK_START_TIME
static String	NAME_STATUS
static String	NAME_WORKERS
static String	NAME_WORKERS_PROCESSOR_FINISHED_TIME
static String	NAME_WORKERS_PROCESSOR_START_TIME
static String	TASKS

构造器概要

构造器

构造器和说明
TaskStorage()

方法概要

限定符和类型	方法和说明
static void	addWorkerProcessor(String taskId, String workerIp, String processorId, Date time) 给task记录处理其的worker进程及相关信息
static void	cancel(String taskId) 取消任务.
static void	createEmptyTask(String taskId) 创建一个空任务,只包含taskId节点和状态节点
static void	createEmptyTask(String taskId, TaskStatus status)
static void	delete(String taskId) 删除Task
static void	finishedWorkerProcessor(String taskId, String workerIp, String processorId, Date time) 给task记录处理其的worker进程的结束记录
static List<String>	getAllFinishedTasks() 获得所有已结束的任务
static List<String>	getAllProcessingTasks() 获得所有当前正在处理中的任务
static List<String>	getAllTasks() 获得所有Task
static List<String>	getAllTaskWorkers(String taskId)
static String	getOldestProcessingTask() 获得最老的Task(执行完的task除外)
static TaskStatus	getStatus(String taskId) 获得Task的当前状态
static TaskConfig	getTaskConfig(String taskId) 获得Task的config信息
static long	getTaskFinishedTime(String taskId)
static TaskStaticInfo	getTaskStaticInfo(String taskId)
static String	getUnallocatedTask() 获得未被分配执行的任务
static List<String>	getWorkerProcessor(String taskId, String workerIp)
static String	getWorkerProcessorFinishedTime(String taskId, String workerIp, String processorId)
static String	getWorkerProcessorStartTime(String taskId, String workerIp, String processorId)
static boolean	isResourceEnough(String taskId) 得到该任务的当前运行资源是否足够的值
static void	logTaskFinishedTime(String taskId) 记录任务的结束时间
static void	logTaskStartTime(String taskId) 记录任务的启动时间
static void	setConfig(String taskId, String config) 设置该Task对应的config信息
static void	setJarPath(String taskId, String jarPath) 设置运行该Task对应的jar路径
static void	setMainClass(String taskId, String mainClass) 设置运行该Task的main函数
static void	setResourceEnough(String taskId, boolean b) 设置该任务的当前运行资源是否足够
static void	setStatus(String taskId, TaskStatus status) 设置任务的状态
static boolean	taskExist(String taskId) 判断该task是否存在
static boolean	taskNotExist(String taskId) 判断该task是否不存在

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

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

字段详细资料

TASKS

public static final String TASKS

另请参阅:

常量字段值

NAME_JAR

public static final String NAME_JAR

另请参阅:

常量字段值

NAME_CONFIG_FILE

public static final String NAME_CONFIG_FILE

另请参阅:

常量字段值

NAME_MAIN_CLASS

public static final String NAME_MAIN_CLASS

另请参阅:

常量字段值

NAME_STATUS

public static final String NAME_STATUS

另请参阅:

常量字段值

NAME_RESOURCE_ENOUGH

public static final String NAME_RESOURCE_ENOUGH

另请参阅:

常量字段值

NAME_WORKERS

public static final String NAME_WORKERS

另请参阅:

常量字段值

NAME_WORKERS_PROCESSOR_START_TIME

public static final String NAME_WORKERS_PROCESSOR_START_TIME

另请参阅:

常量字段值

NAME_WORKERS_PROCESSOR_FINISHED_TIME

public static final String NAME_WORKERS_PROCESSOR_FINISHED_TIME

另请参阅:

常量字段值

NAME_STATISTICS

public static final String NAME_STATISTICS

另请参阅:

常量字段值

NAME_STATISTICS_TASK_START_TIME

public static final String NAME_STATISTICS_TASK_START_TIME

另请参阅:

常量字段值

NAME_STATISTICS_TASK_FINISHED_TIME

public static final String NAME_STATISTICS_TASK_FINISHED_TIME

另请参阅:

常量字段值

构造器详细资料

TaskStorage

public TaskStorage()

方法详细资料

createEmptyTask

public static void createEmptyTask(String taskId)

创建一个空任务,只包含taskId节点和状态节点

参数:

taskId - taskId

createEmptyTask

public static void createEmptyTask(String taskId,
                                   TaskStatus status)

getTaskConfig

public static TaskConfig getTaskConfig(String taskId)

获得Task的config信息

参数:

taskId - taskId

返回:

TaskConfig object

getAllTasks

public static List<String> getAllTasks()

获得所有Task

返回:

all tasks

getAllProcessingTasks

public static List<String> getAllProcessingTasks()

获得所有当前正在处理中的任务

返回:

all processing tasks

getAllFinishedTasks

public static List<String> getAllFinishedTasks()

获得所有已结束的任务

返回:

all finished tasks

getTaskFinishedTime

public static long getTaskFinishedTime(String taskId)

getOldestProcessingTask

public static String getOldestProcessingTask()

获得最老的Task(执行完的task除外)

返回:

如不存在, 则返回null

getUnallocatedTask

public static String getUnallocatedTask()

获得未被分配执行的任务

返回:

如果不存在, 则返回null

taskExist

public static boolean taskExist(String taskId)

判断该task是否存在

参数:

taskId - taskId

返回:

true if the task exist,else return false

taskNotExist

public static boolean taskNotExist(String taskId)

判断该task是否不存在

参数:

taskId - taskId

返回:

true if the task not exist,else return false

getTaskStaticInfo

public static TaskStaticInfo getTaskStaticInfo(String taskId)

delete

public static void delete(String taskId)

删除Task

参数:

taskId - taskId

getStatus

public static TaskStatus getStatus(String taskId)

获得Task的当前状态

参数:

taskId - taskId

返回:

task status

setJarPath

public static void setJarPath(String taskId,
                              String jarPath)

设置运行该Task对应的jar路径

参数:

taskId - taskId

jarPath - the jar path of this task

setConfig

public static void setConfig(String taskId,
                             String config)

设置该Task对应的config信息

参数:

taskId - taskId

config - the config body

setMainClass

public static void setMainClass(String taskId,
                                String mainClass)

设置运行该Task的main函数

参数:

taskId - taskId

mainClass - the main class absolute name

setStatus

public static void setStatus(String taskId,
                             TaskStatus status)

设置任务的状态

参数:

taskId - taskId

status - task status

cancel

public static void cancel(String taskId)

取消任务.

参数:

taskId - taskId

isResourceEnough

public static boolean isResourceEnough(String taskId)

得到该任务的当前运行资源是否足够的值

参数:

taskId - taskId

返回:

true if the resource allocated for this task is enough,else return false

setResourceEnough

public static void setResourceEnough(String taskId,
                                     boolean b)

设置该任务的当前运行资源是否足够

参数:

taskId - taskId

b - enough or not

addWorkerProcessor

public static void addWorkerProcessor(String taskId,
                                      String workerIp,
                                      String processorId,
                                      Date time)

给task记录处理其的worker进程及相关信息

参数:

taskId - taskId

workerIp - worker ip

processorId - processor id

time - add time

finishedWorkerProcessor

public static void finishedWorkerProcessor(String taskId,
                                           String workerIp,
                                           String processorId,
                                           Date time)

给task记录处理其的worker进程的结束记录

参数:

taskId - taskId

workerIp - worker ip

processorId - processor id

time - finished time

getAllTaskWorkers

public static List<String> getAllTaskWorkers(String taskId)

getWorkerProcessor

public static List<String> getWorkerProcessor(String taskId,
                                              String workerIp)

getWorkerProcessorStartTime

public static String getWorkerProcessorStartTime(String taskId,
                                                 String workerIp,
                                                 String processorId)

getWorkerProcessorFinishedTime

public static String getWorkerProcessorFinishedTime(String taskId,
                                                    String workerIp,
                                                    String processorId)

logTaskStartTime

public static void logTaskStartTime(String taskId)

记录任务的启动时间

参数:

taskId - taskId

logTaskFinishedTime

public static void logTaskFinishedTime(String taskId)

记录任务的结束时间

参数:

taskId - taskId