public final class SparkGraphComputer extends AbstractHadoopGraphComputer
AbstractHadoopGraphComputer.FeaturesGraphComputer.Exceptions, GraphComputer.Persist, GraphComputer.ResultGraphexecuted, graphFilter, hadoopGraph, logger, mapReducers, persist, resultGraph, vertexProgram, workers| Constructor and Description |
|---|
SparkGraphComputer(HadoopGraph hadoopGraph) |
| 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. |
static void |
main(String[] args) |
Future<ComputerResult> |
submit()
|
GraphComputer |
workers(int workers)
Set the desired number of workers to execute the
VertexProgram and MapReduce jobs. |
copyDirectoryIfNonExistent, edges, features, mapReduce, persist, program, result, toString, validateStatePriorToExecution, verticespublic SparkGraphComputer(HadoopGraph hadoopGraph)
public GraphComputer workers(int workers)
GraphComputerVertexProgram and MapReduce jobs.
This is a recommendation to the underlying GraphComputer implementation and is allowed to deviate accordingly by the implementation.workers in interface GraphComputerworkers in class AbstractHadoopGraphComputerworkers - the number of workers to execute the submissionpublic GraphComputer configure(String key, Object value)
GraphComputerorg.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.key - the key of the configurationvalue - the value of the configurationpublic Future<ComputerResult> submit()
GraphComputerFuture denoting a reference to the asynchronous computation and where to get the DefaultComputerResult when its is complete.Copyright © 2013–2016 Apache Software Foundation. All rights reserved.