object Aggregator

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Aggregator
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def integral[T](timeunit: TimeUnit, initialValue: Double = .0)(implicit arg0: Numeric[T]): IntegralAggregator[T]

    See IntegralAggregator

  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. def max[T](implicit ordering: Ordering[T]): TimeUnawareReversibleAggregator[T, T]

    Aggregator that returns the maximum of all values in the window.

    Aggregator that returns the maximum of all values in the window. See MinAggregator.

  14. def mean[T](implicit arg0: Numeric[T]): MeanAggregator[T]

    See MeanAggregator

  15. def min[T](implicit arg0: Ordering[T]): TimeUnawareReversibleAggregator[T, T]

    Aggregator that returns the minimum of all values in the window.

    Aggregator that returns the minimum of all values in the window. See MinAggregator.

  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. def queueAggregator[T, A](f: (Seq[T]) => Option[A]): QueueAggregator[T, A]

    Factory for aggregators that need to act on the entire window, like median.

    Factory for aggregators that need to act on the entire window, like median.

    f

    aggregation function from a sequence of entries to an option

    returns

    a reversible aggregator

    Note

    Aggregating this way is a lot less efficient for computations that only need little intermediary state. Rather define your own Aggregator for those cases (see for example SumAggregator, MinAggregator.

  20. def std[T](implicit arg0: Numeric[T]): StdAggregator[T]

    See StdAggregator

  21. def sum[T](implicit arg0: Numeric[T]): SumAggregator[T]

    See SumAggregator

  22. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped