Package

com.datastax.spark.connector

streaming

Permalink

package streaming

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. streaming
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class CassandraStreamingRDD[R] extends CassandraTableScanRDD[R]

    Permalink

    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

    Permalink
  3. class StreamingContextFunctions extends SparkContextFunctions

    Permalink

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

Value Members

  1. implicit def toDStreamFunctions[T](ds: DStream[T])(implicit arg0: ClassTag[T]): DStreamFunctions[T]

    Permalink
  2. implicit def toStreamingContextFunctions(ssc: StreamingContext): SparkContextFunctions

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped