public static class GraphComputerTest.BadGraphComputer extends Object implements GraphComputer
GraphComputer.Exceptions, GraphComputer.Features, GraphComputer.Persist, GraphComputer.ResultGraph
Constructor and Description |
---|
BadGraphComputer() |
Modifier and Type | Method and Description |
---|---|
GraphComputer |
configure(String key,
Object value)
Set an arbitrary configuration key/value for the underlying
org.apache.commons.configuration.Configuration in the GraphComputer . |
GraphComputer |
edges(Traversal<Vertex,Edge> edgeFilter)
Add a filter that will limit which edges of the vertices are loaded from the graph source.
|
GraphComputer.Features |
features() |
GraphComputer |
mapReduce(MapReduce mapReduce)
Add a
MapReduce job to the set of MapReduce jobs to be executed by the GraphComputer . |
GraphComputer |
persist(GraphComputer.Persist persist)
Set the
GraphComputer.Persist level of the computation. |
GraphComputer |
program(VertexProgram vertexProgram)
Set the
VertexProgram to be executed by the GraphComputer . |
GraphComputer |
result(GraphComputer.ResultGraph resultGraph)
Set the
GraphComputer.ResultGraph of the computation. |
Future<ComputerResult> |
submit()
|
GraphComputer |
vertices(Traversal<Vertex,Vertex> vertexFilter)
Add a filter that will limit which vertices are loaded from the graph source.
|
GraphComputer |
workers(int workers)
Set the desired number of workers to execute the
VertexProgram and MapReduce jobs. |
public GraphComputer result(GraphComputer.ResultGraph resultGraph)
GraphComputer
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
.result
in interface GraphComputer
resultGraph
- the type of graph to be returned by ComputerResult.graph()
public GraphComputer persist(GraphComputer.Persist persist)
GraphComputer
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
.persist
in interface GraphComputer
persist
- the persistence level of the resultant computationpublic GraphComputer program(VertexProgram vertexProgram)
GraphComputer
VertexProgram
to be executed by the GraphComputer
.
There can only be one VertexProgram for the GraphComputer.program
in interface GraphComputer
vertexProgram
- the VertexProgram to be executedpublic GraphComputer mapReduce(MapReduce mapReduce)
GraphComputer
MapReduce
job to the set of MapReduce jobs to be executed by the GraphComputer
.
There can be any number of MapReduce jobs.mapReduce
in interface GraphComputer
mapReduce
- the MapReduce job to add to the computationpublic GraphComputer workers(int workers)
GraphComputer
VertexProgram
and MapReduce
jobs.
This is a recommendation to the underlying GraphComputer
implementation and is allowed to deviate accordingly by the implementation.workers
in interface GraphComputer
workers
- the number of workers to execute the submissionpublic GraphComputer vertices(Traversal<Vertex,Vertex> vertexFilter)
GraphComputer
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.vertices
in interface GraphComputer
vertexFilter
- the traversal to verify whether or not to load the current vertexpublic GraphComputer edges(Traversal<Vertex,Edge> edgeFilter)
GraphComputer
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.edges
in interface GraphComputer
edgeFilter
- the traversal that determines which edges are loaded for each vertexpublic GraphComputer configure(String key, Object value)
GraphComputer
org.apache.commons.configuration.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.configure
in interface GraphComputer
key
- the key of the configurationvalue
- the value of the configurationpublic Future<ComputerResult> submit()
GraphComputer
submit
in interface GraphComputer
Future
denoting a reference to the asynchronous computation and where to get the DefaultComputerResult
when its is complete.public GraphComputer.Features features()
features
in interface GraphComputer
Copyright © 2013–2019 Apache Software Foundation. All rights reserved.