com.basho.riak.spark.japi

Class SparkContextJavaFunctions

java.lang.Object

com.basho.riak.spark.japi.SparkContextJavaFunctions

public class SparkContextJavaFunctions
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SparkContextJavaFunctions.ConversionFunction<T>

Field Summary

Fields

Modifier and Type	Field and Description
org.apache.spark.SparkContext	sparkContext

Method Summary

Modifier and Type	Method and Description
<T> RiakJavaRDD<T>	riakBucket(com.basho.riak.client.core.query.Namespace ns, Class<T> valueClass)
<K,V> RiakJavaPairRDD<K,V>	riakBucket(com.basho.riak.client.core.query.Namespace ns, scala.Function2<com.basho.riak.client.core.query.Location,com.basho.riak.client.core.query.RiakObject,scala.Tuple2<K,V>> convert, Class<K> keyClass, Class<V> valueClass)
<K,V> RiakJavaPairRDD<K,V>	riakBucket(String bucketName, scala.Function2<com.basho.riak.client.core.query.Location,com.basho.riak.client.core.query.RiakObject,scala.Tuple2<K,V>> convert, String bucketType, Class<K> keyClass, Class<V> valueClass)
<T> RiakJavaRDD<T>	riakBucket(String bucketName, String bucketType, Class<T> valueClass)
<T> RiakTSJavaRDD<T>	riakTSTable(String bucketName, Class<T> targetClass)
<T> RiakTSJavaRDD<T>	riakTSTable(String bucketName, org.apache.spark.sql.types.StructType schema, Class<T> targetClass)
<T> RiakJavaRDD<T>	toJavaRDD(com.basho.riak.spark.rdd.RiakRDD<T> rdd, Class<T> targetClass)

Methods inherited from class java.lang.Object

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

Field Detail

sparkContext

public final org.apache.spark.SparkContext sparkContext

Method Detail

toJavaRDD

public <T> RiakJavaRDD<T> toJavaRDD(com.basho.riak.spark.rdd.RiakRDD<T> rdd,
                                    Class<T> targetClass)

riakBucket

public <T> RiakJavaRDD<T> riakBucket(com.basho.riak.client.core.query.Namespace ns,
                                     Class<T> valueClass)

riakBucket

public <T> RiakJavaRDD<T> riakBucket(String bucketName,
                                     String bucketType,
                                     Class<T> valueClass)

riakBucket

public <K,V> RiakJavaPairRDD<K,V> riakBucket(com.basho.riak.client.core.query.Namespace ns,
                                             scala.Function2<com.basho.riak.client.core.query.Location,com.basho.riak.client.core.query.RiakObject,scala.Tuple2<K,V>> convert,
                                             Class<K> keyClass,
                                             Class<V> valueClass)

riakBucket

public <K,V> RiakJavaPairRDD<K,V> riakBucket(String bucketName,
                                             scala.Function2<com.basho.riak.client.core.query.Location,com.basho.riak.client.core.query.RiakObject,scala.Tuple2<K,V>> convert,
                                             String bucketType,
                                             Class<K> keyClass,
                                             Class<V> valueClass)

riakTSTable

public <T> RiakTSJavaRDD<T> riakTSTable(String bucketName,
                                        Class<T> targetClass)

riakTSTable

public <T> RiakTSJavaRDD<T> riakTSTable(String bucketName,
                                        org.apache.spark.sql.types.StructType schema,
                                        Class<T> targetClass)