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

Packages that use SupplierFromVertex

Package	Description
org.apache.giraph.block_app.framework.block	Block interface as a composable unit of execution, and its common implementations.
org.apache.giraph.block_app.framework.piece.delegate	Pieces that delegate their work to a set of one or multiple other Pieces.
org.apache.giraph.block_app.library	Core library of Pieces and Suppliers, providing most common usages.
org.apache.giraph.block_app.library.internal	Internal implementation of Pieces needed for Pieces utility class.
org.apache.giraph.function	Package for interfaces representing different functions, that all extends Serializable in order for Kryo to be able to serialize them.

Uses of SupplierFromVertex in org.apache.giraph.block_app.framework.block

Methods in org.apache.giraph.block_app.framework.block with parameters of type SupplierFromVertex

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> Block	FilteringBlock.createReceiveFiltering(SupplierFromVertex<I,V,E,Boolean> toCallReceive, Block innerBlock) Creates filtering block, that filters only vertexReceive function, and always calls vertexSend function.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Block	FilteringBlock.createSendFiltering(SupplierFromVertex<I,V,E,Boolean> toCallSend, Block innerBlock) Creates filtering block, that filters only vertexSend function, and always calls vertexReceive function.

Constructors in org.apache.giraph.block_app.framework.block with parameters of type SupplierFromVertex

Constructor and Description
FilteringBlock(SupplierFromVertex<I,V,E,Boolean> toCallSendAndReceive, Block block) Creates filtering block, where both vertexSend and vertexReceive is filtered based on same supplier.
FilteringBlock(SupplierFromVertex<I,V,E,Boolean> toCallSend, SupplierFromVertex<I,V,E,Boolean> toCallReceive, Block block) Creates filtering block which uses passed toCallSend to filter calls to vertexSend, and passed toCallReceive to filter calls to vertexReceive, on all pieces within passed block.
FilteringBlock(SupplierFromVertex<I,V,E,Boolean> toCallSend, SupplierFromVertex<I,V,E,Boolean> toCallReceive, Block block) Creates filtering block which uses passed toCallSend to filter calls to vertexSend, and passed toCallReceive to filter calls to vertexReceive, on all pieces within passed block.

Uses of SupplierFromVertex in org.apache.giraph.block_app.framework.piece.delegate

Methods in org.apache.giraph.block_app.framework.piece.delegate with parameters of type SupplierFromVertex

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,WV,WM extends org.apache.hadoop.io.Writable,S> FilteringPiece<I,V,E,M,WV,WM,S>	FilteringPiece.createReceiveFiltering(SupplierFromVertex<? super I,? super V,? super E,Boolean> toCallReceive, AbstractPiece<? super I,? super V,? super E,? super M,? super WV,? super WM,? super S> innerPiece) Creates filtering piece, that filters only vertexReceive function, and always calls vertexSend function.
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,WV,WM extends org.apache.hadoop.io.Writable,S> FilteringPiece<I,V,E,M,WV,WM,S>	FilteringPiece.createSendFiltering(SupplierFromVertex<? super I,? super V,? super E,Boolean> toCallSend, AbstractPiece<? super I,? super V,? super E,? super M,? super WV,? super WM,? super S> innerPiece) Creates filtering block, that filters only vertexSend function, and always calls vertexReceive function.

Constructors in org.apache.giraph.block_app.framework.piece.delegate with parameters of type SupplierFromVertex

