Package org.apache.kafka.streams.kstream

Interface Summary

Interface	Description
Aggregator<K,V,VA>	The Aggregator interface for aggregating values of the given key.
BranchedKStream<K,V>	Branches the records in the original stream based on the predicates supplied for the branch definitions.
CogroupedKStream<K,VOut>	CogroupedKStream is an abstraction of multiple grouped record streams of KeyValue pairs.
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.
SessionWindowedCogroupedKStream<K,V>	SessionWindowedCogroupKStream is an abstraction of a windowed record stream of KeyValue pairs.
SessionWindowedKStream<K,V>	SessionWindowedKStream is an abstraction of a windowed record stream of KeyValue pairs.
Suppressed<K>
Suppressed.BufferConfig<BC extends Suppressed.BufferConfig<BC>>
Suppressed.EagerBufferConfig	Marker interface for a buffer configuration that will strictly enforce size constraints (bytes and/or number of records) on the buffer, so it is suitable for reducing duplicate results downstream, but does not promise to eliminate them entirely.
Suppressed.StrictBufferConfig	Marker interface for a buffer configuration that is "strict" in the sense that it will strictly enforce the time bound and never emit early.
TimeWindowedCogroupedKStream<K,V>	TimeWindowedCogroupKStream is an abstraction of a windowed record stream of KeyValue pairs.
TimeWindowedKStream<K,V>	TimeWindowedKStream is an abstraction of a windowed record stream of KeyValue pairs.
Transformer<K,V,R>	The Transformer interface is 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.
ValueMapperWithKey<K,V,VR>	The ValueMapperWithKey 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.
ValueTransformerWithKey<K,V,VR>	The ValueTransformerWithKey interface for stateful mapping of a value to a new value (with possible new type).
ValueTransformerWithKeySupplier<K,V,VR>	A ValueTransformerWithKeySupplier interface which can create one or more ValueTransformerWithKey instances.

Class Summary

Class	Description
Branched<K,V>	The Branched class is used to define the optional parameters when building branches with BranchedKStream.
Consumed<K,V>	The Consumed class is used to define the optional parameters when using StreamsBuilder to build instances of KStream, KTable, and GlobalKTable.
Grouped<K,V>	The class that is used to capture the key and value Serdes and set the part of name used for repartition topics when performing KStream.groupBy(KeyValueMapper, Grouped), KStream.groupByKey(Grouped), or KTable.groupBy(KeyValueMapper, Grouped) operations.
Joined<K,V,VO>	The Joined class represents optional params that can be passed to KStream#join(KTable,...) and KStream#leftJoin(KTable,...) operations.
JoinWindows	The window specifications used for joins.
Materialized<K,V,S extends StateStore>	Used to describe how a StateStore should be materialized.
Named
Printed<K,V>	An object to define the options used when printing a KStream.
Produced<K,V>	This class is used to provide the optional parameters when producing to new topics using KStream.through(String, Produced) or KStream.to(String, Produced).
Repartitioned<K,V>	This class is used to provide the optional parameters for internal repartition topics.
Serialized<K,V>	Deprecated. since 2.1.
SessionWindowedDeserializer<T>	The inner serde class can be specified by setting the property StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS or StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS if the no-arg constructor is called and hence it is not passed during initialization.
SessionWindowedSerializer<T>	The inner serde class can be specified by setting the property StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS or StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS if the no-arg constructor is called and hence it is not passed during initialization.
SessionWindows	A session based window specification used for aggregating events into sessions.
SlidingWindows	A sliding window used for aggregating events.
StreamJoined<K,V1,V2>	Class used to configure the name of the join processor, the repartition topic name, state stores or state store names in Stream-Stream join.
TimeWindowedDeserializer<T>	The inner serde class can be specified by setting the property StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS or StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS if the no-arg constructor is called and hence it is not passed during initialization.
TimeWindowedSerializer<T>	The inner serde class can be specified by setting the property StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS or StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS if the no-arg constructor is called and hence it is not passed during initialization.
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.
WindowedSerdes
WindowedSerdes.SessionWindowedSerde<T>
WindowedSerdes.TimeWindowedSerde<T>
Windows<W extends Window>	The window specification for fixed size windows that is used to define window boundaries and grace period.