org.apache.spark.streaming

dstream

package dstream

Visibility
  1. Public
  2. All

Type Members

  1. class ConstantInputDStream[T] extends InputDStream[T]

    An input stream that always returns the same RDD on each timestep.

  2. abstract class InputDStream[T] extends DStream[T]

    This is the abstract base class for all input streams.

  3. abstract class NetworkInputDStream[T] extends InputDStream[T]

    Abstract class for defining any InputDStream that has to start a receiver on worker nodes to receive external data.

  4. abstract class NetworkReceiver[T] extends Serializable with Logging

    Abstract class of a receiver that can be run on worker nodes to receive external data.

  5. class SparkFlumeEvent extends Externalizable

    A wrapper class for AvroFlumeEvent's with a custom serialization format.