本文介紹了將配置參數(shù)傳遞給自定義Flink ProcessFunction的處理方法，對(duì)大家解決問(wèn)題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧！
問(wèn)題描述
我需要能夠向MyFunction傳遞擴(kuò)展ProcessFunction的配置參數(shù)。在我的參數(shù)中，這是我唯一的方法嗎？我不需要將它與每個(gè)元素一起傳遞。我可以以某種方式使用open方法嗎？
public class MyProcessFunction extends ProcessFunction<AbstractMap.SimpleEntry<Row, RowTypeInfo>, MyOutput> {
public void open(Configuration parameters) {
}
@Override
public void processElement(AbstractMap.SimpleEntry<Row, RowTypeInfo> value, Context ctx, Collector<MyOutput> out) throws Exception {
推薦答案
添加向其傳遞參數(shù)的構(gòu)造函數(shù)是一種很好的方法。
Handling Application Parameters的Flink文檔中的頁(yè)面包含一些相關(guān)信息。
您可能認(rèn)為可以通過(guò)某種方式利用open()方法的Configuration parameters參數(shù)，但這是Flink項(xiàng)目早期的遺留問(wèn)題，Datastream API沒(méi)有使用它。
這篇關(guān)于將配置參數(shù)傳遞給自定義Flink ProcessFunction的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，
