org.apache.giraph.block_app.framework.piece.delegate

Class FilteringPiece<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>

java.lang.Object

org.apache.giraph.block_app.framework.piece.AbstractPiece<I,V,E,M,WV,WM,S>

org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece<I,V,E,M,WV,WM,S>

org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece<I,V,E,M,WV,WM,S>

Type Parameters:

I - Vertex id type

V - Vertex value type

E - Edge value type

M - Message type

WV - Worker value type

WM - Worker message type

S - Execution stage type

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

public class FilteringPiece<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>
extends DelegatePiece<I,V,E,M,WV,WM,S>

Piece which uses a provided suppliers to decide whether or not to run receive/send piece part on a certain vertex.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece

DelegatePiece.DelegateWorkerReceiveFunctions, DelegatePiece.DelegateWorkerSendFunctions

Nested classes/interfaces inherited from class org.apache.giraph.block_app.framework.piece.AbstractPiece

AbstractPiece.InnerVertexReceiver, AbstractPiece.InnerVertexSender

Constructor Summary

Constructors

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.

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,M extends org.apache.hadoop.io.Writable,WV,WM extends org.apache.hadoop.io.Writable,S> FilteringPiece<I,V,E,M,WV,WM,S>	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>	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.
protected DelegatePiece.DelegateWorkerReceiveFunctions	delegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I,V,E,M>> workerReceiveFunctions, BlockWorkerReceiveApi<I> workerApi, S executionStage)
protected DelegatePiece.DelegateWorkerSendFunctions	delegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions, BlockWorkerSendApi<I,V,E,M> workerApi, S executionStage)
protected String	delegationName()

Methods inherited from class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece

forAllPossiblePieces, getMessageClasses, getPieceCount, getVertexReceiver, getWrappedVertexSender, masterCompute, nextExecutionStage, registerAggregators, toString, workerContextReceive, workerContextSend, wrappedRegisterReducers

Methods inherited from class org.apache.giraph.block_app.framework.piece.AbstractPiece

equals, hashCode, iterator

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

FilteringPiece

public 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

public 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.

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,M extends org.apache.hadoop.io.Writable,WV,WM extends org.apache.hadoop.io.Writable,S> FilteringPiece<I,V,E,M,WV,WM,S> 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.

createSendFiltering

public 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> 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.

delegateWorkerSendFunctions

protected DelegatePiece.DelegateWorkerSendFunctions delegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions,
                                                                                BlockWorkerSendApi<I,V,E,M> workerApi,
                                                                                S executionStage)

Overrides:

delegateWorkerSendFunctions in class DelegatePiece<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>

delegateWorkerReceiveFunctions

protected DelegatePiece.DelegateWorkerReceiveFunctions delegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I,V,E,M>> workerReceiveFunctions,
                                                                                      BlockWorkerReceiveApi<I> workerApi,
                                                                                      S executionStage)

Overrides:

delegateWorkerReceiveFunctions in class DelegatePiece<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>

delegationName

protected String delegationName()

Overrides:

delegationName in class DelegatePiece<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>