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.:: DeveloperApi :: Class having information on completed batches.Event classes for JobGenerator:: DeveloperApi :: Class having information on output operations.Trait representing any event in the ReceivedBlockTracker that updates its state.:: DeveloperApi :: 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.:: 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 :: A listener interface for receiving information about an ongoing streaming computation.:: DeveloperApi :: Base trait for events related to StreamingListener:: DeveloperApi :: Track the information of input stream at specified batch time.