Fix join error by caching vTable in mapReduceTriplets

This commit is contained in:
Ankur Dave 2013-11-30 13:37:19 -08:00
parent 10c0f9b0bb
commit dee1318d3d

View file

@ -258,6 +258,9 @@ class GraphImpl[VD: ClassManifest, ED: ClassManifest] protected (
}
}
// Permit joining the result of mapReduceTriplets back with vTable
vTable.cache()
// do the final reduction reusing the index map
vTable.aggregateUsingIndex(preAgg, reduceFunc)
} // end of mapReduceTriplets