scala - Spark Scala简单加法和其他数学计算

嗨，我是apache Spark的新手，在我的用例中，我将有3个输入，所有这些都存在于HDFS中，我需要从hdfs中存在的文件中提取数据，并添加两个数据，并将结果除以第三个数据，如何我继续吗？

谢谢你快速的回复。

最佳答案

这样的事情应该起作用:

  import org.apache.spark.SparkContext
  import org.apache.spark.SparkContext._
  import org.apache.spark.SparkConf
  import org.apache.spark.rdd.RDD

  val conf = new SparkConf().setAppName("spark-scratch").setMaster("local")
  val sc = new SparkContext(conf)

  val A = sc.textFile("/user/root/spark/cc.dat").map(_.split(",")).map(fc => (fc(3).toInt))
  val B = sc.textFile("/user/root/spark/aci.dat").map(_.split(",")).map(fc => (fc(4).toInt))
  val C = sc.textFile("/user/root/spark/bta.dat").map(_.split(",")).map(fc => (fc(5).toInt))

  val calc = { r: ((Int, Int), Int) =>
    val ((a, b), c) = r
    a * b * c / 12
  }

  val result = (A zip B zip C).map(calc)

(它可以编译，但是我没有对其进行测试)