<K,V> RiakJavaPairRDD<K,V> |
SparkContextJavaFunctions.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> |
SparkContextJavaFunctions.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) |