Package com.alibaba.graphscope.parallel

Interface ParallelEngine

All Known Implementing Classes:

BFS, PageRank, SSSP, StringApp, Traverse, WCC

public interface ParallelEngine

Field Summary

Fields

Modifier and Type	Field	Description
static int	chunkSize
static org.slf4j.Logger	logger

Method Summary

Modifier and Type	Method	Description
default void	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	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	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	forEachVertex(VertexRange<Long> vertices, int threadNum, ExecutorService executor, VertexSet vertexSet, BiConsumer<Vertex<Long>,Integer> consumer)	Apply consumer for each vertex in vertices, in a parallel schema
default void	forEachVertex(VertexRange<Long> vertices, int threadNum, ExecutorService executor, BiConsumer<Vertex<Long>,Integer> consumer)	Iterate over vertices in VertexRange, applying lambda functions on each vertex.
default void	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	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

Field Detail

logger

static final org.slf4j.Logger logger

chunkSize

static final int chunkSize

See Also:

Constant Field Values

Method Detail

forEachVertex

default void forEachVertex(VertexRange<Long> vertices,
                           int threadNum,
                           ExecutorService executor,
                           BiConsumer<Vertex<Long>,Integer> consumer)

Iterate over vertices in VertexRange, applying lambda functions on each vertex.

Parameters:

vertices - VertexRange obj contains querying vertices

threadNum - number of thread to use

executor - ThreadPoolExecutor to use

consumer - a BiConsumer(lambda function) takes vertex and thread id as input, perform the desired operation.

See Also:

BiConsumer, ThreadPoolExecutor

forEachVertex

default <MSG_T extends PrimitiveMessage> void 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

Parameters:

vertices - VertexRange obj contains querying vertices.

threadNum - number of threads to use.

executor - ThreadPoolExecutor to use.

vertexSet - A vertex set, marking querying vertices as true, others false.

consumer - a lambda function representing the per-vertex operation.

msgSupplier - supplier for msg creation.

See Also:

BiConsumer, ThreadPoolExecutor

forEachVertex

default void forEachVertex(VertexRange<Long> vertices,
                           int threadNum,
                           ExecutorService executor,
                           VertexSet vertexSet,
                           BiConsumer<Vertex<Long>,Integer> consumer)

Apply consumer for each vertex in vertices, in a parallel schema

Parameters:

vertices - VertexRange obj contains querying vertices.

threadNum - number of threads to use.

executor - ThreadPoolExecutor to use.

vertexSet - A vertex set, marking querying vertices as true, others false.

consumer - a lambda function representing the per-vertex operation.

See Also:

BiConsumer, ThreadPoolExecutor

forEachVertexSendMsg

default void 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

Parameters:

vertices - VertexRange obj contains querying vertices

threadNum - number of thread to use

executor - ThreadPoolExecutor to use

vertexSet - vertexset .

consumer - a BiConsumer(lambda function) takes vertex and thread id as input, perform the desired operation.

msgSupplier - message creator.

See Also:

BiConsumer, ThreadPoolExecutor

forEachVertexSendMsg

default void 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

Parameters:

vertices - VertexRange obj contains querying vertices

threadNum - number of thread to use

executor - ThreadPoolExecutor to use

consumer - a BiConsumer(lambda function) takes vertex and thread id as input, perform the desired operation.

msgSupplier - message creator.

See Also:

BiConsumer, ThreadPoolExecutor

forEachLabelVertex

default void 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. Used in property graph-app where the vertex id label is needed.

Parameters:

vertices - VertexRange obj contains querying vertices.

vertexLabelId - vertex label id.

threadNum - number of threads to use.

executor - ThreadPoolExecutor to use.

vertexSet - A vertex set, marking querying vertices as true, others false.

consumer - a lambda function representing the per-vertex operation.

See Also:

BiConsumer, ThreadPoolExecutor

forEachLabelVertex

default void 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. Used in property graph-app where the vertex id label is needed.

Parameters:

vertices - VertexRange obj contains querying vertices.

vertexLabelId - vertex label id.

threadNum - number of threads to use.

executor - ThreadPoolExecutor to use.

consumer - a lambda function representing the per-vertex operation.

See Also:

BiConsumer, ThreadPoolExecutor