((SimpleSubGraph) myGraph).setSubPid(pid % subpartPerPartition);
LOG.info("Reduce edges for graph: " + pid);
while (iter.hasNext()) {
ValueType val = iter.next();
CombinedEdgeValueType evalue = val.edgeValue();
myGraph.addEdges(evalue.sources(), evalue.targets(), evalue.edata());
}
// Switch to GLGraph by uncommenting the next line.
// GLJsonFormatter formatter = new GLJsonFormatter();
SimpleJsonFormatter formatter = new SimpleJsonFormatter();