spark.streaming

abstract class DStream[T] extends Serializable with Logging

A Discretized Stream (DStream), the basic abstraction in Spark Streaming, is a continuous sequence of RDDs (of the same type) representing a continuous stream of data (see spark.RDD for more details on RDDs).
case class Duration(millis: Long) extends Product with Serializable
class PairDStreamFunctions[K, V] extends Serializable
class StreamingContext extends Logging

A StreamingContext is the main entry point for Spark Streaming functionality.
case class Time(millis: Long) extends Product with Serializable

This is a simple class that represents an absolute instant of time.

object Milliseconds extends AnyRef

Helper object that creates instance of Duration representing a given number of milliseconds.
object Minutes extends AnyRef

Helper object that creates instance of Duration representing a given number of minutes.
object Seconds extends AnyRef

Helper object that creates instance of Duration representing a given number of seconds.
object StreamingContext extends AnyRef
object Time extends Serializable
package api
package dstream
package input
package receivers
package util

streaming