spark

streaming

package streaming

Visibility
  1. Public
  2. All

Type Members

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

  2. case class Duration(millis: Long) extends Product with Serializable

  3. class PairDStreamFunctions[K, V] extends Serializable

  4. class StreamingContext extends Logging

    A StreamingContext is the main entry point for Spark Streaming functionality.

  5. case class Time(millis: Long) extends Product with Serializable

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

Value Members

  1. object Milliseconds extends AnyRef

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

  2. object Minutes extends AnyRef

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

  3. object Seconds extends AnyRef

    Helper object that creates instance of Duration representing a given number of seconds.

  4. object StreamingContext extends AnyRef

  5. object Time extends Serializable

  6. package api

  7. package dstream

  8. package input

  9. package receivers

  10. package util