Packages

object RateEstimator extends Serializable

Source
RateEstimator.scala
Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RateEstimator
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def create(conf: SparkConf, batchInterval: Duration): RateEstimator

    Return a new RateEstimator based on the value of spark.streaming.backpressure.rateEstimator.

    Return a new RateEstimator based on the value of spark.streaming.backpressure.rateEstimator.

    The only known and acceptable estimator right now is pid.

    returns

    An instance of RateEstimator

    Exceptions thrown

    IllegalArgumentException if the configured RateEstimator is not pid.