streaming

Type Members

1. 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

2. class DStreamFunctions[T] extends WritableToCassandra[T] with Serializable with Logging

   

3. trait SparkStreamingActor extends Actor with ActorHelper

   

   Simple akka.actor.Actor mixin.

4. class SparkStreamingListener[T] extends StreamingListener

   

   Simple StreamingListener.

   Simple StreamingListener. Currently just used to listen for initialization of a receiver. Implement further to access information about an ongoing streaming computation.

5. class StreamingContextFunctions extends SparkContextFunctions

   

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

6. abstract class TypedStreamingActor[T] extends SparkStreamingActor