com.basho.riak.spark.japi.rdd

Class RiakJavaPairRDD<K,V>

java.lang.Object

org.apache.spark.api.java.AbstractJavaRDDLike<scala.Tuple2<K,V>,org.apache.spark.api.java.JavaPairRDD<K,V>>

org.apache.spark.api.java.JavaPairRDD<K,V>

com.basho.riak.spark.japi.rdd.RiakJavaPairRDD<K,V>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.JavaRDDLike<scala.Tuple2<K,V>,org.apache.spark.api.java.JavaPairRDD<K,V>>

public class RiakJavaPairRDD<K,V>
extends org.apache.spark.api.java.JavaPairRDD<K,V>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RiakJavaPairRDD(com.basho.riak.spark.rdd.RiakRDD<scala.Tuple2<K,V>> rdd, Class<K> keyClass, Class<V> valueClass)
RiakJavaPairRDD(com.basho.riak.spark.rdd.RiakRDD<scala.Tuple2<K,V>> rdd, scala.reflect.ClassTag<K> keyClassTag, scala.reflect.ClassTag<V> valueClassTag)

Method Summary

Modifier and Type	Method and Description
RiakJavaPairRDD<K,V>	query2iRange(String index, Long from, Long to)
RiakJavaPairRDD<K,V>	queryBucketKeys(String... keys)
com.basho.riak.spark.rdd.RiakRDD<scala.Tuple2<K,V>>	rdd()

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

aggregateByKey, aggregateByKey, aggregateByKey, cache, classTag, coalesce, coalesce, cogroup, cogroup, cogroup, cogroup, cogroup, cogroup, cogroup, cogroup, cogroup, collectAsMap, combineByKey, combineByKey, combineByKey, combineByKey, countApproxDistinctByKey, countApproxDistinctByKey, countApproxDistinctByKey, countByKey, countByKeyApprox, countByKeyApprox, countByKeyApprox$default$2, distinct, distinct, filter, first, flatMapValues, foldByKey, foldByKey, foldByKey, fromJavaRDD, fromRDD, fullOuterJoin, fullOuterJoin, fullOuterJoin, groupByKey, groupByKey, groupByKey, groupWith, groupWith, groupWith, intersection, join, join, join, kClassTag, keys, leftOuterJoin, leftOuterJoin, leftOuterJoin, lookup, mapValues, partitionBy, persist, reduceByKey, reduceByKey, reduceByKey, reduceByKeyLocally, repartition, repartitionAndSortWithinPartitions, repartitionAndSortWithinPartitions, rightOuterJoin, rightOuterJoin, rightOuterJoin, sample, sample, sampleByKey, sampleByKey, sampleByKeyExact, sampleByKeyExact, saveAsHadoopDataset, saveAsHadoopFile, saveAsHadoopFile, saveAsHadoopFile, saveAsNewAPIHadoopDataset, saveAsNewAPIHadoopFile, saveAsNewAPIHadoopFile, setName, sortByKey, sortByKey, sortByKey, sortByKey, sortByKey, sortByKey, subtract, subtract, subtract, subtractByKey, subtractByKey, subtractByKey, toRDD, union, unpersist, unpersist, values, vClassTag, 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, 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, toString, wait, wait, wait

Constructor Detail

RiakJavaPairRDD

public RiakJavaPairRDD(com.basho.riak.spark.rdd.RiakRDD<scala.Tuple2<K,V>> rdd,
                       Class<K> keyClass,
                       Class<V> valueClass)

RiakJavaPairRDD

public RiakJavaPairRDD(com.basho.riak.spark.rdd.RiakRDD<scala.Tuple2<K,V>> rdd,
                       scala.reflect.ClassTag<K> keyClassTag,
                       scala.reflect.ClassTag<V> valueClassTag)

Method Detail

rdd

public com.basho.riak.spark.rdd.RiakRDD<scala.Tuple2<K,V>> rdd()

Specified by:

rdd in interface org.apache.spark.api.java.JavaRDDLike<scala.Tuple2<K,V>,org.apache.spark.api.java.JavaPairRDD<K,V>>

Overrides:

rdd in class org.apache.spark.api.java.JavaPairRDD<K,V>

query2iRange

public RiakJavaPairRDD<K,V> query2iRange(String index,
                                         Long from,
                                         Long to)

queryBucketKeys

public RiakJavaPairRDD<K,V> queryBucketKeys(String... keys)