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

package org.apache.spark.streaming.scheduler.rate
  • Interfaces
    Class
    Description
    RateEstimator
    A component that estimates the rate at which an InputDStream should ingest records, based on updates at every batch completion.