Packages

package kstream

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

Type Members

  1. type Branched[K, V] = kstream.Branched[K, V]
  2. class BranchedKStream[K, V] extends AnyRef

    Branches the records in the original stream based on the predicates supplied for the branch definitions.

    Branches the records in the original stream based on the predicates supplied for the branch definitions.

    Branches are defined with branch or defaultBranch methods. Each record is evaluated against the predicates supplied via Branched parameters, and is routed to the first branch for which its respective predicate evaluates to true. If a record does not match any predicates, it will be routed to the default branch, or dropped if no default branch is created.

    Each branch (which is a KStream instance) then can be processed either by a function or a consumer provided via a Branched parameter. If certain conditions are met, it also can be accessed from the Map returned by an optional defaultBranch or noDefaultBranch method call.

    The branching happens on a first match basis: A record in the original stream is assigned to the corresponding result stream for the first predicate that evaluates to true, and is assigned to this stream only. If you need to route a record to multiple streams, you can apply multiple KStream.filter operators to the same KStream instance, one for each predicate, instead of branching.

    The process of routing the records to different branches is a stateless record-by-record operation.

    K

    Type of keys

    V

    Type of values

  3. class CogroupedKStream[KIn, VOut] extends AnyRef

    Wraps the Java class CogroupedKStream and delegates method calls to the underlying Java object.

    Wraps the Java class CogroupedKStream and delegates method calls to the underlying Java object.

    KIn

    Type of keys

    VOut

    Type of values

    See also

    org.apache.kafka.streams.kstream.CogroupedKStream

  4. type Consumed[K, V] = kstream.Consumed[K, V]
  5. type Grouped[K, V] = kstream.Grouped[K, V]
  6. type Joined[K, V, VO] = kstream.Joined[K, V, VO]
  7. class KGroupedStream[K, V] extends AnyRef

    Wraps the Java class KGroupedStream and delegates method calls to the underlying Java object.

    Wraps the Java class KGroupedStream and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KGroupedStream

  8. class KGroupedTable[K, V] extends AnyRef

    Wraps the Java class KGroupedTable and delegates method calls to the underlying Java object.

    Wraps the Java class KGroupedTable and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KGroupedTable

  9. class KStream[K, V] extends AnyRef

    Wraps the Java class KStream and delegates method calls to the underlying Java object.

    Wraps the Java class KStream and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KStream

  10. class KTable[K, V] extends AnyRef

    Wraps the Java class org.apache.kafka.streams.kstream.KTable and delegates method calls to the underlying Java object.

    Wraps the Java class org.apache.kafka.streams.kstream.KTable and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KTable

  11. type Materialized[K, V, S <: StateStore] = kstream.Materialized[K, V, S]
  12. type Named = kstream.Named
  13. type Produced[K, V] = kstream.Produced[K, V]
  14. type Repartitioned[K, V] = kstream.Repartitioned[K, V]
  15. class SessionWindowedCogroupedKStream[K, V] extends AnyRef

    Wraps the Java class SessionWindowedCogroupedKStream and delegates method calls to the underlying Java object.

    Wraps the Java class SessionWindowedCogroupedKStream and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream

  16. class SessionWindowedKStream[K, V] extends AnyRef

    Wraps the Java class SessionWindowedKStream and delegates method calls to the underlying Java object.

    Wraps the Java class SessionWindowedKStream and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.SessionWindowedKStream

  17. type StreamJoined[K, V, VO] = kstream.StreamJoined[K, V, VO]
  18. class TimeWindowedCogroupedKStream[K, V] extends AnyRef

    Wraps the Java class TimeWindowedCogroupedKStream and delegates method calls to the underlying Java object.

    Wraps the Java class TimeWindowedCogroupedKStream and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.TimeWindowedCogroupedKStream

  19. class TimeWindowedKStream[K, V] extends AnyRef

    Wraps the Java class TimeWindowedKStream and delegates method calls to the underlying Java object.

    Wraps the Java class TimeWindowedKStream and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.TimeWindowedKStream

Value Members

  1. object Branched
  2. object Consumed
  3. object Grouped
  4. object Joined
  5. object Materialized
  6. object Produced
  7. object Repartitioned
  8. object StreamJoined

Inherited from AnyRef

Inherited from Any

Ungrouped