com.basho.riak.spark.japi.rdd

Class RiakJavaRDD<T>

java.lang.Object

org.apache.spark.api.java.AbstractJavaRDDLike<T,org.apache.spark.api.java.JavaRDD<T>>

org.apache.spark.api.java.JavaRDD<T>

com.basho.riak.spark.japi.rdd.RiakJavaRDD<T>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.JavaRDDLike<T,org.apache.spark.api.java.JavaRDD<T>>

public class RiakJavaRDD<T>
extends org.apache.spark.api.java.JavaRDD<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RiakJavaRDD(com.basho.riak.spark.rdd.RiakRDD<T> rdd, Class<T> clazz)
RiakJavaRDD(com.basho.riak.spark.rdd.RiakRDD<T> rdd, scala.reflect.ClassTag<T> classTag)

Method Summary

Modifier and Type	Method and Description
scala.reflect.ClassTag<T>	classTag()
<K> RiakJavaRDD<T>	partitionBy2iKeys(String index, K... keys)
<K> RiakJavaRDD<T>	partitionBy2iRanges(String index, scala.Tuple2<K,K>... ranges)
<K> RiakJavaRDD<T>	query2iKeys(String index, K... keys)
RiakJavaRDD<T>	query2iRange(String index, Long from, Long to)
RiakJavaRDD<T>	query2iRangeLocal(String index, Long from, Long to)
RiakJavaRDD<T>	queryAll()
RiakJavaRDD<T>	queryBucketKeys(String... keys)
com.basho.riak.spark.rdd.RiakRDD<T>	rdd()

Methods inherited from class org.apache.spark.api.java.JavaRDD

cache, coalesce, coalesce, distinct, distinct, filter, fromRDD, intersection, persist, randomSplit, randomSplit, repartition, sample, sample, setName, sortBy, subtract, subtract, subtract, toRDD, toString, union, unpersist, unpersist, wrapRDD

Methods inherited from class org.apache.spark.api.java.AbstractJavaRDDLike

aggregate, cartesian, checkpoint, collect, collectAsync, collectPartitions, context, count, countApprox, countApprox, countApproxDistinct, countAsync, countByValue, countByValueApprox, countByValueApprox, first, flatMap, flatMapToDouble, flatMapToPair, fold, foreach, foreachAsync, foreachPartition, foreachPartitionAsync, getCheckpointFile, getNumPartitions, getStorageLevel, glom, groupBy, groupBy, id, isCheckpointed, isEmpty, iterator, keyBy, map, mapPartitions, mapPartitions, mapPartitionsToDouble, mapPartitionsToDouble, mapPartitionsToPair, mapPartitionsToPair, mapPartitionsWithIndex, mapPartitionsWithIndex$default$2, mapToDouble, mapToPair, max, min, name, partitioner, partitions, pipe, pipe, pipe, reduce, saveAsObjectFile, saveAsTextFile, saveAsTextFile, splits, take, takeAsync, takeOrdered, takeOrdered, takeSample, takeSample, toArray, toDebugString, toLocalIterator, top, top, treeAggregate, treeAggregate, treeReduce, treeReduce, zip, zipPartitions, zipWithIndex, zipWithUniqueId

Methods inherited from class java.lang.Object

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

Constructor Detail

RiakJavaRDD

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

RiakJavaRDD

public RiakJavaRDD(com.basho.riak.spark.rdd.RiakRDD<T> rdd,
                   scala.reflect.ClassTag<T> classTag)

Method Detail

rdd

public com.basho.riak.spark.rdd.RiakRDD<T> rdd()

Specified by:

rdd in interface org.apache.spark.api.java.JavaRDDLike<T,org.apache.spark.api.java.JavaRDD<T>>

Overrides:

rdd in class org.apache.spark.api.java.JavaRDD<T>

classTag

public scala.reflect.ClassTag<T> classTag()

Specified by:

classTag in interface org.apache.spark.api.java.JavaRDDLike<T,org.apache.spark.api.java.JavaRDD<T>>

Overrides:

classTag in class org.apache.spark.api.java.JavaRDD<T>

query2iRange

public RiakJavaRDD<T> query2iRange(String index,
                                   Long from,
                                   Long to)

query2iRangeLocal

public RiakJavaRDD<T> query2iRangeLocal(String index,
                                        Long from,
                                        Long to)

query2iKeys

@SafeVarargs
public final <K> RiakJavaRDD<T> query2iKeys(String index,
                                                         K... keys)

queryBucketKeys

public RiakJavaRDD<T> queryBucketKeys(String... keys)

queryAll

public RiakJavaRDD<T> queryAll()

partitionBy2iRanges

@SafeVarargs
public final <K> RiakJavaRDD<T> partitionBy2iRanges(String index,
                                                                 scala.Tuple2<K,K>... ranges)

partitionBy2iKeys

@SafeVarargs
public final <K> RiakJavaRDD<T> partitionBy2iKeys(String index,
                                                               K... keys)