Uses of Class
org.apache.giraph.types.NoMessage

Packages that use NoMessage

Package	Description
org.apache.giraph.block_app.framework.piece	Single execution object - Piece, and related classes.
org.apache.giraph.block_app.library	Core library of Pieces and Suppliers, providing most common usages.
org.apache.giraph.block_app.library.gc	GC utility pieces.

Uses of NoMessage in org.apache.giraph.block_app.framework.piece

Method parameters in org.apache.giraph.block_app.framework.piece with type arguments of type NoMessage

Modifier and Type	Method and Description
void	Piece.workerContextReceive(BlockWorkerContextReceiveApi workerContextApi, S executionStage, Object workerValue, List<NoMessage> workerMessages)
void	Piece.workerContextSend(BlockWorkerContextSendApi<I,NoMessage> workerContextApi, S executionStage, Object workerValue)

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

Methods in org.apache.giraph.block_app.library that return types with arguments of type NoMessage

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> Piece<I,V,E,NoMessage,Object>	Pieces.forAllVertices(String pieceName, Consumer<Vertex<I,V,E>> process) For each vertex execute given process function.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Piece<I,V,E,NoMessage,Object>	Pieces.forAllVerticesOnReceive(String pieceName, Consumer<Vertex<I,V,E>> process) For each vertex execute given process function.
static Piece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object>	Pieces.masterCompute(String pieceName, Consumer<BlockMasterApi> process) Execute given function on master.
static <S,R extends org.apache.hadoop.io.Writable,I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Piece<I,V,E,NoMessage,Object>	Pieces.reduce(String name, ReduceOperation<S,R> reduceOp, SupplierFromVertex<I,V,E,S> valueSupplier, Consumer<R> reducedValueConsumer) Creates single reducer piece - given reduce class, supplier of values on worker, reduces and passes the result to given consumer on master.
static <S,R extends org.apache.hadoop.io.Writable,I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Piece<I,V,E,NoMessage,Object>	Pieces.reduceAndBroadcast(String name, ReduceOperation<S,R> reduceOp, SupplierFromVertex<I,V,E,S> valueSupplier, ConsumerWithVertex<I,V,E,R> reducedValueConsumer) Creates single reducer and broadcast piece - given reduce class, supplier of values on worker, reduces and broadcasts the value, passing it to the consumer on worker for each vertex.
static <S,R extends org.apache.hadoop.io.Writable,I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Piece<I,V,E,NoMessage,Object>	Pieces.reduceAndBroadcastWithArrayOfHandles(String name, int numHandles, Supplier<ReduceOperation<S,R>> reduceOp, SupplierFromVertex<I,V,E,Long> handleHashSupplier, SupplierFromVertex<I,V,E,S> valueSupplier, ConsumerWithVertex<I,V,E,R> reducedValueConsumer) Like reduceAndBroadcast, but uses array of handles for reducers and broadcasts, to make it feasible and performant when values are large.
static <S,R extends org.apache.hadoop.io.Writable,I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Piece<I,V,E,NoMessage,Object>	Pieces.reduceWithMaster(String name, ReduceOperation<S,R> reduceOp, SupplierFromVertex<I,V,E,S> valueSupplier, PairConsumer<R,BlockMasterApi> reducedValueConsumer) Creates single reducer piece - given reduce class, supplier of values on worker, reduces and passes the result to given consumer on master.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Piece<I,V,E,NoMessage,Object>	Pieces.removeVertices(String pieceName, SupplierFromVertex<I,V,E,Boolean> shouldRemoveVertex) Creates Piece which removes vertices for which supplier returns true.

Uses of NoMessage in org.apache.giraph.block_app.library.gc

Method parameters in org.apache.giraph.block_app.library.gc with type arguments of type NoMessage

Modifier and Type	Method and Description
void	WorkerGCPiece.workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.WritableComparable,NoMessage> workerContextApi, Object executionStage, Object workerValue)