剛剛使用flink，有幾個(gè)疑問，求各位了解的大大們，幫幫忙flink如何初始化spring上下文flink如何使用定時(shí)任務(wù)@codecraft @阿里云云棲社區(qū) @范閑 叩謝
1 回答
慕尼黑的夜晚無繁華
TA貢獻(xiàn)1864條經(jīng)驗(yàn) 獲得超6個(gè)贊
對(duì)于問題1：
1、基本的原理就是在執(zhí)行之前先加載下spring的context，為了避免重復(fù)重建，可以使用單利模式
2、對(duì)于source、sink及transformation，可以使用繼承AbstractRichFunction的相關(guān)function，在open的時(shí)候初始化spring context
3、對(duì)于spring context的銷毀，注冊(cè)一個(gè)shutdown hook來銷毀
對(duì)于問題2：
看是要怎么使用定時(shí)任務(wù)，如果是僅僅需要類似普通的spring中的schedule，那問題1解決了就可以了，如果是要在source或sink里頭進(jìn)行定時(shí)，估計(jì)要自己根據(jù)需求實(shí)現(xiàn)，比如使用cron4j等
- 1 回答
- 0 關(guān)注
- 728 瀏覽
添加回答
舉報(bào)
0/150
提交
取消