| Interface | Description |
|---|---|
| Aggregator<K,V,T> |
The
Aggregator interface for aggregating values of the given key. |
| ForeachAction<K,V> |
The
ForeachAction interface for performing an action on a key-value pair. |
| Initializer<T> |
The
Initializer interface for creating an initial value in aggregations. |
| KeyValueMapper<K,V,R> |
The
KeyValueMapper interface for mapping a key-value pair to a new value (could be another key-value pair). |
| KGroupedStream<K,V> |
KGroupedStream is an abstraction of a grouped record stream of key-value pairs
usually grouped on a different key than the original stream key |
| KGroupedTable<K,V> |
KGroupedTable is an abstraction of a grouped changelog stream from a primary-keyed table,
usually on a different grouping key than the original primary key. |
| KStream<K,V> |
KStream is an abstraction of a record stream of key-value pairs. |
| KTable<K,V> |
KTable is an abstraction of a changelog stream from a primary-keyed table. |
| Predicate<K,V> |
The
Predicate interface represents a predicate (boolean-valued function) of a key-value pair. |
| Reducer<V> |
The
Reducer interface for combining two values of the same type into a new value. |
| Transformer<K,V,R> |
A stateful
Transformer interface for transform a key-value pair into a new value. |
| TransformerSupplier<K,V,R> |
A
TransformerSupplier interface which can create one or more Transformer instances. |
| ValueJoiner<V1,V2,R> |
The
ValueJoiner interface for joining two values into a new value. |
| ValueMapper<V1,V2> |
The
ValueMapper interface for mapping an original value to a new value (could be another key-value pair). |
| ValueTransformer<V,R> |
A stateful
ValueTransformer interface to transform a value into a new value. |
| ValueTransformerSupplier<V,R> |
A
ValueTransformerSupplier interface which can create one or more ValueTransformer instances. |
| Class | Description |
|---|---|
| JoinWindows |
The window specifications used for joins.
|
| KStreamBuilder |
KStreamBuilder is a subclass of TopologyBuilder that provides the Kafka Streams DSL
for users to specify computational logic and translates the given logic to a org.apache.kafka.streams.processor.internals.ProcessorTopology. |
| TimeWindows |
The time-based window specifications used for aggregations.
|
| UnlimitedWindows |
The unlimited window specifications.
|
| Window |
A single window instance, defined by its start and end timestamp.
|
| Windowed<K> |
Used to represent windowed stream aggregations (e.g.
|
| Windows<W extends Window> |
The window specification interface that can be extended for windowing operation in joins and aggregations.
|