Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece.delegate |
Pieces that delegate their work to a set of one or multiple other Pieces.
|
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.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.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.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.