Details
-
Improvement
-
Status: Resolved
-
Trivial
-
Resolution: Not A Problem
-
None
-
None
-
None
Description
The boolean expression in:
@Override public void map(Object key, Object value, Context context) throws IOException, InterruptedException { // map() only does computation // 1) Run checkpoint per frequency policy. // 2) For every vertex on this mapper, run the compute() function // 3) Wait until all messaging is done. // 4) Check if all vertices are done. If not goto 2). // 5) Dump output. if (done == true) { return; }
can be simplified.