streaming

class CassandraStreamingRDD[R] extends CassandraTableScanRDD[R]

RDD representing a Cassandra table for Spark Streaming.
RDD representing a Cassandra table for Spark Streaming.

See also
com.datastax.spark.connector.rdd.CassandraTableScanRDD
class DStreamFunctions[T] extends WritableToCassandra[T] with Serializable with Logging
class StreamingContextFunctions extends SparkContextFunctions

Provides Cassandra-specific methods on org.apache.spark.streaming.StreamingContext.

implicit def toDStreamFunctions[T](ds: DStream[T])(implicit arg0: ClassTag[T]): DStreamFunctions[T]
implicit def toStreamingContextFunctions(ssc: StreamingContext): SparkContextFunctions