Skip to content
Snippets Groups Projects
Commit 5f3ee537 authored by Dan Crankshaw's avatar Dan Crankshaw
Browse files

Added accessVertexAttr func which somehow got lost in a merge.

parent 8a460e18
No related branches found
No related tags found
No related merge requests found
......@@ -517,4 +517,13 @@ object GraphImpl {
VertexSetRDD.aggregate(preAgg, g.vTable.index, reduceFunc)
}
private def accessesVertexAttr[VD: ClassManifest, ED: ClassManifest](
closure: AnyRef, attrName: String): Boolean = {
try {
BytecodeUtils.invokedMethod(closure, classOf[EdgeTriplet[VD, ED]], attrName)
} catch {
case _: ClassNotFoundException => true // if we don't know, be conservative
}
}
} // end of object GraphImpl
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment