Hi Thanks for reply.
Here is my code:
class BusStopNode(val name: String,val mode:String,val maxpasengers :Int)
extends Serializable
case class busstop(override val name: String,override val mode:String,val
shelterId: String, override val maxpasengers :Int) extends
BusStopNode(name,mode,maxpasengers) with Serializable
case class busNodeDetails(override val name: String,override val
mode:String,val srcId: Int,val destId :Int,val arrivalTime :Int,override val
maxpasengers :Int) extends BusStopNode(name,mode,maxpasengers) with
Serializable
case class routeDetails(override val name: String,override val
mode:String,val srcId: Int,val destId :Int,override val maxpasengers :Int)
extends BusStopNode(name,mode,maxpasengers) with Serializable
val busstopRDD: RDD[(VertexId, BusStopNode)] =
sc.textFile("\\BusStopNameMini.txt").filter(!_.startsWith("#")).
map { line =>
val row = line split ","
(row(0).toInt, new
busstop(row(0),row(3),row(1)+row(0),row(2).toInt))
}
busstopRDD.foreach(println)
val busNodeDetailsRdd: RDD[(VertexId, BusStopNode)] =
sc.textFile("\\RouteDetails.txt").filter(!_.startsWith("#")).
map { line =>
val row = line split ","
(row(0).toInt, new
busNodeDetails(row(0),row(4),row(1).toInt,row(2).toInt,row(3).toInt,0))
}
busNodeDetailsRdd.foreach(println)
val detailedStats: RDD[Edge[BusStopNode]] =
sc.textFile("\\routesEdgeNew.txt").
filter(! _.startsWith("#")).
map {line =>
val row = line split ','
Edge(row(0).toInt, row(1).toInt,new BusStopNode(row(2),
row(3),1)
)}
val busGraph = busstopRDD ++ busNodeDetailsRdd
busGraph.foreach(println)
val mainGraph = Graph(busGraph, detailedStats)
mainGraph.triplets.foreach(println)
val subGraph = mainGraph subgraph (epred = _.srcAttr.name == "101")
//Working Fine
for (subTriplet <- subGraph.triplets) {
println(subTriplet.dstAttr.name)
}
//Working fine
for (mainTriplet <- mainGraph.triplets) {
println(subTriplet.dstAttr.name)
}
//causing error while iterating both at same time
for (subTriplet <- subGraph.triplets) {
for (mainTriplet <- mainGraph.triplets) { //Nullpointer exception
is causing here
if
(subTriplet.dstAttr.name.toString.equals(mainTriplet.dstAttr.name)) {
println("hellooooo")//success case on both destination names of of
subgraph and maingraph
}
}
}
}
BusStopNameMini.txt
101,bs,10,B
102,bs,10,B
103,bs,20,B
104,bs,14,B
105,bs,8,B
RouteDetails.txt
#101,102,104 4 5 6
#102,103 3 4
#103,105,104 2 3 4
#104,102,101 4 5 6
#104,101 5
#105,104,102 5 6 2
1,101,104,5,R
2,102,103,5,R
3,103,104,5,R
4,102,103,5,R
5,104,101,5,R
6,105,102,5,R
routesEdgeNew.txt it contains two types of edges are bus to bus with edge
value is distance and bus to route with edge value as time
#101,102,104 4 5 6
#102,103 3 4
#103,105,104 2 3 4
#104,102,101 4 5 6
#104,101 5
#105,104,102 5 6 2
101,102,4,BS
102,104,5,BS
102,103,3,BS
103,105,4,BS
105,104,3,BS
104,102,4,BS
102,101,5,BS
104,101,5,BS
105,104,5,BS
104,102,6,BS
101,1,4,R,102
101,1,4,R,103
102,2,5,R
103,3,6,R
103,3,5,R
104,4,7,R
105,5,4,Z
101,2,9,R
105,5,4,R
105,2,5,R
104,2,5,R
103,1,4,R
101,103,4,BS
101,104,4,BS
101,105,4,BS
101,103,5,BS
101,104,5,BS
101,105,5,BS
1,101,4,R
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Graphx-triplet-comparison-tp28198p28205.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscr...@spark.apache.org
