如您所知，“在封閉范圍內定義的局部變量必須是最終的或實際上是最終的”。所以我有以下代碼List<Airline> filteredAirlines = new ArrayList<>();JavaRDD<Company> flightCompanyJavaRDD = rdd.map(f -> { ...... results = foo(f); filteredAirlines.addAll(results.getFilteredAirlines()); System.out.println(results.getFilteredAirlines().size()); Company convertedCompanyResult = convert(results); return convertedCompanyResult;});......System.out.println(filteredArilines.size());Line 1 printed1和 line 2 printed 0。似乎該列表filteredArilines未被填充。任何想法為什么？以及如何獲取外部可用的 lambda 表達式中的值？謝謝。
3 回答
吃雞游戲
TA貢獻1829條經驗 獲得超7個贊
你的 lambda 被稱為閉包，因為它從外部范圍（這里是你的數組）捕獲一些東西。
完全不鼓勵使用捕獲旨在修改的對象的閉包。這是因為它可能只在本地模式下工作：實際上在序列化/反序列化后的集群模式下，每個捕獲的對象都會有一個獨立存在于每個 JVM 上的版本。
做你想做的最干凈的方法可能是使用Accumulators
精慕HU
TA貢獻1845條經驗 獲得超8個贊
您可以像這樣將結果直接映射到列表：
List<Airline> filteredAirlines = rdd.map(f -> {
......
results = foo();
System.out.println(results.getFilteredAirlines().size());
return results.getFilteredAirlines();
}).collect(Collectors.toList());
躍然一笑
TA貢獻1826條經驗 獲得超6個贊
我不知道什么rdd是什么，rdd.map()做什么，但你傳遞給它的 lambda 表達式并不意味著它會立即執行（或根本不執行）。
因此，當您在代碼段的最后一行打印時filteredArilines.size()，lambda 表達式可能尚未執行，因此List仍然是空的。
添加回答
舉報
0/150
提交
取消