| Package | Description |
|---|---|
| com.basho.riak.spark.japi | |
| com.basho.riak.spark.japi.rdd |
| Modifier and Type | Method and Description |
|---|---|
<T> RiakJavaRDD<T> |
SparkContextJavaFunctions.riakBucket(com.basho.riak.client.core.query.Namespace ns,
Class<T> valueClass) |
<T> RiakJavaRDD<T> |
SparkContextJavaFunctions.riakBucket(String bucketName,
String bucketType,
Class<T> valueClass) |
<T> RiakJavaRDD<T> |
SparkContextJavaFunctions.toJavaRDD(com.basho.riak.spark.rdd.RiakRDD<T> rdd,
Class<T> targetClass) |
| Modifier and Type | Method and Description |
|---|---|
<K> RiakJavaRDD<T> |
RiakJavaRDD.partitionBy2iKeys(String index,
K... keys) |
<K> RiakJavaRDD<T> |
RiakJavaRDD.partitionBy2iRanges(String index,
scala.Tuple2<K,K>... ranges) |
<K> RiakJavaRDD<T> |
RiakJavaRDD.query2iKeys(String index,
K... keys) |
RiakJavaRDD<T> |
RiakJavaRDD.query2iRange(String index,
Long from,
Long to) |
RiakJavaRDD<T> |
RiakJavaRDD.query2iRangeLocal(String index,
Long from,
Long to) |
RiakJavaRDD<T> |
RiakJavaRDD.queryAll() |
RiakJavaRDD<T> |
RiakJavaRDD.queryBucketKeys(String... keys) |
Copyright © 2016. All rights reserved.