📄️ 单机
单机执行表示一个任务实例只会随机分发到一个工作节点,在一个工作节点完成任务执行,支持所有的任务类型。定义一个单机任务通常是实现 io.openjob.worker.processor.JavaProcessor
📄️ 广播
广播任务类型的任务实例会广播到应用对应的所有Worker上执行,当所有Worker都执行完成,该任务才算完成,任意一台Worker执行失败,任务就算失败。
📄️ Map Reduce
MapReduce 模型是轻量级分布式跑批任务。通过 MapProcessor 或 MapReduceProcessor 接口实现。相对于传统的大数据跑批(例如Hadoop、Spark等),MapReduce无需将数据导入大数据平台,且无额外存储及计算成本,即可实现秒级别海量数据处理,具有成本低、速度快、编程简单等特性。
📄️ 静态分片
分片模型主要包含静态分片和动态分片: