Flink中richfunction的一點小做用

①傳遞參數 全部須要用戶定義的函數均可以轉換成richfunction，例如實現map operator中你須要實現一個內部類，並實現它的map方法：web data.map (new MapFunction<String, Integer>() { public Integer map(String value) { return Integer.parseInt(value); } });

>>阅读原文<<