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