| Interface | Description |
|---|---|
| Aggregator<K,V,VA> |
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. |
| GlobalKTable<K,V> |
GlobalKTable is an abstraction of a changelog stream from a primary-keyed table. |
| Initializer<VA> |
The
Initializer interface for creating an initial value in aggregations. |
| KeyValueMapper<K,V,VR> |
The
KeyValueMapper interface for mapping a key-value pair to a new value of arbitrary type. |
| KGroupedStream<K,V> |
KGroupedStream is an abstraction of a grouped record stream of KeyValue pairs. |
| KGroupedTable<K,V> |
KGroupedTable is an abstraction of a re-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 KeyValue pairs, i.e., each record is an
independent entity/event in the real world. |
| KTable<K,V> |
KTable is an abstraction of a changelog stream from a primary-keyed table. |
| Merger<K,V> |
The interface for merging aggregate values for
SessionWindows with the given key. |
| Predicate<K,V> |
The
Predicate interface represents a predicate (boolean-valued function) of a KeyValue pair. |
| Reducer<V> |
The
Reducer interface for combining two values of the same type into a new value. |
| Transformer<K,V,R> |
The
Transformer interface for stateful mapping of an input record to zero, one, or multiple new output
records (both key and value type can be altered arbitrarily). |
| TransformerSupplier<K,V,R> |
A
TransformerSupplier interface which can create one or more Transformer instances. |
| ValueJoiner<V1,V2,VR> |
The
ValueJoiner interface for joining two values into a new value of arbitrary type. |
| ValueMapper<V,VR> |
The
ValueMapper interface for mapping a value to a new value of arbitrary type. |
| ValueTransformer<V,VR> |
The
ValueTransformer interface for stateful mapping of a value to a new value (with possible new type). |
| ValueTransformerSupplier<V,VR> |
A
ValueTransformerSupplier interface which can create one or more ValueTransformer instances. |
| Class | Description |
|---|---|
| JoinWindows |
The window specifications used for joins.
|
| KStreamBuilder |
KStreamBuilder provide the high-level Kafka Streams DSL to specify a Kafka Streams topology. |
| SessionWindows |
A session based window specification used for aggregating events into sessions.
|
| TimeWindows |
The fixed-size time-based window specifications used for aggregations.
|
| UnlimitedWindows |
The unlimited window specifications used for aggregations.
|
| Window |
A single window instance, defined by its start and end timestamp.
|
| Windowed<K> |
The result key type of a windowed stream aggregation.
|
| Windows<W extends Window> |
The window specification interface for fixed size windows that is used to define window boundaries and window
maintain duration.
|