Package org.apache.tinkerpop.gremlin.tinkergraph.process.computer

Class TinkerGraphComputer

  • All Implemented Interfaces:
    GraphComputer
    public final class TinkerGraphComputer
extends Object
implements GraphComputer
    Author:
    Marko A. Rodriguez (http://markorodriguez.com), Stephen Mallette (http://stephen.genoprime.com)

    • Method Detail

      • mapReduce

        public GraphComputer mapReduce​(MapReduce mapReduce)
        Description copied from interface: GraphComputer
        Add a MapReduce job to the set of MapReduce jobs to be executed by the GraphComputer. There can be any number of MapReduce jobs.
        Specified by:
        mapReduce in interface GraphComputer
        Parameters:
        mapReduce - the MapReduce job to add to the computation
        Returns:
        the updated GraphComputer with newly added MapReduce job

      • workers

        public GraphComputer workers​(int workers)
        Description copied from interface: GraphComputer
        Set the desired number of workers to execute the VertexProgram and MapReduce jobs. This is a recommendation to the underlying GraphComputer implementation and is allowed to deviate accordingly by the implementation.
        Specified by:
        workers in interface GraphComputer
        Parameters:
        workers - the number of workers to execute the submission
        Returns:
        the updated GraphComputer with newly set worker count

      • vertices

        public GraphComputer vertices​(Traversal<Vertex,​Vertex> vertexFilter)
        Description copied from interface: GraphComputer
        Add a filter that will limit which vertices are loaded from the graph source. The provided Traversal can only check the vertex, its vertex properties, and the vertex property properties. The loaded graph will only have those vertices that pass through the provided filter.
        Specified by:
        vertices in interface GraphComputer
        Parameters:
        vertexFilter - the traversal to verify whether or not to load the current vertex
        Returns:
        the updated GraphComputer with newly set vertex filter

      • edges

        public GraphComputer edges​(Traversal<Vertex,​Edge> edgeFilter)
        Description copied from interface: GraphComputer
        Add a filter that will limit which edges of the vertices are loaded from the graph source. The provided Traversal can only check the local star graph of the vertex and thus, can not access properties/labels of the adjacent vertices. The vertices of the loaded graph will only have those edges that pass through the provided filter.
        Specified by:
        edges in interface GraphComputer
        Parameters:
        edgeFilter - the traversal that determines which edges are loaded for each vertex
        Returns:
        the updated GraphComputer with newly set edge filter

      • vertexProperties

        public GraphComputer vertexProperties​(Traversal<Vertex,​? extends Property<?>> vertexPropertyFilter)
        Description copied from interface: GraphComputer
        Add a filter that will limit which vertex properties are loaded from the graph source. The loaded vertices will only have those properties that pass through the provided filter. To drop all vertex properties, provide a traversal like __.properties("dummy") where "dummy" is not a valid vertex property.
        Specified by:
        vertexProperties in interface GraphComputer
        Parameters:
        vertexPropertyFilter - the traversal that determines which vertex properties are loaded for each vertex
        Returns:
        the updated GraphComputer with newly set vertex property filter