小编Fob*_*obi的帖子

我的配置是:

• Scala 2.11(插件Scala IDE)
• Eclipse Neon.3发布(4.6.3)
• Windows 7 64位

我想运行这个简单的scala代码(Esempio.scala):

package it.scala

// importo packages di Spark
import org.apache.spark.SparkContext
import org.apache.spark.SparkConf


object Wordcount {
    def main(args: Array[String]) {

        val inputs: Array[String] = new Array[String](2)
        inputs(0) = "C:\\Users\\FobiDell\\Desktop\\input"
        inputs(1) = "C:\\Users\\FobiDell\\Desktop\\output"

        // oggetto SparkConf per settare i parametri sulla propria applicazione 
        // da fornire poi al cluster manager scelto (Yarn, Mesos o Standalone).
        val conf = new SparkConf()
        conf.setAppName("Smartphone Addiction")
        conf.setMaster("local")

        // oggetto SparkContext per connessione al cluster manager scelto
        val …

我知道scala.collection包中有两个非常有用的对象,它们将帮助我们实现这个目标:

• JavaConverters(如果我想要明确并告诉我想要转换的内容)
• JavaConversions(如果我不想进行共同控制转换,让编译器为我做隐式工作)

但是我在我的案例中应用它们有一些麻烦,因为我的数据结构比我在许多例子中看到的其他数据结构稍微复杂一些.

我在scala代码中,我希望我的scala函数返回Java集合.所以我想将Scala Seq [(Int,Seq [String])]转换为Java集合List [(int,List [String])].

我怎样才能做到这一点？