Skip to content

Commit d32ec1c

Browse files
committed
dropping commented references to bytecode inspection
1 parent f25a6ac commit d32ec1c

File tree

1 file changed

+0
-10
lines changed

1 file changed

+0
-10
lines changed

graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -176,8 +176,6 @@ class GraphImpl[VD: ClassTag, ED: ClassTag] protected (
176176
vertices.cache()
177177
// For each vertex, replicate its attribute only to partitions where it is
178178
// in the relevant position in an edge.
179-
// val mapUsesSrcAttr = accessesVertexAttr(mapFunc, "srcAttr")
180-
// val mapUsesDstAttr = accessesVertexAttr(mapFunc, "dstAttr")
181179
replicatedVertexView.upgrade(vertices, mapUsesSrcAttr, mapUsesDstAttr)
182180
val view = activeSetOpt match {
183181
case Some((activeSet, _)) =>
@@ -250,14 +248,6 @@ class GraphImpl[VD: ClassTag, ED: ClassTag] protected (
250248
}
251249
}
252250

253-
/** Test whether the closure accesses the the attribute with name `attrName`. */
254-
private def accessesVertexAttr(closure: AnyRef, attrName: String): Boolean = {
255-
try {
256-
BytecodeUtils.invokedMethod(closure, classOf[EdgeTriplet[VD, ED]], attrName)
257-
} catch {
258-
case _: ClassNotFoundException => true // if we don't know, be conservative
259-
}
260-
}
261251
} // end of class GraphImpl
262252

263253

0 commit comments

Comments
 (0)