索引 (powerjob-worker 3.2.3 API)

A B C D E F G I L M O P R S T U V W

A

actorSystem - 类中的静态变量com.github.kfcfans.powerjob.worker.OhMyWorker
afterPropertiesSet() - 类中的方法com.github.kfcfans.powerjob.worker.OhMyWorker
AkkaUtils - com.github.kfcfans.powerjob.worker.common.utils中的类: AKKA 工具类
AkkaUtils() - 类的构造器com.github.kfcfans.powerjob.worker.common.utils.AkkaUtils
atomicCreateTaskTracker(Long, Function<Long, TaskTracker>) - 类中的静态方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTrackerPool
available() - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatus: 是否可用

B

BasicProcessor - com.github.kfcfans.powerjob.worker.core.processor.sdk中的接口: 基础的处理器，适用于单机执行
batchSave(Collection<TaskDO>) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO
batchSave(Collection<TaskDO>) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
batchSave(List<TaskDO>) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
batchUpdateTaskStatus(Long, List<String>, TaskStatus, String) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 批量更新 Task 状态
broadcast(boolean, long, String, String) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 生成广播任务
BROADCAST - 类中的静态变量com.github.kfcfans.powerjob.worker.pojo.request.ProcessorReportTaskStatusReq
BROADCAST_TASK_NAME - 类中的静态变量com.github.kfcfans.powerjob.worker.common.constants.TaskConstant: 广播执行任务的名称
BroadcastProcessor - com.github.kfcfans.powerjob.worker.core.processor.sdk中的类: 广播执行处理器，适用于广播执行
BroadcastProcessor() - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.sdk.BroadcastProcessor
buildIdleReport(Long) - 类中的静态方法com.github.kfcfans.powerjob.worker.pojo.request.ProcessorTrackerStatusReportReq
buildLoadReport(Long, Long) - 类中的静态方法com.github.kfcfans.powerjob.worker.pojo.request.ProcessorTrackerStatusReportReq

C

clear() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.ThreadLocalStore
com.github.kfcfans.powerjob.worker - 程序包 com.github.kfcfans.powerjob.worker
com.github.kfcfans.powerjob.worker.actors - 程序包 com.github.kfcfans.powerjob.worker.actors
com.github.kfcfans.powerjob.worker.background - 程序包 com.github.kfcfans.powerjob.worker.background
com.github.kfcfans.powerjob.worker.common - 程序包 com.github.kfcfans.powerjob.worker.common
com.github.kfcfans.powerjob.worker.common.constants - 程序包 com.github.kfcfans.powerjob.worker.common.constants
com.github.kfcfans.powerjob.worker.common.utils - 程序包 com.github.kfcfans.powerjob.worker.common.utils
com.github.kfcfans.powerjob.worker.container - 程序包 com.github.kfcfans.powerjob.worker.container
com.github.kfcfans.powerjob.worker.core - 程序包 com.github.kfcfans.powerjob.worker.core
com.github.kfcfans.powerjob.worker.core.executor - 程序包 com.github.kfcfans.powerjob.worker.core.executor
com.github.kfcfans.powerjob.worker.core.ha - 程序包 com.github.kfcfans.powerjob.worker.core.ha
com.github.kfcfans.powerjob.worker.core.processor - 程序包 com.github.kfcfans.powerjob.worker.core.processor
com.github.kfcfans.powerjob.worker.core.processor.built - 程序包 com.github.kfcfans.powerjob.worker.core.processor.built
com.github.kfcfans.powerjob.worker.core.processor.sdk - 程序包 com.github.kfcfans.powerjob.worker.core.processor.sdk
com.github.kfcfans.powerjob.worker.core.tracker.processor - 程序包 com.github.kfcfans.powerjob.worker.core.tracker.processor
com.github.kfcfans.powerjob.worker.core.tracker.task - 程序包 com.github.kfcfans.powerjob.worker.core.tracker.task
com.github.kfcfans.powerjob.worker.log - 程序包 com.github.kfcfans.powerjob.worker.log
com.github.kfcfans.powerjob.worker.log.impl - 程序包 com.github.kfcfans.powerjob.worker.log.impl
com.github.kfcfans.powerjob.worker.persistence - 程序包 com.github.kfcfans.powerjob.worker.persistence
com.github.kfcfans.powerjob.worker.pojo.model - 程序包 com.github.kfcfans.powerjob.worker.pojo.model
com.github.kfcfans.powerjob.worker.pojo.request - 程序包 com.github.kfcfans.powerjob.worker.pojo.request
CommonTaskTracker - com.github.kfcfans.powerjob.worker.core.tracker.task中的类: 负责管理 JobInstance 的运行，主要包括任务的派发（MR可能存在大量的任务）和状态的更新
CommonTaskTracker(ServerScheduleJobReq) - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.task.CommonTaskTracker
ConnectionFactory - com.github.kfcfans.powerjob.worker.persistence中的类: 数据库连接管理
ConnectionFactory() - 类的构造器com.github.kfcfans.powerjob.worker.persistence.ConnectionFactory
create(ServerScheduleJobReq) - 类中的静态方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 静态方法创建 TaskTracker
createReceive() - 类中的方法com.github.kfcfans.powerjob.worker.actors.ProcessorTrackerActor
createReceive() - 类中的方法com.github.kfcfans.powerjob.worker.actors.TaskTrackerActor
createReceive() - 类中的方法com.github.kfcfans.powerjob.worker.actors.TroubleshootingActor
createReceive() - 类中的方法com.github.kfcfans.powerjob.worker.actors.WorkerActor
createTime - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker

