Uses of Class
org.apache.giraph.block_app.library.internal.SendMessagePiece

Packages that use SendMessagePiece

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

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

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

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,M extends org.apache.hadoop.io.Writable> SendMessagePiece<I,V,E,M>	Pieces.sendMessage(String name, Class<M> messageClass, SupplierFromVertex<I,V,E,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier, ConsumerWithVertex<I,V,E,Iterable<M>> messagesConsumer) Creates Piece that for each vertex, sends 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> SendMessagePiece<I,V,E,M>	Pieces.sendMessageToNeighbors(String name, Class<M> messageClass, SupplierFromVertex<I,V,E,M> messageSupplier, ConsumerWithVertex<I,V,E,Iterable<M>> messagesConsumer) Creates Piece that for each vertex, sends message provided by messageSupplier to all neighbors of current vertex.