com.basho.riak.spark.japi

Class SparkJavaUtil

java.lang.Object

com.basho.riak.spark.japi.SparkJavaUtil

public final class SparkJavaUtil
extends Object

Method Summary

Modifier and Type	Method and Description
static <T> RDDJavaFunctions<T>	javaFunctions(org.apache.spark.api.java.JavaRDD<T> rdd)
static SparkContextJavaFunctions	javaFunctions(org.apache.spark.api.java.JavaSparkContext sparkContext)
static <T> RDDJavaFunctions<T>	javaFunctions(org.apache.spark.rdd.RDD<T> rdd)
static SparkContextJavaFunctions	javaFunctions(org.apache.spark.SparkContext sparkContext)

Methods inherited from class java.lang.Object

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

Method Detail

javaFunctions

public static SparkContextJavaFunctions javaFunctions(org.apache.spark.SparkContext sparkContext)

javaFunctions

public static SparkContextJavaFunctions javaFunctions(org.apache.spark.api.java.JavaSparkContext sparkContext)

javaFunctions

public static <T> RDDJavaFunctions<T> javaFunctions(org.apache.spark.rdd.RDD<T> rdd)

javaFunctions

public static <T> RDDJavaFunctions<T> javaFunctions(org.apache.spark.api.java.JavaRDD<T> rdd)