2014-12-03 51 views
0

下面的代码读取一个文件(example.txt)并计算每个点之间的eucleudian距离。 example.txt中(以下引用)内容是: “ 一个,1个 B,1个 C,2 ” 此代码按预期方式工作但对于大数据集是相当缓慢的。 (a,b)&(b,a) - >(b,a)比较重复的过滤比较在Apache Spark中的多个节点上运行代码时的注意事项

有什么我应该知道的吗?目前我只是在单个节点上运行此代码。但是要在多个节点上运行这个功能,我需要考虑哪些因素?

import org.apache.spark.SparkContext; 

object first { 
    println("Welcome to the Scala worksheet") 

    val conf = new org.apache.spark.SparkConf() 
    .setMaster("local") 
    .setAppName("distances") 
    .setSparkHome("C:\\spark-1.1.0-bin-hadoop2.4\\spark-1.1.0-bin-hadoop2.4") 
    .set("spark.executor.memory", "2g") 
    val sc = new SparkContext(conf) 

    def euclDistance(userA: User, userB: User) = { 

    val subElements = (userA.features zip userB.features) map { 
     m => (m._1 - m._2) * (m._1 - m._2) 
    } 
    val summed = subElements.sum 
    val sqRoot = Math.sqrt(summed) 

    println("value is" + sqRoot) 
    ((userA.name, userB.name), sqRoot) 
    } 

    case class User(name: String, features: Vector[Double]) 

    def createUser(data: String) = { 

    val id = data.split(",")(0) 
    val splitLine = data.split(",") 

    val distanceVector = (splitLine.toList match { 
     case h :: t => t 
    }).map(m => m.toDouble).toVector 

    User(id, distanceVector) 

    } 

    val dataFile = sc.textFile("c:\\data\\example.txt") 
    val users = dataFile.map(m => createUser(m)) 
    val cart = users.cartesian(users) // 
    val distances = cart.map(m => euclDistance(m._1, m._2)) 
    //> distances : org.apache.spark.rdd.RDD[((String, String), Double)] = MappedR 
    //| DD[4] at map at first.scala:46 
    val d = distances.collect // 

    d.foreach(println) //> ((a,a),0.0) 
    //| ((a,b),0.0) 
    //| ((a,c),1.0) 
    //| ((a,),0.0) 
    //| ((b,a),0.0) 
    //| ((b,b),0.0) 
    //| ((b,c),1.0) 
    //| ((b,),0.0) 
    //| ((c,a),1.0) 
    //| ((c,b),1.0) 
    //| ((c,c),0.0) 
    //| ((c,),0.0) 
    //| ((,a),0.0) 
    //| ((,b),0.0) 
    //| ((,c),0.0) 
    //| ((,),0.0) 

} 

回答

0

在没有任何代码更改的情况下,多个节点上的Spark应该运行得更快。您可以调整它以像其他软件系统一样运行得更快。

现在,您可以运行您的本地代码,运行速度更快,如果您只是给它更多的内核。

更改以下到

.setMaster("local") 

.setMaster("local[4]") //4 or 8 or 16 depending on how many cores you have on your local machine. 
相关问题