object Branched

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

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. def as[K, V](name: String): kstream.Branched[K, V]

    Create an instance of Branched with provided branch name suffix.

    Create an instance of Branched with provided branch name suffix.

    K

    key type

    V

    value type

    name

    the branch name suffix to be used (see BranchedKStream description for details)

    returns

    a new instance of Branched

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  20. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  21. def withConsumer[K, V](chain: (KStream[K, V]) => Unit, name: String = null): kstream.Branched[K, V]

    Create an instance of Branched with provided chain consumer and branch name suffix.

    Create an instance of Branched with provided chain consumer and branch name suffix.

    K

    key type

    V

    value type

    chain

    A consumer to which the branch will be sent. If a non-null consumer is provided here, the respective branch will not be added to the resulting Map returned by BranchedKStream.defaultBranch or BranchedKStream.noDefaultBranch (see BranchedKStream description for details).

    name

    the branch name suffix to be used. If null, a default branch name suffix will be generated (see BranchedKStream description for details)

    returns

    a new instance of Branched

    See also

    org.apache.kafka.streams.kstream.Branched#withConsumer(java.util.function.Consumer, java.lang.String)

  22. def withFunction[K, V](chain: (KStream[K, V]) => KStream[K, V], name: String = null): kstream.Branched[K, V]

    Create an instance of Branched with provided chain function and branch name suffix.

    Create an instance of Branched with provided chain function and branch name suffix.

    K

    key type

    V

    value type

    chain

    A function that will be applied to the branch. If the provided function returns null, its result is ignored, otherwise it is added to the Map returned by BranchedKStream.defaultBranch or BranchedKStream.noDefaultBranch (see BranchedKStream description for details).

    name

    the branch name suffix to be used. If null, a default branch name suffix will be generated (see BranchedKStream description for details)

    returns

    a new instance of Branched

    See also

    org.apache.kafka.streams.kstream.Branched#withFunction(java.util.function.Function, java.lang.String)

Inherited from AnyRef

Inherited from Any

Ungrouped