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

Class GraphComputerTest.BadGraphComputer

java.lang.Object
org.apache.tinkerpop.gremlin.process.computer.GraphComputerTest.BadGraphComputer
All Implemented Interfaces:
GraphComputer
Enclosing class:
GraphComputerTest
public static class GraphComputerTest.BadGraphComputer extends Object implements GraphComputer

  • Constructor Details

    • BadGraphComputer

      public BadGraphComputer()

  • Method Details

    • result

      public GraphComputer result(GraphComputer.ResultGraph resultGraph)
      Description copied from interface: GraphComputer
      Set the GraphComputer.ResultGraph of the computation. If this is not set explicitly by the user, then the VertexProgram can choose the most efficient result for its intended use. If there is no declared vertex program, then the GraphComputer defaults to GraphComputer.ResultGraph.ORIGINAL.
      Specified by:
      result in interface GraphComputer
      Parameters:
      resultGraph - the type of graph to be returned by ComputerResult.graph()
      Returns:
      the updated GraphComputer with newly set result graph

    • persist

      public GraphComputer persist(GraphComputer.Persist persist)
      Description copied from interface: GraphComputer
      Set the GraphComputer.Persist level of the computation. If this is not set explicitly by the user, then the\ VertexProgram can choose the most efficient persist for the its intended use. If there is no declared vertex program, then the GraphComputer defaults to GraphComputer.Persist.NOTHING.
      Specified by:
      persist in interface GraphComputer
      Parameters:
      persist - the persistence level of the resultant computation
      Returns:
      the updated GraphComputer with newly set persist

    • program

      public GraphComputer program(VertexProgram vertexProgram)
      Description copied from interface: GraphComputer
      Set the VertexProgram to be executed by the GraphComputer. There can only be one VertexProgram for the GraphComputer.
      Specified by:
      program in interface GraphComputer
      Parameters:
      vertexProgram - the VertexProgram to be executed
      Returns:
      the updated GraphComputer with newly set VertexProgram

    • 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

    • configure

      public GraphComputer configure(String key, Object value)
      Description copied from interface: GraphComputer
      Set an arbitrary configuration key/value for the underlying Configuration in the GraphComputer. Typically, the other fluent methods in GraphComputer should be used to configure the computation. However, for some custom configuration in the underlying engine, this method should be used. Different GraphComputer implementations will have different key/values and thus, parameters placed here are generally not universal to all GraphComputer implementations. The default implementation simply does nothing and returns the GraphComputer unchanged.
      Specified by:
      configure in interface GraphComputer
      Parameters:
      key - the key of the configuration
      value - the value of the configuration
      Returns:
      the updated GraphComputer with newly set key/value configuration

    • submit

      public Future<ComputerResult> submit()
      Description copied from interface: GraphComputer
      Submit the VertexProgram and the set of MapReduce jobs for execution by the GraphComputer.
      Specified by:
      submit in interface GraphComputer
      Returns:
      a Future denoting a reference to the asynchronous computation and where to get the DefaultComputerResult when its is complete.

    • features

      public GraphComputer.Features features()
      Specified by:
      features in interface GraphComputer