com.basho.riak.spark.japi

Class RDDJavaFunctions<T>

java.lang.Object

com.basho.riak.spark.japi.RDDJavaFunctions<T>

public class RDDJavaFunctions<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RDDJavaFunctions.JobFunc<T,U>

Field Summary

Fields

Modifier and Type	Field and Description
org.apache.spark.rdd.RDD<T>	rdd
com.basho.riak.spark.rdd.RDDFunctions<T>	rddFunctions

Constructor Summary

Constructors

Constructor and Description
RDDJavaFunctions(org.apache.spark.rdd.RDD<T> rdd)

Method Summary

Modifier and Type	Method and Description
com.basho.riak.spark.rdd.connector.RiakConnector	defaultConnector()
org.apache.spark.SparkConf	getConf()
void	saveToRiak(com.basho.riak.client.core.query.Namespace ns)
void	saveToRiak(com.basho.riak.client.core.query.Namespace ns, com.basho.riak.spark.writer.WriteDataMapperFactory<T,scala.Tuple2<String,Object>> vwf)
void	saveToRiak(String bucketName)
void	saveToRiak(String bucketName, String bucketType)
void	saveToRiak(String bucketName, String bucketType, com.basho.riak.spark.writer.WriteConf writeConf, com.basho.riak.spark.rdd.connector.RiakConnector connector, com.basho.riak.spark.writer.WriteDataMapperFactory<T,scala.Tuple2<String,Object>> vwf)
void	saveToRiak(String bucketName, com.basho.riak.spark.writer.WriteDataMapperFactory<T,scala.Tuple2<String,Object>> vwf)
void	saveToRiakTS(com.basho.riak.spark.rdd.connector.RiakConnector connector, String bucketType, String bucketName, com.basho.riak.spark.writer.WriteConf writeConf, com.basho.riak.spark.writer.WriteDataMapperFactory<T,com.basho.riak.spark.writer.ts.RowDef> factory)
void	saveToRiakTS(String bucketName)

Methods inherited from class java.lang.Object

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

Field Detail

rdd

public final org.apache.spark.rdd.RDD<T> rdd

rddFunctions

public final com.basho.riak.spark.rdd.RDDFunctions<T> rddFunctions

Constructor Detail

RDDJavaFunctions

public RDDJavaFunctions(org.apache.spark.rdd.RDD<T> rdd)

Method Detail

defaultConnector

public com.basho.riak.spark.rdd.connector.RiakConnector defaultConnector()

getConf

public org.apache.spark.SparkConf getConf()

saveToRiak

public void saveToRiak(String bucketName,
                       String bucketType)

saveToRiak

public void saveToRiak(String bucketName)

saveToRiak

public void saveToRiak(com.basho.riak.client.core.query.Namespace ns)

saveToRiak

public void saveToRiak(String bucketName,
                       String bucketType,
                       com.basho.riak.spark.writer.WriteConf writeConf,
                       com.basho.riak.spark.rdd.connector.RiakConnector connector,
                       com.basho.riak.spark.writer.WriteDataMapperFactory<T,scala.Tuple2<String,Object>> vwf)

saveToRiak

public void saveToRiak(String bucketName,
                       com.basho.riak.spark.writer.WriteDataMapperFactory<T,scala.Tuple2<String,Object>> vwf)

saveToRiak

public void saveToRiak(com.basho.riak.client.core.query.Namespace ns,
                       com.basho.riak.spark.writer.WriteDataMapperFactory<T,scala.Tuple2<String,Object>> vwf)

saveToRiakTS

public void saveToRiakTS(com.basho.riak.spark.rdd.connector.RiakConnector connector,
                         String bucketType,
                         String bucketName,
                         com.basho.riak.spark.writer.WriteConf writeConf,
                         com.basho.riak.spark.writer.WriteDataMapperFactory<T,com.basho.riak.spark.writer.ts.RowDef> factory)

saveToRiakTS

public void saveToRiakTS(String bucketName)