org.apache.tinkerpop.gremlin.spark.structure.io

Class PersistedInputRDD

java.lang.Object

org.apache.tinkerpop.gremlin.spark.structure.io.PersistedInputRDD

All Implemented Interfaces:

InputRDD

public final class PersistedInputRDD
extends Object
implements InputRDD

Author:

Marko A. Rodriguez (http://markorodriguez.com)

Constructor Summary

Constructors

Constructor and Description
PersistedInputRDD()

Method Summary

Modifier and Type	Method and Description
<any>	readGraphRDD(Configuration configuration, JavaSparkContext sparkContext) Read the graphRDD from the underlying graph system.
<K,V> <any>	readMemoryRDD(Configuration configuration, String memoryKey, JavaSparkContext sparkContext) Read a memoryRDD from the storage location.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistedInputRDD

public PersistedInputRDD()

Method Detail

readGraphRDD

public <any> readGraphRDD(Configuration configuration,
                          JavaSparkContext sparkContext)

Description copied from interface: InputRDD

Read the graphRDD from the underlying graph system.

Specified by:

readGraphRDD in interface InputRDD

Parameters:

configuration - the configuration for the SparkGraphComputer

sparkContext - the Spark context with the requisite methods for generating a JavaPairRDD

Returns:

an adjacency list representation of the underlying graph system.

readMemoryRDD

public <K,V> <any> readMemoryRDD(Configuration configuration,
                                 String memoryKey,
                                 JavaSparkContext sparkContext)

Description copied from interface: InputRDD

Read a memoryRDD from the storage location. The default implementation returns an empty RDD.

Specified by:

readMemoryRDD in interface InputRDD

Type Parameters:

K - the key class of the memoryRDD

V - the value class of the memoryRDD

Parameters:

configuration - the configuration for the SparkGraphComputer

memoryKey - the memory key of the memoryRDD

sparkContext - the Spark context with the requisite methods for generating a JavaPairRDD

Returns:

the memoryRDD with respective key/value pairs.