新增MapReduce任务

MapReduce任务可配置参数

参数名	参数类型	参数值	参数规则	备注
jobName	String	任务名称
argsStr	String	执行任务参数		封装了对应新增的方法，通过k,v的形式新增
shardNum	Integer	Reduce的分片数
executorInfo	String	执行器名称
triggerType	Integer	触发类型	2. 固定时间 3.CRON 表达式 99.工作流
triggerInterval	String	间隔时长
blockStrategy	Integer	阻塞策略	1、丢弃 2、覆盖 3、并行
executorTimeout	Integer	任务执行超时时间		单位：秒
maxRetryTimes	Integer	最大重试次数
retryInterval	Integer	重试间隔		单位：秒
parallelNum	Integer	并行数
description	String	描述

2.5.2、MapReduce任务demo

/**
 * 新增MapReduce模式的任务
 *
 * @param jobName 任务名称
 * @return 任务id
 */
public Long addMapReduceJob(String jobName) {
    return SnailJobOpenApi.addMapReduceJob()
            .setJobName(jobName)
            .setExecutorInfo("testJobExecutor")
            .setExecutorTimeout(30)
            .setDescription("add")
            .setBlockStrategy(BlockStrategyEnum.DISCARD)
            .setMaxRetryTimes(1)
            .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
            .setTriggerInterval(String.valueOf(60))
            .setParallelNum(3)
            .setShardNum(2)
            .setRetryInterval(3)
            .execute();
}