Package org.apache.spark.streaming.scheduler
package org.apache.spark.streaming.scheduler
-
ClassDescriptionA message used by ReceiverTracker to ask all receiver's ids still stored in ReceiverTrackerEndpoint.Developer API Class having information on completed batches.Event classes for JobGeneratorDeveloper API Class having information on output operations.Trait representing any event in the ReceivedBlockTracker that updates its state.Developer API Class having information about a receiverEnumeration to identify current state of a ReceiverMessages used by the driver and ReceiverTrackerEndpoint to communicate locally.Messages used by the NetworkReceiver and the ReceiverTracker to communicate with each other.Developer API 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.Developer API A listener interface for receiving information about an ongoing streaming computation.Developer API Base trait for events related to StreamingListenerDeveloper API Track the information of input stream at specified batch time.