flink 在其他執行環境注冊的函數,在另一個環境可以使用嗎?

在 Flink 中,每個執行環境都維護自己的函數注冊表。因此,如果您在一個執行環境中注冊了一個函數,它不會自動在另一個執行環境中注冊。 如果您想在另一個執行環境中使用已經注冊的函數,您需要手動在該環境中注冊該函數。

具體方法是將已注冊的函數的類及其構造函數的信息(如果有)手動傳遞給新環境中的 ExecutionEnvironment 或 StreamExecutionEnvironment 的注冊方法,例如:


env.registerFunction("myFunction", new MyFunction());

其中,myFunction 是您想要在新環境中使用的函數名稱,MyFunction 是您要注冊的函數的類名。 如果您的函數需要構造函數參數,您可以使用適當的構造函數重載,例如:


env.registerFunction("myFunction", new MyFunction("parameter_value"));

請注意,這種情況下,您需要確保每個環境中使用的所有依賴項(例如共享的類和庫)都可用和相同,以便函數能夠正確地工作。

主站蜘蛛池模板: 日本内射精品一区二区视频| 国产成人综合精品一区| 国产av成人一区二区三区| 天天看高清无码一区二区三区| 国产一区二区三区免费看| 日韩精品一区二区亚洲AV观看| 一区三区三区不卡| 一区二区精品在线| 韩国一区二区三区视频| www一区二区三区| 一区二区三区福利| 天堂一区人妻无码| 无码乱人伦一区二区亚洲| 日本一区二区三区精品国产| 无码人妻精品一区二区三区夜夜嗨| 国产精品99无码一区二区| 亚洲狠狠狠一区二区三区| 日本强伦姧人妻一区二区| 亚洲一区电影在线观看| 中文字幕一区二区人妻| 免费一区二区三区在线视频| 精品久久久久久无码中文字幕一区 | 亚洲av乱码一区二区三区香蕉| 久久精品一区二区免费看| 天天视频一区二区三区| 亚洲国产一区二区三区青草影视| 无码人妻精品一区二区蜜桃网站 | 精品国产一区二区22| 亚洲熟妇无码一区二区三区| 亚洲一区精品视频在线| 国产精品一区在线播放| 精品国产一区AV天美传媒| 日韩精品一区二区三区中文| 亚洲视频在线一区二区三区 | 中文字幕一区日韩精品| 亚洲一区二区久久| 国产精品日本一区二区在线播放| 亚洲欧美成人一区二区三区| 99久久人妻精品免费一区| 日韩一区二区久久久久久| 无码精品人妻一区二区三区漫画 |