| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | // ---------------------- helper ---------------------- |
|---|
| | | |
|---|
| | | private static JobTriggerPoolHelper helper = new JobTriggerPoolHelper(); |
|---|
| | |
|---|
| | | public static void toStart() { |
|---|
| | | helper.start(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static void toStop() { |
|---|
| | | helper.stop(); |
|---|
| | | } |
|---|
| | |
|---|
| | | /** |
|---|
| | | * @param jobId |
|---|
| | | * @param triggerType |
|---|
| | | * @param failRetryCount |
|---|
| | | * >=0: use this param |
|---|
| | | * @param failRetryCount >=0: use this param |
|---|
| | | * <0: use param from job info config |
|---|
| | | * @param executorShardingParam |
|---|
| | | * @param executorParam |
|---|
| | | * null: use job param |
|---|
| | | * @param executorParam null: use job param |
|---|
| | | * not null: cover job param |
|---|
| | | */ |
|---|
| | | public static void trigger(int jobId, TriggerTypeEnum triggerType, int failRetryCount, String executorShardingParam, String executorParam, String addressList) { |
|---|
