com.twitter.summingbird.javaapi.impl

JSummerImpl

class JSummerImpl[P <: Platform[P], K, V] extends JKeyedProducerImpl[P, K, (Option[V], V)] with JSummer[P, K, V]

Source
JSummerImpl.java
Linear Supertypes
JSummer[P, K, V], JTailProducer[P, (K, (Option[V], V))], JKeyedProducerImpl[P, K, (Option[V], V)], JKeyedProducer[P, K, (Option[V], V)], JProducerImpl[P, (K, (Option[V], V))], JProducer[P, (K, (Option[V], V))], AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. JSummerImpl
  2. JSummer
  3. JTailProducer
  4. JKeyedProducerImpl
  5. JKeyedProducer
  6. JProducerImpl
  7. JProducer
  8. AnyRef
  9. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

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

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. def also[R](that: JProducer[P, R]): JProducer[P, R]

    Definition Classes
    JSummerImpl → JTailProducer

  7. def also[R](that: JTailProducer[P, R]): JTailProducer[P, R]

    Definition Classes
    JSummerImpl → JTailProducer

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  9. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  10. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  11. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  12. def filter(f: Predicate[(K, (Option[V], V))]): JProducer[P, (K, (Option[V], V))]

    Definition Classes
    JProducerImpl → JProducer

  13. def filterKeys(f: Predicate[K]): JKeyedProducer[P, K, (Option[V], V)]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  14. def filterValues(f: Predicate[(Option[V], V)]): JKeyedProducer[P, K, (Option[V], V)]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  15. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  16. def flatMap[U](f: Function[(K, (Option[V], V)), _ <: Iterable[U]]): JProducer[P, U]

    Definition Classes
    JProducerImpl → JProducer

  17. def flatMapKeys[K2](f: Function[K, _ <: Iterable[K2]]): JKeyedProducer[P, K2, (Option[V], V)]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  18. def flatMapValues[V2](f: Function[(Option[V], V), _ <: Iterable[V2]]): JKeyedProducer[P, K, V2]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  19. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  20. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  21. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  22. def keys(): JProducer[P, K]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  23. def leftJoin[RightV](stream: JKeyedProducer[P, K, RightV], buffer: Buffer[P, _, K, RightV]): JKeyedProducer[P, K, ((Option[V], V), Option[RightV])]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  24. def leftJoin[RightV](service: Service[P, _, K, RightV]): JKeyedProducer[P, K, ((Option[V], V), Option[RightV])]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  25. def lookup[V](service: Service[P, _, (K, (Option[V], V)), V]): JKeyedProducer[P, (K, (Option[V], V)), Option[V]]

    Definition Classes
    JProducerImpl → JProducer

  26. def map[U](f: Function[(K, (Option[V], V)), U]): JProducer[P, U]

    Definition Classes
    JProducerImpl → JProducer

  27. def mapKeys[K2](f: Function[K, K2]): JKeyedProducer[P, K2, (Option[V], V)]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  28. def mapToKeyed[K, V](f: Function[(K, (Option[V], V)), (K, V)]): JKeyedProducer[P, K, V]

    Definition Classes
    JProducerImpl → JProducer

  29. def mapValues[V2](f: Function[(Option[V], V), V2]): JKeyedProducer[P, K, V2]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  30. def merge(r: JProducer[P, (K, (Option[V], V))]): JProducer[P, (K, (Option[V], V))]

    Definition Classes
    JProducerImpl → JProducer

  31. def name(id: String): JTailProducer[P, (K, (Option[V], V))]

    Definition Classes
    JSummerImpl → JProducerImpl → JProducer

  32. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  33. final def notify(): Unit

    Definition Classes
    AnyRef

  34. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  35. def optionMap[U](f: Function[(K, (Option[V], V)), Option[U]]): JProducer[P, U]

    Definition Classes
    JProducerImpl → JProducer

  36. def sumByKey(store: Store[P, _, K, (Option[V], V)], semigroup: Semigroup[(Option[V], V)]): JSummer[P, K, (Option[V], V)]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  37. def swap(): JKeyedProducer[P, (Option[V], V), K]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  38. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  39. def toString(): String

    Definition Classes
    AnyRef → Any

  40. def unwrap(): Summer[P, K, V]

    Definition Classes
    JSummerImpl → JSummer → JTailProducer → JKeyedProducerImpl → JKeyedProducer → JProducerImpl → JProducer

  41. def values(): JProducer[P, (Option[V], V)]

    Definition Classes
    JKeyedProducerImpl → JKeyedProducer

  42. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  43. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  44. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  45. def write(sink: Sink[P, _, (K, (Option[V], V))]): JTailProducer[P, (K, (Option[V], V))]

    Definition Classes
    JProducerImpl → JProducer

Inherited from JSummer[P, K, V]

Inherited from JTailProducer[P, (K, (Option[V], V))]

Inherited from JKeyedProducerImpl[P, K, (Option[V], V)]

Inherited from JKeyedProducer[P, K, (Option[V], V)]

Inherited from JProducerImpl[P, (K, (Option[V], V))]

Inherited from JProducer[P, (K, (Option[V], V))]

Inherited from AnyRef

Inherited from Any

Ungrouped