I
- Vertex id typeV
- Vertex value typeE
- Edge value typepublic 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
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 . |
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> |
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> |
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public FilteringBlock(SupplierFromVertex<I,V,E,Boolean> toCallSend, SupplierFromVertex<I,V,E,Boolean> toCallReceive, Block block)
toCallSend
to filter
calls to vertexSend
, and passed toCallReceive
to filter
calls to vertexReceive
, on all pieces within passed block
.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)
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)
public Iterator<AbstractPiece> iterator()
Block
iterator
in interface Iterable<AbstractPiece>
iterator
in interface Block
public void forAllPossiblePieces(Consumer<AbstractPiece> consumer)
Block
forAllPossiblePieces
in interface Block
public PieceCount getPieceCount()
Block
getPieceCount
in interface Block
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.