Dear Wiki user, You have subscribed to a wiki page or wiki category on "Hadoop Wiki" for change notification.
The following page has been changed by edwardyoon: http://wiki.apache.org/hadoop/Hamburg ------------------------------------------------------------------------------ {{{ User Interface: + /** + * @param input + * @param nextQueue + */ - public void traverse(Map<Vertex, Message> value, Map<Integer, Message> nextQueue) { + public void traverse(Map<V, Message> input, Map<K, Message> nextQueue, - for (Integer i : v.getAdjList()) { - // Handle the vertex and send a message with modified state of vertex i to next level - } - } + Map<Object, Object> localCollector); + + public void synchronize(Map<Object, Object> localCollector, + Iterator<Entry<Integer, Map<K, Message>>> outgoingQueue); + + public void finalyze(Map<Object, Object> localCollector); + + /** + * At initial time or when a local queue is empty, the picker chooses + * unvisited vertex from local graphs. + */ + public V pick(); }}} == Related Projects ==
