核心
调度中心 powerjob-server
执行器 powerjob-worker
处理器 processor 不同类型任务(shell、sql、httpClient)处理器
核心概念
分组:业务分组与隔离 类似租户
任务(Job):描述了需要被 PowerJob 调度的任务信息,包括任务名称、调度时间、处理器信息等。
任务实例( JobInstance,简称 Instance):任务(Job)被调度执行后会生成任务实例(Instance),任务实例记录了任务的运行时信息(任务与任务实例的关系类似于类与对象的关系)。
作业(Task):任务实例的执行单元,一个 JobInstance 存在至少一个 Task,具体规则如下:
单机任务(STANDALONE):一个 JobInstance 对应一个 Task
广播任务(BROADCAST):一个 JobInstance 对应 N 个 Task,N为集群机器数量,即每一台机器都会生成一个 Task
Map/MapReduce任务:一个 JobInstance 对应若干个 Task,由开发者手动 map 产生
工作流(Workflow):由 DAG(有向无环图)描述的一组任务(Job),用于任务编排。
工作流实例(WorkflowInstance):工作流被调度执行后会生成工作流实例,记录了工作流的运行时信息。