numeric

Type Members

1. class Avg[T] extends RxTransformer[T, Double]

   

   Computes the average of the source elements.

   Computes the average of the source elements. Emits either the rolling average or only the final value.

2. class BasicStats[T] extends RxTransformer[T, Stats]

   

   Computes the statistics parameters of the source elements.

   Computes the statistics parameters of the source elements. Emits either the rolling stats or only the final value.

3. class Max[T] extends RxTransformer[T, T]

   

   Computes the maximum of the source elements.

   Computes the maximum of the source elements. Emits either the rolling maximum or only the final value.

4. class Min[T] extends RxTransformer[T, T]

   

   Computes the minimum of the source elements.

   Computes the minimum of the source elements. Emits either the rolling minimum or only the final value.

5. class Mul[T] extends RxTransformer[T, T]

   

   Computes the product of the source elements.

   Computes the product of the source elements. Emits either the rolling product or only the final value.

6. class Range[T] extends AbstractRxBlock[T]

   

   Iterates over the specified range of numeric values and emits each item.

7. case class Stats(count: Long, mean: Double, varnum: Double, min: Double, max: Double) extends Product with Serializable

   

   A class for tracking the statistics of a set of numbers (count, mean and variance) in a numerically robust way.

   A class for tracking the statistics of a set of numbers (count, mean and variance) in a numerically robust way. Includes support for merging two Stats objects. Based on Welford and Chan's algorithms for running variance.

8. class Sum[T] extends RxTransformer[T, T]

   

   Computes the sum of the source elements.

   Computes the sum of the source elements. Emits either the rolling sum or only the final value.