Event classes for JobGenerator
Trait representing any event in the ReceivedBlockTracker that updates its state.
Messages used by the driver and ReceiverTrackerEndpoint to communicate locally.
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
A message used by ReceiverTracker to ask all receiver's ids still stored in ReceiverTrackerEndpoint.
:: DeveloperApi :: Class having information on completed batches.
:: DeveloperApi :: Class having information on output operations.
:: DeveloperApi :: Class having information about a receiver
Enumeration to identify current state of a Receiver
:: DeveloperApi :: A simple StreamingListener that logs summary statistics across Spark Streaming batches param: numBatchInfos Number of last batches to consider for generating statistics (default: 10)
This message will trigger ReceiverTrackerEndpoint to send stop signals to all registered receivers.
:: DeveloperApi :: Track the information of input stream at specified batch time.