Uses of Class
org.apache.giraph.block_app.library.SendMessageChain

Packages that use SendMessageChain

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

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

Methods in org.apache.giraph.block_app.library that return SendMessageChain

Modifier and Type	Method and Description
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,P extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,P>	SendMessageChain.startCustom(Function<ConsumerWithVertex<I,V,E,P>,Block> createStartingBlock) Start chain by providing a function that will produce Block representing beginning of the chain, given a consumer of messages send by the last link in the created block.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,Iterable<M>>	SendMessageChain.startSend(String name, Class<M> messageClass, SupplierFromVertex<I,V,E,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier) Start chain with sending message provided by messageSupplier to all targets provided by targetsSupplier.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,M>	SendMessageChain.startSend(String name, MessageCombiner<? super I,M> messageCombiner, SupplierFromVertex<I,V,E,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier) Start chain with sending message provided by messageSupplier to all targets provided by targetsSupplier, and use given messageCombiner to combine messages together.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,Iterable<M>>	SendMessageChain.startSendToNeighbors(String name, Class<M> messageClass, SupplierFromVertex<I,V,E,M> messageSupplier) Start chain with sending message provided by messageSupplier to all neighbors of a current vertex.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> SendMessageChain<I,V,E,M>	SendMessageChain.startSendToNeighbors(String name, MessageCombiner<? super I,M> messageCombiner, SupplierFromVertex<I,V,E,M> messageSupplier) Start chain with sending message provided by messageSupplier to all neighbors of a current vertex, and use given messageCombiner to combine messages together.
<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.