package streaming
- Alphabetic
- By Inheritance
- streaming
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
class
CassandraStreamingRDD[R] extends CassandraTableScanRDD[R]
RDD representing a Cassandra table for Spark Streaming.
RDD representing a Cassandra table for Spark Streaming.
- class DStreamFunctions[T] extends WritableToCassandra[T] with Serializable with Logging
-
class
StreamingContextFunctions extends SparkContextFunctions
Provides Cassandra-specific methods on
org.apache.spark.streaming.StreamingContext
.
Value Members
- implicit def toDStreamFunctions[T](ds: DStream[T])(implicit arg0: ClassTag[T]): DStreamFunctions[T]
- implicit def toStreamingContextFunctions(ssc: StreamingContext): SparkContextFunctions