org.apache.tinkerpop.gremlin.spark.structure

Class Spark

java.lang.Object

org.apache.tinkerpop.gremlin.spark.structure.Spark

public class Spark
extends Object

This is a static cache the prevents Spark from garbage collecting unreferenced RDDs.

Author:

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

Method Summary

Modifier and Type	Method and Description
static void	close()
static void	create(Configuration configuration)
static void	create(SparkContext sparkContext)
static SparkContext	getContext()
static <any>	getRDD(String name)
static List<<any>>	getRDDs()
static boolean	hasRDD(String name)
static void	refresh()
static void	removeRDD(String name)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static void create(Configuration configuration)

create

public static void create(SparkContext sparkContext)

getContext

public static SparkContext getContext()

refresh

public static void refresh()

getRDD

public static <any> getRDD(String name)

hasRDD

public static boolean hasRDD(String name)

getRDDs

public static List<<any>> getRDDs()

removeRDD

public static void removeRDD(String name)

close

public static void close()