rdd

Type Members

1. class CassandraJoinRDD[L, R] extends CassandraRDD[(L, R)] with CassandraTableRowReaderProvider[R]

   An RDD that will do a selecting join between left RDD and the specified Cassandra Table This will perform individual selects to retrieve the rows from Cassandra and will take advantage of RDDs that have been partitioned with the com.datastax.spark.connector.rdd.partitioner.ReplicaPartitioner

2. abstract class CassandraRDD[R] extends RDD[R]

3. trait CassandraTableRowReaderProvider[R] extends AnyRef

   Used to get a RowReader of type [R] for transforming the rows of a particular Cassandra table into scala objects.

4. class CassandraTableScanRDD[R] extends CassandraRDD[R] with CassandraTableRowReaderProvider[R]

   RDD representing a Table Scan of A Cassandra table.

5. sealed trait ClusteringOrder extends Serializable

6. case class CqlWhereClause(predicates: Seq[String], values: Seq[Any]) extends Product with Serializable

   Represents a logical conjunction of CQL predicates.

7. class EmptyCassandraRDD[R] extends CassandraRDD[R]

   Represents a CassandraRDD with no rows.

8. case class ReadConf(splitCount: Option[Int] = scala.None, splitSizeInMB: Int = ReadConf.SplitSizeInMBParam.default, fetchSizeInRows: Int = ..., consistencyLevel: ConsistencyLevel = ..., taskMetricsEnabled: Boolean = ReadConf.TaskMetricParam.default, throughputJoinQueryPerSec: Long = ...) extends Product with Serializable

   Read settings for RDD

9. trait ValidRDDType[T] extends AnyRef

   Annotations

   @implicitNotFound( ... )