嘗試將閉包作爲函數傳遞給JavaDStream時重載

Question

在我的groovy（spock）單元測試中，我構建了一個JavaDStream，然後嘗試用它來處理每個RDD。當我嘗試使用foreachRDD或接受一個函數作爲參數通過傳遞常規閉合我得到過載問題的其他類似的方法：

Cannot resolve which method to invoke for [class someClass] due to overlapping prototypes between: 
    [interface org.apache.spark.api.java.function.Function] 
    [interface org.apache.spark.api.java.function.Function2] 
    [interface org.apache.spark.api.java.function.VoidFunction] 
    [interface org.apache.spark.api.java.function.VoidFunction2] 

我試着做一些與此類似：

JavaDStream wordStream = buildWordStream(textInputStream) 
wordStream.foreachRDD({rdd,time -> println rdd.toString()}) 

這是什麼導致了上述輸出。

Answer 1

的問題是有多個類（Function，Function2，VoidFunction和VoidFunction2），它的Groovy可以迫使封蓋進入基於你調用的方法。它不能決定使用哪一個，所以Groovy放棄並要求你澄清。

wordStream.foreachRDD {rdd,time -> println rdd.toString()} as Function2 

使用as關鍵字你可以告訴Groovy來迫使封蓋進入哪一類。