Uses of Interface
org.apache.giraph.function.vertex.FunctionWithVertex

Packages that use FunctionWithVertex

Package	Description
org.apache.giraph.block_app.library	Core library of Pieces and Suppliers, providing most common usages.

Uses of FunctionWithVertex in org.apache.giraph.block_app.library

Methods in org.apache.giraph.block_app.library with parameters of type FunctionWithVertex

Modifier and Type	Method and Description
<S,R extends org.apache.hadoop.io.Writable> Block	SendMessageChain.endReduce(String name, ReduceOperation<S,R> reduceOp, FunctionWithVertex<I,V,E,P,S> valueSupplier, Consumer<R> reducedValueConsumer) End chain by giving received messages to valueSupplier, to produce value that should be reduced, and consumed on master by reducedValueConsumer.
<S,R extends org.apache.hadoop.io.Writable> Block	SendMessageChain.endReduceWithMaster(String name, ReduceOperation<S,R> reduceOp, FunctionWithVertex<I,V,E,P,S> valueSupplier, PairConsumer<R,BlockMasterApi> reducedValueConsumer) End chain by giving received messages to valueSupplier, to produce value that should be reduced, and consumed on master by reducedValueConsumer.
<M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,Iterable<M>>	SendMessageChain.thenSend(String name, Class<M> messageClass, FunctionWithVertex<I,V,E,P,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier) Give previously received message(s) to messageSupplier, and send message it returns to all targets provided by targetsSupplier.
<M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,M>	SendMessageChain.thenSend(String name, MessageCombiner<? super I,M> messageCombiner, FunctionWithVertex<I,V,E,P,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier) Give previously received message(s) to messageSupplier, and send message it returns to all targets provided by targetsSupplier, and use given messageCombiner to combine messages together.
<M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,Iterable<M>>	SendMessageChain.thenSendToNeighbors(String name, Class<M> messageClass, FunctionWithVertex<I,V,E,P,M> messageSupplier) Give previously received message(s) to messageSupplier, and send message it returns to all neighbors of current vertex.
<M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,M>	SendMessageChain.thenSendToNeighbors(String name, MessageCombiner<? super I,M> messageCombiner, FunctionWithVertex<I,V,E,P,M> messageSupplier) Give previously received message(s) to messageSupplier, and send message it returns to all neighbors of current vertex, and use given messageCombiner to combine messages together.