D

debug(String, Object...) - 类中的方法com.github.kfcfans.powerjob.worker.log.impl.OmsServerLogger
debug(String, Object...) - 接口中的方法com.github.kfcfans.powerjob.worker.log.OmsLogger: 输出 DEBUG 类型的日志，与 Slf4j 用法一致
defaultResult(List<TaskResult>) - 类中的静态方法com.github.kfcfans.powerjob.worker.core.processor.sdk.BroadcastProcessor
deleteAllSubInstanceTasks(Long, Long) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
deleteAllTasks(Long) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
deployContainer(ServerDeployContainerRequest) - 类中的静态方法com.github.kfcfans.powerjob.worker.container.OmsContainerFactory: 部署容器，整个过程串行进行，问题不大
deSerialized(byte[]) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.SerializerUtils
destroy() - 接口中的方法com.github.kfcfans.powerjob.worker.container.LifeCycle: 销毁
destroy() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer
destroy() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.processor.ProcessorTracker: 释放资源
destroy() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 销毁自身，释放资源
destroy() - 类中的方法com.github.kfcfans.powerjob.worker.OhMyWorker
destroyContainer(Long) - 类中的静态方法com.github.kfcfans.powerjob.worker.container.OmsContainerFactory: 销毁指定容器
discovery() - 类中的静态方法com.github.kfcfans.powerjob.worker.background.ServerDiscoveryService
Dispatcher() - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.Dispatcher
dispatchTask(TaskDO, String) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 派发任务到 ProcessorTracker

E

error(String, Object...) - 类中的方法com.github.kfcfans.powerjob.worker.log.impl.OmsServerLogger
error(String, Object...) - 接口中的方法com.github.kfcfans.powerjob.worker.log.OmsLogger: 输出 ERROR 类型的日志，与 Slf4j 用法一致

F

failedNum - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder
fetchContainer(Long, boolean) - 类中的静态方法com.github.kfcfans.powerjob.worker.container.OmsContainerFactory: 获取容器
fetchRunCommand() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.built.PythonProcessor
fetchRunCommand() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.built.ScriptProcessor: 获取运行命令（eg，shell返回 /bin/sh）
fetchRunCommand() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.built.ShellProcessor
fetchRunningStatus() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.CommonTaskTracker
fetchRunningStatus() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.FrequentTaskTracker
fetchRunningStatus() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 查询任务实例的详细运行状态
fetchUpstreamTaskResult() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.TaskContext: 获取工作流上游任务传递的数据（仅该任务实例由工作流触发时存在）
finished - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker
finishedStatus - 枚举中的静态变量com.github.kfcfans.powerjob.worker.common.constants.TaskStatus
forEach(BiConsumer<? super K, ? super V>) - 类中的方法com.github.kfcfans.powerjob.worker.common.utils.LRUCache
FrequentTaskTracker - com.github.kfcfans.powerjob.worker.core.tracker.task中的类: 处理秒级任务（FIX_RATE/FIX_DELAY）的TaskTracker FIX_RATE 直接由 ScheduledExecutorService 实现，精度高，推荐使用 FIX_DELAY 会有几秒的延迟，精度不是很理想
FrequentTaskTracker(ServerScheduleJobReq) - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.task.FrequentTaskTracker

G

