Package org.apache.spark.streaming.scheduler.rate

Interface Summary

Interface	Description
RateEstimator	A component that estimates the rate at which an InputDStream should ingest records, based on updates at every batch completion.