I
- Vertex id typeV
- Vertex value typeE
- Edge value typeM
- Message typeWV
- Worker value typeWM
- Worker message typeS
- Execution stage typepublic 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>
DelegatePiece.DelegateWorkerReceiveFunctions, DelegatePiece.DelegateWorkerSendFunctions
AbstractPiece.InnerVertexReceiver, AbstractPiece.InnerVertexSender
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 . |
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> |
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> |
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() |
forAllPossiblePieces, getMessageClasses, getPieceCount, getVertexReceiver, getWrappedVertexSender, masterCompute, nextExecutionStage, registerAggregators, toString, workerContextReceive, workerContextSend, wrappedRegisterReducers
equals, hashCode, iterator
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
forEach, spliterator
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)
toCallSend
to filter
calls to vertexSend
, and passed toCallReceive
to filter
calls to vertexReceive
, on passed innerPiece
.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)
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)
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)
protected DelegatePiece.DelegateWorkerSendFunctions delegateWorkerSendFunctions(ArrayList<AbstractPiece.InnerVertexSender> workerSendFunctions, BlockWorkerSendApi<I,V,E,M> workerApi, S executionStage)
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>
protected DelegatePiece.DelegateWorkerReceiveFunctions delegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I,V,E,M>> workerReceiveFunctions, BlockWorkerReceiveApi<I> workerApi, S executionStage)
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>
protected String delegationName()
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>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.