package kstream
- Alphabetic
- By Inheritance
- kstream
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- type Branched[K, V] = kstream.Branched[K, V]
- 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
- 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
- type Consumed[K, V] = kstream.Consumed[K, V]
- type Grouped[K, V] = kstream.Grouped[K, V]
- type Joined[K, V, VO] = kstream.Joined[K, V, VO]
- 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
- 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
- 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
- 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
- type Materialized[K, V, S <: StateStore] = kstream.Materialized[K, V, S]
- type Named = kstream.Named
- type Produced[K, V] = kstream.Produced[K, V]
- type Repartitioned[K, V] = kstream.Repartitioned[K, V]
- 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
- 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
- type StreamJoined[K, V, VO] = kstream.StreamJoined[K, V, VO]
- 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
- 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