genScriptName() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.built.PythonProcessor
genScriptName() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.built.ScriptProcessor: 生成脚本名称
genScriptName() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.built.ShellProcessor
get(K) - 类中的方法com.github.kfcfans.powerjob.worker.common.utils.LRUCache
getAkkaServerPath(String) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.AkkaUtils
getAkkaWorkerPath(String, String) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.AkkaUtils
getAllDisconnectedProcessorTrackers() - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatusHolder: 获取所有失联 ProcessorTracker 的IP地址
getAllFrequentTaskTrackerKeys() - 类中的静态方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTrackerPool
getAllProcessorTrackers() - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatusHolder: 获取所有 ProcessorTracker 的IP地址（包括不可用状态）
getAllTask(Long, Long) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
getAllTaskResult(Long, Long) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO: 查询所有子任务的执行结果 (为了性能特殊定制，主要是内存占用，如果使用 simpleQueryPlus，内存中需要同时存在3份数据？
getAllTaskResult(Long, Long) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
getAllTaskResult(Long, Long) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 查询所有Task执行结果，reduce阶段或 postProcess阶段使用
getAllUnFinishedTaskByAddress(Long, String) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
getAvailableProcessorTrackers() - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatusHolder: 获取可用 ProcessorTracker 的IP地址
getBean(Class<T>) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.SpringUtils
getBean(String) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.SpringUtils
getConnection() - 类中的静态方法com.github.kfcfans.powerjob.worker.persistence.ConnectionFactory
getContainerClassLoader() - 接口中的方法com.github.kfcfans.powerjob.worker.container.OmsContainer: 获取容器的类加载器
getContainerClassLoader() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer
getContainerDir() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.OmsWorkerFileUtils
getContainerId() - 接口中的方法com.github.kfcfans.powerjob.worker.container.OmsContainer
getContainerId() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer
getDeployedContainerInfos() - 类中的静态方法com.github.kfcfans.powerjob.worker.container.OmsContainerFactory: 获取该Worker已部署容器的信息
getDeployedTime() - 接口中的方法com.github.kfcfans.powerjob.worker.container.OmsContainer
getDeployedTime() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer
getH2WorkDir() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.OmsWorkerFileUtils
getInstance() - 类中的静态方法com.github.kfcfans.powerjob.worker.core.ProcessorBeanFactory
getInstanceStatisticsHolder(long) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 获取任务实例产生的各个Task状态，用于分析任务实例执行情况
getLastTask(Long, Long) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 获取 MapReduce 或 Broadcast 的最后一个任务
getLocalProcessor(String) - 类中的方法com.github.kfcfans.powerjob.worker.core.ProcessorBeanFactory
getName() - 接口中的方法com.github.kfcfans.powerjob.worker.container.OmsContainer
getName() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer
getProcessor(String) - 接口中的方法com.github.kfcfans.powerjob.worker.container.OmsContainer: 获取处理器
getProcessor(String) - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer
getProcessorTracker(Long, String, Supplier<ProcessorTracker>) - 类中的静态方法com.github.kfcfans.powerjob.worker.core.tracker.processor.ProcessorTrackerPool: 获取 ProcessorTracker，如果不存在则创建
getProcessorTrackerStatus(String) - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatusHolder
getQueryCondition() - 类中的方法com.github.kfcfans.powerjob.worker.persistence.SimpleTaskQuery
getScriptDir() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.OmsWorkerFileUtils
getSystemMetrics() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.SystemInfoUtils
getTask() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.ThreadLocalStore
getTask(Long, String) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 根据主键查询 Task
getTaskByStatus(Long, TaskStatus, int) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 获取指定状态的Task
getTaskIDAddr() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.ThreadLocalStore
getTaskStatus(Long, String) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 查询任务状态（只查询 status，节约 I/O 资源 -> 测试表明，在（我高端的NVMe）SSD上都效果惊人...别说一般的HDD了...磁盘I/O果然是重要瓶颈...）
getTaskStatusStatistics(Long, Long) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 获取 TaskTracker 管理的子 task 状态统计信息 TaskStatus -> num
getTaskTrackerPool(Long) - 类中的静态方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTrackerPool: 获取 TaskTracker
getTotalTaskNum() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder
getUpdateSQL() - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDO
getVersion() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.OmsWorkerVersion: Return the full version string of the present OhMyScheduler-Worker codebase, or null if it cannot be determined.
getVersion() - 接口中的方法com.github.kfcfans.powerjob.worker.container.OmsContainer
getVersion() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer

I

IDLE - 类中的静态变量com.github.kfcfans.powerjob.worker.pojo.request.ProcessorTrackerStatusReportReq
info(String, Object...) - 类中的方法com.github.kfcfans.powerjob.worker.log.impl.OmsServerLogger
info(String, Object...) - 接口中的方法com.github.kfcfans.powerjob.worker.log.OmsLogger: 输出 INFO 类型的日志，与 Slf4j 用法一致
init() - 接口中的方法com.github.kfcfans.powerjob.worker.container.LifeCycle: 初始化
init() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer
init(String) - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatus: 初始化 ProcessorTracker，此时并未持有实际的 ProcessorTracker 状态
init() - 类中的方法com.github.kfcfans.powerjob.worker.OhMyWorker
init() - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
initTable() - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO: 初始化任务表
initTable() - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
initTaskTracker(ServerScheduleJobReq) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.CommonTaskTracker
initTaskTracker(ServerScheduleJobReq) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.FrequentTaskTracker
initTaskTracker(ServerScheduleJobReq) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 初始化 TaskTracker
inject(ApplicationContext) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.SpringUtils
innerRun() - 类中的方法com.github.kfcfans.powerjob.worker.core.executor.ProcessorRunnable
INSTANCE - 类中的静态变量com.github.kfcfans.powerjob.worker.background.OmsLogHandler
INSTANCE - 类中的静态变量com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
instanceId - 类中的变量com.github.kfcfans.powerjob.worker.core.processor.built.ScriptProcessor
instanceId - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker
instanceInfo - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker
InstanceInfo - com.github.kfcfans.powerjob.worker.pojo.model中的类: 被调度执行的任务实例详情
InstanceInfo() - 类的构造器com.github.kfcfans.powerjob.worker.pojo.model.InstanceInfo
InstanceStatisticsHolder() - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder
isRootTask() - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.sdk.MapProcessor: 是否为根任务
isTimeout() - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatus: 是否超时（超过一定时间没有收到心跳）
isTimeout() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.CommonTaskTracker: 任务是否超时

L

LAST_TASK_ID - 类中的静态变量com.github.kfcfans.powerjob.worker.common.constants.TaskConstant
LAST_TASK_NAME - 类中的静态变量com.github.kfcfans.powerjob.worker.common.constants.TaskConstant: 终极任务的名称（MapReduce的reduceTask和Broadcast的postProcess会有该任务）
LifeCycle - com.github.kfcfans.powerjob.worker.container中的接口: 生命周期
listAll() - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
load(String) - 类中的方法com.github.kfcfans.powerjob.worker.container.OhMyClassLoader: 主动加载类，否则类加载器内空空如也，Spring IOC容器初始化不到任何东西
LOAD - 类中的静态变量com.github.kfcfans.powerjob.worker.pojo.request.ProcessorTrackerStatusReportReq
logSubmitter - 类中的变量com.github.kfcfans.powerjob.worker.background.OmsLogHandler
LRUCache<K,V> - com.github.kfcfans.powerjob.worker.common.utils中的类: LRU（Least Recently Used）缓存 before v3.1.1 使用 LinkedHashMap，但存在修改时访问报错问题，改用 Guava
LRUCache(int) - 类的构造器com.github.kfcfans.powerjob.worker.common.utils.LRUCache

M

map(List<?>, String) - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.sdk.MapProcessor: 分发子任务
MapProcessor - com.github.kfcfans.powerjob.worker.core.processor.sdk中的类: Map 处理器，允许开发者自定义拆分任务进行分布式执行
MapProcessor() - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.sdk.MapProcessor
MapReduceProcessor - com.github.kfcfans.powerjob.worker.core.processor.sdk中的类: MapReduce执行处理器，适用于MapReduce任务在 MapProcessor 的基础上添加了结果汇集（reduce）的方法
MapReduceProcessor() - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.sdk.MapReduceProcessor

O

of(int) - 枚举中的静态方法com.github.kfcfans.powerjob.worker.common.constants.TaskStatus
OhMyClassLoader - com.github.kfcfans.powerjob.worker.container中的类: 类加载器未破坏双亲委派模型，可能带来相同类ClassNotFoundException的后果（比如不同版本互不兼容的工具类）为什么不破坏？
OhMyClassLoader(URL[], ClassLoader) - 类的构造器com.github.kfcfans.powerjob.worker.container.OhMyClassLoader
OhMyConfig - com.github.kfcfans.powerjob.worker.common中的类: Worker 配置文件
OhMyConfig() - 类的构造器com.github.kfcfans.powerjob.worker.common.OhMyConfig
OhMyWorker - com.github.kfcfans.powerjob.worker中的类: 客户端启动类
OhMyWorker() - 类的构造器com.github.kfcfans.powerjob.worker.OhMyWorker
OmsBannerPrinter - com.github.kfcfans.powerjob.worker.common中的类: 打印启动 Banner
OmsBannerPrinter() - 类的构造器com.github.kfcfans.powerjob.worker.common.OmsBannerPrinter
OmsContainer - com.github.kfcfans.powerjob.worker.container中的接口: OhMyScheduler 容器规范
OmsContainerFactory - com.github.kfcfans.powerjob.worker.container中的类: 容器工厂
OmsContainerFactory() - 类的构造器com.github.kfcfans.powerjob.worker.container.OmsContainerFactory
OmsJarContainer - com.github.kfcfans.powerjob.worker.container中的类: OMS 容器实现
OmsJarContainer(Long, String, String, File) - 类的构造器com.github.kfcfans.powerjob.worker.container.OmsJarContainer
OmsLogger - com.github.kfcfans.powerjob.worker.log中的接口: OhMyScheduler 在线日志，直接上报到 Server，可在控制台直接查看
OmsLogHandler - com.github.kfcfans.powerjob.worker.background中的类: 日志处理器
OmsServerLogger - com.github.kfcfans.powerjob.worker.log.impl中的类: OhMyScheduler 在线日志，直接上报到 Server，可在控制台直接查看
OmsServerLogger() - 类的构造器com.github.kfcfans.powerjob.worker.log.impl.OmsServerLogger
OmsWorkerFileUtils - com.github.kfcfans.powerjob.worker.common.utils中的类: 文件工具类
OmsWorkerFileUtils() - 类的构造器com.github.kfcfans.powerjob.worker.common.utils.OmsWorkerFileUtils
OmsWorkerVersion - com.github.kfcfans.powerjob.worker.common中的类: 获取 Worker 版本，便于开发者排查问题
OmsWorkerVersion() - 类的构造器com.github.kfcfans.powerjob.worker.common.OmsWorkerVersion
onReceiveDeadLetter(DeadLetter) - 类中的方法com.github.kfcfans.powerjob.worker.actors.TroubleshootingActor

P

postProcess(TaskContext, List<TaskResult>) - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.sdk.BroadcastProcessor: 在所有节点广播执行完成后执行，只会在一台机器执行一次
preProcess(TaskContext) - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.sdk.BroadcastProcessor: 在所有节点广播执行前执行，只会在一台机器执行一次
print() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.OmsBannerPrinter
process(TaskContext) - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.built.ScriptProcessor
process(TaskContext) - 接口中的方法com.github.kfcfans.powerjob.worker.core.processor.sdk.BasicProcessor: 核心处理逻辑
ProcessorBeanFactory - com.github.kfcfans.powerjob.worker.core中的类: 处理器工厂
ProcessorBeanFactory() - 类的构造器com.github.kfcfans.powerjob.worker.core.ProcessorBeanFactory
ProcessorMapTaskRequest - com.github.kfcfans.powerjob.worker.pojo.request中的类: WorkerMapTaskRequest
ProcessorMapTaskRequest(TaskDO, List<?>, String) - 类的构造器com.github.kfcfans.powerjob.worker.pojo.request.ProcessorMapTaskRequest
ProcessorMapTaskRequest.SubTask - com.github.kfcfans.powerjob.worker.pojo.request中的类
ProcessorReportTaskStatusReq - com.github.kfcfans.powerjob.worker.pojo.request中的类: worker 上报 task 执行情况
ProcessorReportTaskStatusReq() - 类的构造器com.github.kfcfans.powerjob.worker.pojo.request.ProcessorReportTaskStatusReq
ProcessorRunnable - com.github.kfcfans.powerjob.worker.core.executor中的类: Processor 执行器
ProcessorRunnable() - 类的构造器com.github.kfcfans.powerjob.worker.core.executor.ProcessorRunnable
ProcessorTracker - com.github.kfcfans.powerjob.worker.core.tracker.processor中的类: 负责管理 Processor 的执行
ProcessorTracker(TaskTrackerStartTaskReq) - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.processor.ProcessorTracker: 创建 ProcessorTracker（其实就是创建了个执行用的线程池 T_T）
ProcessorTrackerActor - com.github.kfcfans.powerjob.worker.actors中的类: 普通计算节点，处理来自 TaskTracker 的请求
ProcessorTrackerActor() - 类的构造器com.github.kfcfans.powerjob.worker.actors.ProcessorTrackerActor
ProcessorTrackerPool - com.github.kfcfans.powerjob.worker.core.tracker.processor中的类: 持有 Processor 对象 instanceId -> Processor
ProcessorTrackerPool() - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.processor.ProcessorTrackerPool
ProcessorTrackerStatus - com.github.kfcfans.powerjob.worker.core.ha中的类: ProcessorTracker 的状态
ProcessorTrackerStatus() - 类的构造器com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatus
ProcessorTrackerStatusHolder - com.github.kfcfans.powerjob.worker.core.ha中的类: 统一管理 ProcessorTracker 的状态
ProcessorTrackerStatusHolder(List<String>) - 类的构造器com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatusHolder
ProcessorTrackerStatusReportReq - com.github.kfcfans.powerjob.worker.pojo.request中的类: ProcessorTracker 定时向 TaskTracker 上报健康状态
ProcessorTrackerStatusReportReq() - 类的构造器com.github.kfcfans.powerjob.worker.pojo.request.ProcessorTrackerStatusReportReq
ProcessResult - com.github.kfcfans.powerjob.worker.core.processor中的类: processor执行结果
ProcessResult(boolean) - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.ProcessResult
ptStatusHolder - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker
put(K, V) - 类中的方法com.github.kfcfans.powerjob.worker.common.utils.LRUCache
PythonProcessor - com.github.kfcfans.powerjob.worker.core.processor.built中的类: Python 处理器
PythonProcessor(Long, String, long) - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.built.PythonProcessor

R

receivedNum - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder
receiveProcessorTrackerHeartbeat(ProcessorTrackerStatusReportReq) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 处理 ProcessorTracker 的心跳信息
reduce(TaskContext, List<TaskResult>) - 类中的方法com.github.kfcfans.powerjob.worker.core.processor.sdk.MapReduceProcessor: reduce方法将在所有任务结束后调用
ReleaseCheckRunnable - com.github.kfcfans.powerjob.worker.background中的类: 定期检查资源释放情况（长时间未释放的 TaskTracker 和 DB记录）
ReleaseCheckRunnable() - 类的构造器com.github.kfcfans.powerjob.worker.background.ReleaseCheckRunnable
reliableTransmit(ActorSelection, Object) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.AkkaUtils: 可靠传输
remove(Long) - 类中的静态方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTrackerPool
removeProcessorTracker(Long) - 类中的静态方法com.github.kfcfans.powerjob.worker.core.tracker.processor.ProcessorTrackerPool
ROOT_TASK_NAME - 类中的静态变量com.github.kfcfans.powerjob.worker.common.constants.TaskConstant: 所有根任务的名称
run() - 类中的方法com.github.kfcfans.powerjob.worker.background.ReleaseCheckRunnable
run() - 类中的方法com.github.kfcfans.powerjob.worker.background.WorkerHealthReporter
run() - 类中的方法com.github.kfcfans.powerjob.worker.core.executor.ProcessorRunnable
run() - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.Dispatcher
runningNum - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder

S

save(TaskDO) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO: 插入任务数据
save(TaskDO) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
save(TaskDO) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService
scheduledPool - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker
ScriptProcessor - com.github.kfcfans.powerjob.worker.core.processor.built中的类: 脚本处理器
ScriptProcessor(Long, String, long) - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.built.ScriptProcessor
serialize(Object) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.SerializerUtils
SerializerUtils - com.github.kfcfans.powerjob.worker.common.utils中的类: 序列化器 V1.0.0：对象池，因无法解决反序列化容器类（外部类）的原因而被移除，LastCommitId: a14f554e0085b6a179375a8ca04665434b73c7bd V1.2.0：ThreadLocal + 手动设置Kryo所使用的类加载器（默认类加载器为创建kryo的类对象（Kryo.class）的类加载器）实现容器类的序列化和反序列化
SerializerUtils() - 类的构造器com.github.kfcfans.powerjob.worker.common.utils.SerializerUtils
ServerDiscoveryService - com.github.kfcfans.powerjob.worker.background中的类: 服务发现
ServerDiscoveryService() - 类的构造器com.github.kfcfans.powerjob.worker.background.ServerDiscoveryService
setApplicationContext(ApplicationContext) - 类中的方法com.github.kfcfans.powerjob.worker.OhMyWorker
setConfig(OhMyConfig) - 类中的方法com.github.kfcfans.powerjob.worker.OhMyWorker
setTask(TaskDO) - 类中的静态方法com.github.kfcfans.powerjob.worker.common.ThreadLocalStore
ShellProcessor - com.github.kfcfans.powerjob.worker.core.processor.built中的类: Shell 处理器由 ProcessorTracker 创建
ShellProcessor(Long, String, long) - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.built.ShellProcessor
simpleDelete(SimpleTaskQuery) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO
simpleDelete(SimpleTaskQuery) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
simpleQuery(SimpleTaskQuery) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO
simpleQuery(SimpleTaskQuery) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
simpleQueryPlus(SimpleTaskQuery) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO
simpleQueryPlus(SimpleTaskQuery) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
SimpleTaskQuery - com.github.kfcfans.powerjob.worker.persistence中的类: 简单查询直接类，只支持 select * from task_info where xxx = xxx and xxx = xxx 的查询
SimpleTaskQuery() - 类的构造器com.github.kfcfans.powerjob.worker.persistence.SimpleTaskQuery
simpleUpdate(SimpleTaskQuery, TaskDO) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO
simpleUpdate(SimpleTaskQuery, TaskDO) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
SpringUtils - com.github.kfcfans.powerjob.worker.common.utils中的类: Spring ApplicationContext 工具类
SpringUtils() - 类的构造器com.github.kfcfans.powerjob.worker.common.utils.SpringUtils
StoreStrategy - com.github.kfcfans.powerjob.worker.common.constants中的枚举: 持久化策略
submitLog(long, String) - 类中的方法com.github.kfcfans.powerjob.worker.background.OmsLogHandler: 提交日志
submitTask(TaskDO) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.processor.ProcessorTracker: 提交任务到线程池执行 1.0版本：TaskTracker有任务就dispatch，导致 ProcessorTracker 本地可能堆积过多的任务，造成内存压力。
submitTask(List<TaskDO>) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 提交Task任务(MapReduce的Map，Broadcast的广播)，上层保证 batchSize，同时插入过多数据可能导致失败
SubTask() - 类的构造器com.github.kfcfans.powerjob.worker.pojo.request.ProcessorMapTaskRequest.SubTask
succeedNum - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder
supportSpringBean() - 类中的静态方法com.github.kfcfans.powerjob.worker.common.utils.SpringUtils
SystemInfoUtils - com.github.kfcfans.powerjob.worker.common.utils中的类: 系统信息工具，用于采集监控指标
SystemInfoUtils() - 类的构造器com.github.kfcfans.powerjob.worker.common.utils.SystemInfoUtils

T

TaskConstant - com.github.kfcfans.powerjob.worker.common.constants中的类: task 常熟
TaskConstant() - 类的构造器com.github.kfcfans.powerjob.worker.common.constants.TaskConstant
TaskContext - com.github.kfcfans.powerjob.worker.core.processor中的类: 任务上下文概念统一，所有的worker只处理Task，Job和JobInstance的概念只存在于Server和TaskTracker 单机任务：整个Job变成一个Task 广播任务：整个job变成一堆一样的Task MR 任务：被map出来的任务都视为根Task的子Task
TaskContext() - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.TaskContext
TaskDAO - com.github.kfcfans.powerjob.worker.persistence中的接口: 任务持久化接口
TaskDAOImpl - com.github.kfcfans.powerjob.worker.persistence中的类: 任务持久化实现层，表名：task_info
TaskDAOImpl() - 类的构造器com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
TaskDO - com.github.kfcfans.powerjob.worker.persistence中的类: TaskDO（为了简化 DAO 层，一张表实现两种功能）对于 TaskTracker，task_info 存储了当前 JobInstance 所有的子任务信息对于普通的 Worker，task_info 存储了当前无法处理的任务信息
TaskDO() - 类的构造器com.github.kfcfans.powerjob.worker.persistence.TaskDO
taskPersistenceService - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker
TaskPersistenceService - com.github.kfcfans.powerjob.worker.persistence中的类: 任务持久化服务
TaskResult - com.github.kfcfans.powerjob.worker.core.processor中的类: Task执行结果
TaskResult() - 类的构造器com.github.kfcfans.powerjob.worker.core.processor.TaskResult
TaskStatus - com.github.kfcfans.powerjob.worker.common.constants中的枚举: 任务状态，task_info 表中 status 字段的枚举值
TaskTracker - com.github.kfcfans.powerjob.worker.core.tracker.task中的类: 负责管理 JobInstance 的运行，主要包括任务的派发（MR可能存在大量的任务）和状态的更新
TaskTracker(ServerScheduleJobReq) - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker
TaskTracker.Dispatcher - com.github.kfcfans.powerjob.worker.core.tracker.task中的类: 定时扫描数据库中的task（出于内存占用量考虑，每次最多获取100个），并将需要执行的任务派发出去
TaskTracker.InstanceStatisticsHolder - com.github.kfcfans.powerjob.worker.core.tracker.task中的类: 存储任务实例产生的各个Task状态，用于分析任务实例执行情况
TaskTrackerActor - com.github.kfcfans.powerjob.worker.actors中的类: worker的master节点，处理来自server的jobInstance请求和来自worker的task请求
TaskTrackerActor() - 类的构造器com.github.kfcfans.powerjob.worker.actors.TaskTrackerActor
TaskTrackerPool - com.github.kfcfans.powerjob.worker.core.tracker.task中的类: 持有 TaskTracker 对象
TaskTrackerPool() - 类的构造器com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTrackerPool
TaskTrackerStartTaskReq - com.github.kfcfans.powerjob.worker.pojo.request中的类: TaskTracker 派发 task 进行执行
TaskTrackerStartTaskReq(InstanceInfo, TaskDO) - 类的构造器com.github.kfcfans.powerjob.worker.pojo.request.TaskTrackerStartTaskReq: 创建 TaskTrackerStartTaskReq，该构造方法必须在 TaskTracker 节点调用
TaskTrackerStopInstanceReq - com.github.kfcfans.powerjob.worker.pojo.request中的类: TaskTracker 停止 ProcessorTracker，释放相关资源任务执行完毕后停止 OR 手动强制停止
TaskTrackerStopInstanceReq() - 类的构造器com.github.kfcfans.powerjob.worker.pojo.request.TaskTrackerStopInstanceReq
ThreadLocalStore - com.github.kfcfans.powerjob.worker.common中的类: 存储一些不方便直接传递的东西 #attention：警惕内存泄漏问题，执行完毕后手动释放
ThreadLocalStore() - 类的构造器com.github.kfcfans.powerjob.worker.common.ThreadLocalStore
toString() - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDO
TroubleshootingActor - com.github.kfcfans.powerjob.worker.actors中的类: 处理系统异常的 Actor
TroubleshootingActor() - 类的构造器com.github.kfcfans.powerjob.worker.actors.TroubleshootingActor
tryRelease() - 接口中的方法com.github.kfcfans.powerjob.worker.container.OmsContainer: 尝试释放容器资源
tryRelease() - 类中的方法com.github.kfcfans.powerjob.worker.container.OmsJarContainer

U

update(ProcessorTrackerStatusReportReq) - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatus: 接收到 ProcessorTracker 的心跳信息后，更新状态
updateLostTasks(List<String>) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 更新被派发到已经失联的 ProcessorTracker 的任务，重新执行 update task_info set address = 'N/A', status = 0 where address in () and status not in (5,6)
updateStatus(ProcessorTrackerStatusReportReq) - 类中的方法com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatusHolder: 根据 ProcessorTracker 的心跳更新状态
updateTask(Long, String, TaskDO) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 依靠主键更新 Task（不涉及 result 的，都可以用该方法更新）
updateTaskStatus(String, int, long, String) - 类中的方法com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker: 更新Task状态 V1.0.0 -> V1.0.1（e405e283ad7f97b0b4e5d369c7de884c0caf9192）锁方案变更，从 synchronized (taskId.intern()) 修改为分段锁，能大大减少内存占用，损失的只有理论并发度而已
updateTaskStatus(Long, String, int, long, String) - 接口中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAO: 更新任务状态（result可能出现千奇百怪的字符，比如 ' ，只能特殊定制SQL直接写入）
updateTaskStatus(Long, String, int, long, String) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskDAOImpl
updateTaskStatus(Long, String, int, long, String) - 类中的方法com.github.kfcfans.powerjob.worker.persistence.TaskPersistenceService: 更新任务状态

V

valueOf(String) - 枚举中的静态方法com.github.kfcfans.powerjob.worker.common.constants.StoreStrategy: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法com.github.kfcfans.powerjob.worker.common.constants.TaskStatus: 返回带有指定名称的该类型的枚举常量。
values() - 枚举中的静态方法com.github.kfcfans.powerjob.worker.common.constants.StoreStrategy: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法com.github.kfcfans.powerjob.worker.common.constants.TaskStatus: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。

W

waitingDispatchNum - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder
warn(String, Object...) - 类中的方法com.github.kfcfans.powerjob.worker.log.impl.OmsServerLogger
warn(String, Object...) - 接口中的方法com.github.kfcfans.powerjob.worker.log.OmsLogger: 输出 WARN 类型的日志，与 Slf4j 用法一致
WorkerActor - com.github.kfcfans.powerjob.worker.actors中的类: Worker节点Actor，接受服务器请求
WorkerActor() - 类的构造器com.github.kfcfans.powerjob.worker.actors.WorkerActor
WorkerHealthReporter - com.github.kfcfans.powerjob.worker.background中的类: Worker健康度定时上报
WorkerHealthReporter() - 类的构造器com.github.kfcfans.powerjob.worker.background.WorkerHealthReporter
workerUnreceivedNum - 类中的变量com.github.kfcfans.powerjob.worker.core.tracker.task.TaskTracker.InstanceStatisticsHolder

A B C D E F G I L M O P R S T U V W