Constructor and Description
FilteringPiece(SupplierFromVertex<? super I,? super V,? super E,Boolean> toCallSendAndReceive, AbstractPiece<? super I,? super V,? super E,? super M,? super WV,? super WM,? super S> innerPiece) Creates filtering piece, where both vertexSend and vertexReceive is filtered based on same supplier.
FilteringPiece(SupplierFromVertex<? super I,? super V,? super E,Boolean> toCallSend, SupplierFromVertex<? super I,? super V,? super E,Boolean> toCallReceive, AbstractPiece<? super I,? super V,? super E,? super M,? super WV,? super WM,? super S> innerPiece) Creates filtering piece which uses passed toCallSend to filter calls to vertexSend, and passed toCallReceive to filter calls to vertexReceive, on passed innerPiece.
FilteringPiece(SupplierFromVertex<? super I,? super V,? super E,Boolean> toCallSend, SupplierFromVertex<? super I,? super V,? super E,Boolean> toCallReceive, AbstractPiece<? super I,? super V,? super E,? super M,? super WV,? super WM,? super S> innerPiece) Creates filtering piece which uses passed toCallSend to filter calls to vertexSend, and passed toCallReceive to filter calls to vertexReceive, on passed innerPiece.

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

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

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> SupplierFromVertex<I,V,E,Iterable<Edge<I,E>>>	VertexSuppliers.vertexEdgesSupplier() Supplier which extracts and returns edges object.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,I>	VertexSuppliers.vertexIdSupplier() Supplier which extracts and returns vertex ID.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>>	VertexSuppliers.vertexNeighborsSupplier() Supplier which extracts and returns Iterator over all neighbor IDs.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>>	VertexSuppliers.vertexNeighborsSupplier(Predicate<I> toSupply) Supplier which extracts and returns Iterator over neighbor IDs that return true for given predicate.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>>	VertexSuppliers.vertexNeighborsSupplierWithIndex(PairPredicate<PrimitiveRefs.IntRef,I> toSupply) Supplier which gives Iterator over neighbor IDs that return true for given predicate over (index, target) Note - iterator returns reused object, so you need to "use" them, before calling next() again.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,V>	VertexSuppliers.vertexValueSupplier() Supplier which extracts and returns vertex value.

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

Modifier and Type	Method and Description
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.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.
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.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> SendMessageWithCombinerPiece<I,V,E,M>	Pieces.sendMessage(String name, MessageCombiner<? super I,M> messageCombiner, SupplierFromVertex<I,V,E,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier, ConsumerWithVertex<I,V,E,M> messagesConsumer) Creates Piece that for each vertex, sends message provided by messageSupplier to all targets provided by targetsSupplier, and uses 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> SendMessageWithCombinerPiece<I,V,E,M>	Pieces.sendMessage(String name, MessageCombiner<? super I,M> messageCombiner, SupplierFromVertex<I,V,E,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier, ConsumerWithVertex<I,V,E,M> messagesConsumer) Creates Piece that for each vertex, sends message provided by messageSupplier to all targets provided by targetsSupplier, and uses 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> 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.
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> SendMessageWithCombinerPiece<I,V,E,M>	Pieces.sendMessageToNeighbors(String name, MessageCombiner<? super I,M> messageCombiner, SupplierFromVertex<I,V,E,M> messageSupplier, ConsumerWithVertex<I,V,E,M> messagesConsumer) Creates Piece that for each vertex, sends message provided by messageSupplier to all neighbors of current vertex, and uses 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.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,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,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.

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

Modifier and Type	Method and Description
Block	SendMessageChain.endCustom(Function<SupplierFromVertex<I,V,E,P>,Block> createBlockToAttach) End chain by providing a function that will produce Block to be attached to the end of current chain, given a supplier of messages received within the last link in the chain.

Uses of SupplierFromVertex in org.apache.giraph.block_app.library.internal

Constructors in org.apache.giraph.block_app.library.internal with parameters of type SupplierFromVertex

Constructor and Description
SendMessagePiece(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)
SendMessagePiece(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)
SendMessageWithCombinerPiece(String name, MessageCombiner<? super I,M> messageCombiner, SupplierFromVertex<I,V,E,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier, ConsumerWithVertex<I,V,E,M> messagesConsumer)
SendMessageWithCombinerPiece(String name, MessageCombiner<? super I,M> messageCombiner, SupplierFromVertex<I,V,E,M> messageSupplier, SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier, ConsumerWithVertex<I,V,E,M> messagesConsumer)

Uses of SupplierFromVertex in org.apache.giraph.function

Methods in org.apache.giraph.function that return SupplierFromVertex

Modifier and Type	Method and Description
<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,T>	ObjectTransfer.castToSupplier() To be called when needing to pass it as a Supplier - making it obvious that K, V and E on supplier side can be any types, and to make code work without compile errors/warnings.