Package | Description |
---|---|
org.apache.tinkerpop.gremlin.spark.process.computer |
Modifier and Type | Method and Description |
---|---|
SparkGraphComputer |
SparkGraphComputer.configure(String key,
Object value) |
SparkGraphComputer |
SparkGraphComputer.graphStorageLevel(StorageLevel storageLevel)
Specifies the method by which the
VertexProgram created graph is persisted. |
SparkGraphComputer |
SparkGraphComputer.kryoRegistrationRequired(boolean required)
Determines if kryo registration is required such that attempts to serialize classes that are not registered
will result in an error.
|
SparkGraphComputer |
SparkGraphComputer.master(String clusterManager)
Sets the configuration option for
spark.master which is the cluster manager to connect to which may be
one of the allowed master URLs. |
SparkGraphComputer |
SparkGraphComputer.persistContext(boolean persist)
Determines if the Spark context should be left open preventing Spark from garbage collecting unreferenced RDDs.
|
SparkGraphComputer |
SparkGraphComputer.persistStorageLevel(StorageLevel storageLevel) |
SparkGraphComputer |
SparkGraphComputer.serializer(Class<? extends Serializer> serializer)
Specifies the
org.apache.spark.serializer.Serializer implementation to use. |
SparkGraphComputer |
SparkGraphComputer.skipGraphCache(boolean skip)
Determines if the graph RDD should be cached or not.
|
SparkGraphComputer |
SparkGraphComputer.skipPartitioner(boolean skip)
Determines if the graph RDD should be partitioned or not.
|
SparkGraphComputer |
SparkGraphComputer.sparkKryoRegistrator(Class<? extends KryoRegistrator> registrator)
Specifies the
org.apache.spark.serializer.KryoRegistrator to use to install additional types. |
SparkGraphComputer |
SparkGraphComputer.workers(int workers)
Sets the number of workers.
|
Copyright © 2013–2018 Apache Software Foundation. All rights reserved.