default void |
ParallelEngine.forEachLabelVertex(VertexRange<Long> vertices,
int vertexLabelId,
int threadNum,
ExecutorService executor,
VertexSet vertexSet,
TriConsumer<Vertex<Long>,Integer,Integer> consumer) |
Apply Triconsumer for each vertex in vertices, in a parallel schema.
|
default void |
ParallelEngine.forEachLabelVertex(VertexRange<Long> vertices,
int vertexLabelId,
int threadNum,
ExecutorService executor,
TriConsumer<Vertex<Long>,Integer,Integer> consumer) |
Apply Triconsumer for each vertex in vertices, without checking the vertexSet in a parallel
schema.
|
default <MSG_T extends PrimitiveMessage>
void |
ParallelEngine.forEachVertex(VertexRange<Long> vertices,
int threadNum,
ExecutorService executor,
VertexSet vertexSet,
TriConsumer<Vertex<Long>,Integer,PrimitiveMessage> consumer,
Supplier<MSG_T> msgSupplier) |
Parallel sending messages, with a TriConsumer and msg Supplier
|
default void |
ParallelEngine.forEachVertexSendMsg(VertexRange<Long> vertices,
int threadNum,
ExecutorService executor,
VertexSet vertexSet,
TriConsumer<Vertex<Long>,Integer,DoubleMsg> consumer,
Supplier<DoubleMsg> msgSupplier) |
Iterate over vertices in VertexRange, applying lambda functions on each vertex, and send msg
with msg created from message supplier
|
default void |
ParallelEngine.forEachVertexSendMsg(VertexRange<Long> vertices,
int threadNum,
ExecutorService executor,
TriConsumer<Vertex<Long>,Integer,DoubleMsg> consumer,
Supplier<DoubleMsg> msgSupplier) |
Iterate over vertices in VertexRange(without vertex set), applying lambda functions on each
vertex, and send msg with msg created from message supplier
|
default <FRAG_T extends IFragment,MSG_T,UNUSED_T>
void |
ParallelPropertyMessageManager.parallelProcess(FRAG_T frag,
int vertexLabelId,
int threadNum,
ExecutorService executor,
Supplier<MSG_T> msgSupplier,
TriConsumer<Vertex<Long>,MSG_T,Integer> consumer) |
|