partitioning - 哈马的广度优先搜索

Question

我正在 Apache hama 中做一个项目以实现广度优先搜索，并且在划分输入图时遇到了麻烦。有人可以建议一种方法来做同样的事情吗？

public static class MinIntCombiner extends Combiner<IntWritable> {

@Override
public IntWritable combine(Iterable<IntWritable> messages) {
  int visited = Integer.MAX_VALUE;

  Iterator<IntWritable> it = messages.iterator();
 // int msgValue = it.next().get();
  while (it.hasNext()== true) {

  int msgValue = it.next().get();  
    if (visited > msgValue)
      visited = msgValue;
//    msgValue = it.next().get();
  }

  return new IntWritable(visited);
}

这里使用的分区器是

ssspJob.setPartitioner(HashPartitioner.class); 

由于我们不能将 Hashpartitioner 用于 bfs，任何人都可以提出替代方法吗？