Class

com.salesforce.op.aggregators

CustomMonoidAggregator

Related Doc: package aggregators

Permalink

case class CustomMonoidAggregator[O <: FeatureType](zero: O.Value, associativeFn: (O.Value, O.Value) ⇒ O.Value)(implicit ttag: scala.reflect.api.JavaUniverse.WeakTypeTag[O]) extends MonoidAggregator[Event[O], aggregators.CustomMonoidAggregator.O.Value, O] with AggregatorDefaults[O] with Product with Serializable

Custom Monoid Aggregator allowing passing a zero value and an associative function to combine values

O

type of feature

zero

zero value

associativeFn

associative function to combine values

Linear Supertypes
Serializable, Product, Equals, AggregatorDefaults[O], MonoidAggregator[Event[O], O.Value, O], Aggregator[Event[O], O.Value, O], Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CustomMonoidAggregator
  2. Serializable
  3. Product
  4. Equals
  5. AggregatorDefaults
  6. MonoidAggregator
  7. Aggregator
  8. Serializable
  9. AnyRef
  10. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new CustomMonoidAggregator(zero: O.Value, associativeFn: (O.Value, O.Value) ⇒ O.Value)(implicit ttag: scala.reflect.api.JavaUniverse.WeakTypeTag[O])

    Permalink

    zero

    zero value

    associativeFn

    associative function to combine values

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. def andThenPresent[D](present2: (O) ⇒ D): MonoidAggregator[Event[O], O.Value, D]

    Permalink
    Definition Classes
    MonoidAggregator → Aggregator
  5. def append(l: O.Value, r: Event[O]): O.Value

    Permalink
    Definition Classes
    Aggregator
  6. def appendAll(items: TraversableOnce[Event[O]]): O.Value

    Permalink
    Definition Classes
    MonoidAggregator
  7. def appendAll(old: O.Value, items: TraversableOnce[Event[O]]): O.Value

    Permalink
    Definition Classes
    Aggregator
  8. def apply(inputs: TraversableOnce[Event[O]]): O

    Permalink
    Definition Classes
    Aggregator
  9. def applyCumulatively[In <: TraversableOnce[Event[O]], Out](inputs: In)(implicit bf: CanBuildFrom[In, O, Out]): Out

    Permalink
    Definition Classes
    Aggregator
  10. def applyOption(inputs: TraversableOnce[Event[O]]): Option[O]

    Permalink
    Definition Classes
    Aggregator
  11. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  12. val associativeFn: (O.Value, O.Value) ⇒ O.Value

    Permalink

    associative function to combine values

  13. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  14. def collectBefore[A2](fn: PartialFunction[A2, Event[O]]): MonoidAggregator[A2, O.Value, O]

    Permalink
    Definition Classes
    MonoidAggregator
  15. def composePrepare[A2](prepare2: (A2) ⇒ Event[O]): MonoidAggregator[A2, O.Value, O]

    Permalink
    Definition Classes
    MonoidAggregator → Aggregator
  16. def cumulativeIterator(inputs: Iterator[Event[O]]): Iterator[O]

    Permalink
    Definition Classes
    Aggregator
  17. def either[A2, B2, C2](that: MonoidAggregator[A2, B2, C2]): MonoidAggregator[Either[Event[O], A2], (O.Value, B2), (O, C2)]

    Permalink
    Definition Classes
    MonoidAggregator
  18. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  19. def filterBefore[A1 <: Event[O]](pred: (A1) ⇒ Boolean): MonoidAggregator[A1, O.Value, O]

    Permalink
    Definition Classes
    MonoidAggregator
  20. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  21. val ftFactory: FeatureTypeFactory[O]

    Permalink
  22. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  23. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  24. def join[A2 <: Event[O], B2, C2](that: Aggregator[A2, B2, C2]): Aggregator[A2, (O.Value, B2), (O, C2)]

    Permalink
    Definition Classes
    Aggregator
  25. def lift: MonoidAggregator[Event[O], Option[O.Value], Option[O]]

    Permalink
    Definition Classes
    Aggregator
  26. val monoid: Monoid[O.Value]

    Permalink
    Definition Classes
    CustomMonoidAggregator → MonoidAggregator
  27. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  28. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  29. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  30. def prepare(input: Event[O]): O.Value

    Permalink
    Definition Classes
    AggregatorDefaults
  31. def present(reduction: O.Value): O

    Permalink
    Definition Classes
    AggregatorDefaults
  32. final def reduce(items: TraversableOnce[O.Value]): O.Value

    Permalink
    Definition Classes
    MonoidAggregator → Aggregator
  33. def reduce(l: O.Value, r: O.Value): O.Value

    Permalink
    Definition Classes
    Aggregator
  34. def reduceOption(items: TraversableOnce[O.Value]): Option[O.Value]

    Permalink
    Definition Classes
    Aggregator
  35. def semigroup: Monoid[O.Value]

    Permalink
    Definition Classes
    MonoidAggregator → Aggregator
  36. def sumBefore: MonoidAggregator[TraversableOnce[Event[O]], O.Value, O]

    Permalink
    Definition Classes
    MonoidAggregator
  37. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  38. def toFold: Fold[Event[O], Option[O]]

    Permalink
    Definition Classes
    Aggregator
  39. implicit val ttag: scala.reflect.api.JavaUniverse.WeakTypeTag[O]

    Permalink
  40. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  41. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  42. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. val zero: O.Value

    Permalink

    zero value

  44. def zip[A2, B2, C2](ag2: MonoidAggregator[A2, B2, C2]): MonoidAggregator[(Event[O], A2), (O.Value, B2), (O, C2)]

    Permalink
    Definition Classes
    MonoidAggregator
  45. def zip[A2, B2, C2](ag2: Aggregator[A2, B2, C2]): Aggregator[(Event[O], A2), (O.Value, B2), (O, C2)]

    Permalink
    Definition Classes
    Aggregator

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AggregatorDefaults[O]

Inherited from MonoidAggregator[Event[O], O.Value, O]

Inherited from Aggregator[Event[O], O.Value, O]

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped