c

org.checkita.dqf.core.metrics.rdd.regular.BasicNumericRDDMetrics

NumberBetweenRDDMetricCalculator

case class NumberBetweenRDDMetricCalculator(cnt: Long, lowerCompareValue: Double, upperCompareValue: Double, includeBound: Boolean, reversed: Boolean, failCount: Long = 0, status: CalculatorStatus = CalculatorStatus.Success, failMsg: String = "OK") extends RDDMetricCalculator with ReversibleRDDCalculator with Product with Serializable

Calculates count of rows for which column value is within the lowerCompareValue:upperCompareValue interval

cnt

Current count of appearance

lowerCompareValue

Target lower interval bound to compare with

upperCompareValue

Target upper interval bound to compare with

includeBound

Flag which sets whether interval bounds are included or excluded from the interval.

returns

result map with keys: "NUMBER_BETWEEN"

Linear Supertypes
Serializable, Serializable, Product, Equals, ReversibleRDDCalculator, RDDMetricCalculator, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NumberBetweenRDDMetricCalculator
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. ReversibleRDDCalculator
  7. RDDMetricCalculator
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new NumberBetweenRDDMetricCalculator(lowerCompareValue: Double, upperCompareValue: Double, includeBound: Boolean, reversed: Boolean)
  2. new NumberBetweenRDDMetricCalculator(cnt: Long, lowerCompareValue: Double, upperCompareValue: Double, includeBound: Boolean, reversed: Boolean, failCount: Long = 0, status: CalculatorStatus = CalculatorStatus.Success, failMsg: String = "OK")

    cnt

    Current count of appearance

    lowerCompareValue

    Target lower interval bound to compare with

    upperCompareValue

    Target upper interval bound to compare with

    includeBound

    Flag which sets whether interval bounds are included or excluded from the interval.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. val cnt: Long
  7. def copyWithError(status: CalculatorStatus, msg: String, failInc: Long = 1): RDDMetricCalculator

    Copy calculator with error status and corresponding message.

    Copy calculator with error status and corresponding message.

    status

    Calculator status to copy with

    msg

    Failure message

    failInc

    Failure increment

    returns

    Copy of this calculator with error status

    Attributes
    protected
    Definition Classes
    NumberBetweenRDDMetricCalculator → RDDMetricCalculator
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. val failCount: Long
    Attributes
    protected
    Definition Classes
    NumberBetweenRDDMetricCalculator → RDDMetricCalculator
  10. val failMsg: String
    Attributes
    protected
    Definition Classes
    NumberBetweenRDDMetricCalculator → RDDMetricCalculator
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  12. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def getFailCounter: Long

    Gets current metric failure counts

    Gets current metric failure counts

    returns

    Failure count

    Definition Classes
    RDDMetricCalculator
  14. def getFailMessage: String

    Gets current failure or error message

    Gets current failure or error message

    returns

    Failure message

    Definition Classes
    RDDMetricCalculator
  15. def getStatus: CalculatorStatus

    Gets current metric calculator status

    Gets current metric calculator status

    returns

    Calculator status

    Definition Classes
    RDDMetricCalculator
  16. val includeBound: Boolean
  17. def increment(values: Seq[Any]): RDDMetricCalculator

    Safely updates metric calculator with respect to specified error collection logic (direct or reversed).

    Safely updates metric calculator with respect to specified error collection logic (direct or reversed).

    values

    values to process

    returns

    updated calculator

    Definition Classes
    ReversibleRDDCalculator
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. val lowerCompareValue: Double
  20. def merge(m2: RDDMetricCalculator): RDDMetricCalculator

    Merges two metric calculators together

    Merges two metric calculators together

    m2

    second metric calculator

    returns

    merged metric calculator

    Definition Classes
    NumberBetweenRDDMetricCalculator → RDDMetricCalculator
  21. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. def result(): Map[String, (Double, Option[String])]

    Gets results of calculator in the current state

    Gets results of calculator in the current state

    returns

    Map of (result_name -> (result, additionalResults))

    Definition Classes
    NumberBetweenRDDMetricCalculator → RDDMetricCalculator
  25. val reversed: Boolean
    Attributes
    protected
    Definition Classes
    NumberBetweenRDDMetricCalculator → ReversibleRDDCalculator
  26. val status: CalculatorStatus
    Attributes
    protected
    Definition Classes
    NumberBetweenRDDMetricCalculator → RDDMetricCalculator
  27. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  28. def tryToIncrement(values: Seq[Any]): RDDMetricCalculator

    Increment metric calculator.

    Increment metric calculator. May throw an exception. Direct error collection logic implies that numeric values which are outside of provided interval are considered as metric failure and are collected.

    values

    values to process

    returns

    updated calculator or throws an exception

    Attributes
    protected
    Definition Classes
    NumberBetweenRDDMetricCalculator → RDDMetricCalculator
  29. def tryToIncrementReversed(values: Seq[Any]): RDDMetricCalculator

    Increment metric calculator with REVERSED error collection logic.

    Increment metric calculator with REVERSED error collection logic. May throw an exception. Reversed error collection logic implies that numeric values which are inside of the provided interval are considered as metric failure and are collected.

    values

    values to process

    returns

    updated calculator or throws an exception

    Attributes
    protected
    Definition Classes
    NumberBetweenRDDMetricCalculator → ReversibleRDDCalculator
  30. val upperCompareValue: Double
  31. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from ReversibleRDDCalculator

Inherited from RDDMetricCalculator

Inherited from AnyRef

Inherited from Any

Ungrouped