Event classes for JobGenerator
Trait representing any event in the ReceivedBlockTracker that updates its state.
Messages used by the NetworkReceiver and the ReceiverTracker to communicate with each other.
:: DeveloperApi :: A listener interface for receiving information about an ongoing streaming computation.
:: DeveloperApi :: Base trait for events related to StreamingListener
Class representing the blocks of all the streams allocated to a batch
:: DeveloperApi :: Class having information on completed batches.
Class representing a Spark computation.
This class generates jobs from DStreams as well as drives checkpointing and cleaning up DStream metadata.
This class schedules jobs to be run on Spark.
Class representing a set of Jobs belong to the same batch.
Information about blocks received by the receiver
Class that keep track of all the received blocks, and allocate them to batches when required.
:: DeveloperApi :: Class having information about a receiver
This class manages the execution of the receivers of ReceiverInputDStreams.
:: DeveloperApi :: A simple StreamingListener that logs summary statistics across Spark Streaming batches
Asynchronously passes StreamingListenerEvents to registered StreamingListeners.
An event used in the listener to shutdown the listener daemon thread.