org.apache.giraph.block_app.framework.block

Class FilteringBlock<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.block_app.framework.block.FilteringBlock<I,V,E>

Type Parameters:

I - Vertex id type

V - Vertex value type

E - Edge value type

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

public final class FilteringBlock<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements Block

Block which filters out calls to vertexSend/vertexReceive functions of all pieces in a given block. Filtering happens based on toCallSend and toCallReceive suppliers that are passed in, as every piece is just wrapped with FilteringPiece.

Constructor Summary

Constructors

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.

Method Summary

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	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	createSendFiltering(SupplierFromVertex<I,V,E,Boolean> toCallSend, Block innerBlock) Creates filtering block, that filters only vertexSend function, and always calls vertexReceive function.
void	forAllPossiblePieces(Consumer<AbstractPiece> consumer) Calls consumer for each Piece: - in no particular order - potentially calling multiple times on same Piece - even if Piece might never be returned in the iterator - it will be called at least once for every piece that is going to be returned by iterator Can be used for static analysis/introspection of the block, without actually executing them.
PieceCount	getPieceCount() How many pieces are in this block.
Iterator<AbstractPiece>	iterator() Create iterator representing all pieces needed to be executed in this block.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

FilteringBlock

public 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

public FilteringBlock(SupplierFromVertex<I,V,E,Boolean> toCallSendAndReceive,
                      Block block)

Creates filtering block, where both vertexSend and vertexReceive is filtered based on same supplier.

Method Detail

createReceiveFiltering

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Block createReceiveFiltering(SupplierFromVertex<I,V,E,Boolean> toCallReceive,
                                                                                                                                                                               Block innerBlock)

Creates filtering block, that filters only vertexReceive function, and always calls vertexSend function.

createSendFiltering

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Block createSendFiltering(SupplierFromVertex<I,V,E,Boolean> toCallSend,
                                                                                                                                                                            Block innerBlock)

Creates filtering block, that filters only vertexSend function, and always calls vertexReceive function.

iterator

public Iterator<AbstractPiece> iterator()

Description copied from interface: Block

Create iterator representing all pieces needed to be executed in this block. After Iterator.next call returns, master compute of returned Piece is guaranteed to be called before calling hasNext/next on the iterator. (allows for iterators logic to depend on the execution dynamically, and not be only static)

Specified by:

iterator in interface Iterable<AbstractPiece>

Specified by:

iterator in interface Block

forAllPossiblePieces

public void forAllPossiblePieces(Consumer<AbstractPiece> consumer)

Description copied from interface: Block

Calls consumer for each Piece: - in no particular order - potentially calling multiple times on same Piece - even if Piece might never be returned in the iterator - it will be called at least once for every piece that is going to be returned by iterator Can be used for static analysis/introspection of the block, without actually executing them.

Specified by:

forAllPossiblePieces in interface Block

getPieceCount

public PieceCount getPieceCount()

Description copied from interface: Block

How many pieces are in this block. Sometimes we don't know (eg RepeatBlock).

Specified by:

getPieceCount in interface Block

Returns:

How many pieces are in this block.