SchedulerX可以處理有資料狀態的任務,您可以通過資料時間處理非任務執行時間的資料。
操作步驟
例如一個任務在每天00:30運行,但是實際上要處理前一天的資料,即資料時間需要在任務時間的基礎上,向前位移一小時。
在用戶端中接入SchedulerX,詳情請參見快速入門章節,並實現資料時間。
public class TestHelloJob extends JavaProcessor { @Override public ProcessResult process(JobContext context) throws Exception { System.out.println("hello schedulerx2.0"); System.out.println("dataTime=" + context.getDataTime().toString("yyyy-MM-dd HH:mm:ss")); return new ProcessResult(true); } }在控制台建立任務,詳情請參見建立調度任務。並在定時配置中設定時間位移-3600(單位:秒),即向前位移3600 秒(一小時)。任務執行時間不變,執行的時候通過
context.getDataTime()擷取的是前一天23:30的資料。
結果驗證
在包含資料時間的任務建立完成後,進入執行列表頁面,找到對應的任務,在操作列單擊詳情。
在任務執行個體詳情頁面單擊基本資料。
在基本資料頁簽中確認任務的資料時間是否和設定的一致。