object Moments extends Serializable
- Alphabetic
- By Inheritance
- Moments
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val aggregator: MomentsAggregator.type
- def apply(m0: Long, m1: Double, m2: Double, m3: Double, m4: Double): Moments
This it the legacy apply when count was a Long
- def apply[V](m0: Long, m1: V, m2: V, m3: V, m4: V)(implicit num: Numeric[V]): Moments
- def apply[V](value: V)(implicit arg0: Numeric[V], num: Numeric[V]): Moments
Create a Moments object given a single value.
Create a Moments object given a single value. This is useful for initializing moment calculations at the start of a stream.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getCombinedMeanDouble(weightN: Double, an: Double, weightK: Double, ak: Double): Double
Given two streams of doubles (weightN, an) and (weightK, ak) of form (weighted count, mean), calculates the mean of the combined stream.
Given two streams of doubles (weightN, an) and (weightK, ak) of form (weighted count, mean), calculates the mean of the combined stream.
Uses a more stable online algorithm which should be suitable for large numbers of records similar to: http://en.wikipedia.org/wiki/Algorithms_for_calculating_variance#Parallel_algorithm
This differs from the implementation in MomentsGroup.scala only in that here, the counts are weighted, and are thus doubles instead of longs
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit val momentsMonoid: Monoid[Moments] with CommutativeMonoid[Moments]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def numericAggregator[N](implicit num: Numeric[N]): MonoidAggregator[N, Moments, Moments]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unapply(m: Moments): Option[(Long, Double, Double, Double, Double)]
This it the legacy unapply when count was a Long
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()