An input stream that always returns the same RDD on each timestep.
This is the abstract base class for all input streams.
Abstract class for defining any InputDStream that has to start a receiver on worker nodes to receive external data.
Abstract class of a receiver that can be run on worker nodes to receive external data.
A wrapper class for AvroFlumeEvent's with a custom serialization format.