Skip to content
Snippets Groups Projects
Commit 5a9b07ea authored by Joseph E. Gonzalez's avatar Joseph E. Gonzalez
Browse files

Fixing documentation

parent 266eb01c
No related branches found
No related tags found
No related merge requests found
......@@ -205,9 +205,11 @@ class VertexSetRDD[@specialized V: ClassManifest](
} // end of mapValues
/**
* Fill in missing values for all vertices in the index.
*
* @param missingValue
* @return
* @param missingValue the value to be used for vertices in the
* index that don't currently have values.
* @return A VertexSetRDD with a value for all vertices.
*/
def fillMissing(missingValue: V): VertexSetRDD[V] = {
val newValuesRDD: RDD[ (Array[V], BitSet) ] =
......
......@@ -329,18 +329,7 @@ object GraphImpl {
val index = VertexSetRDD.makeIndex(allVids, Some(Partitioner.defaultPartitioner(vertices)))
// Index the vertices and fill in missing attributes with the default
val vtable = VertexSetRDD(vertices, index, mergeFunc).fillMissing(defaultVertexAttr)
/**
* @todo Verify that there are no edges that contain vertices
* that are not in vTable. This should probably be resolved:
*
* edges.flatMap{ e => Array((e.srcId, null), (e.dstId, null)) }
* .cogroup(vertices).map{
* case (vid, _, attr) =>
* if (attr.isEmpty) (vid, defaultValue)
* else (vid, attr)
* }
*
*/
val etable = createETable(edges)
val vid2pid = new Vid2Pid(etable, vtable.index)
val localVidMap = createLocalVidMap(etable)
......
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