M
- The VertexProgram
message classpublic static final class MessageScope.Local<M> extends MessageScope
Traversal
that dictates how to go from the sending vertex to the receiving vertex.
This is the preferred message scope as it can potentially be optimized by the underlying Messenger
implementation.
The preferred optimization is to not distribute a message object to all adjacent vertices.
Instead, allow the recipients to read a single message object stored at the "sending" vertex.
This is possible via `Traversal.reverse()`. This optimizations greatly reduces the amount of data created in the computation.Modifier and Type | Class and Description |
---|---|
static class |
MessageScope.Local.ReverseTraversalSupplier
A helper class that can be used to generate the reverse traversal of the traversal within a
MessageScope.Local . |
MessageScope.Global, MessageScope.Local<M>
Modifier and Type | Field and Description |
---|---|
BiFunction<M,Edge,M> |
edgeFunction |
Supplier<? extends org.apache.tinkerpop.gremlin.process.traversal.Traversal<Vertex,Edge>> |
incidentTraversal |
Modifier and Type | Method and Description |
---|---|
BiFunction<M,Edge,M> |
getEdgeFunction() |
Supplier<? extends org.apache.tinkerpop.gremlin.process.traversal.Traversal<Vertex,Edge>> |
getIncidentTraversal() |
static <M> MessageScope.Local<M> |
of(Supplier<? extends org.apache.tinkerpop.gremlin.process.traversal.Traversal<Vertex,Edge>> incidentTraversal) |
static <M> MessageScope.Local<M> |
of(Supplier<? extends org.apache.tinkerpop.gremlin.process.traversal.Traversal<Vertex,Edge>> incidentTraversal,
BiFunction<M,Edge,M> edgeFunction) |
public final Supplier<? extends org.apache.tinkerpop.gremlin.process.traversal.Traversal<Vertex,Edge>> incidentTraversal
public final BiFunction<M,Edge,M> edgeFunction
public static <M> MessageScope.Local<M> of(Supplier<? extends org.apache.tinkerpop.gremlin.process.traversal.Traversal<Vertex,Edge>> incidentTraversal)
public static <M> MessageScope.Local<M> of(Supplier<? extends org.apache.tinkerpop.gremlin.process.traversal.Traversal<Vertex,Edge>> incidentTraversal, BiFunction<M,Edge,M> edgeFunction)
public BiFunction<M,Edge,M> getEdgeFunction()
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.