Wrappers for the Java 'lambda' functions.
Wrappers for the Java 'lambda' functions.
(aggregator aggregator-fn)
Packages up a Clojure fn in a kstream aggregator.
Packages up a Clojure fn in a kstream aggregator.
(foreach-action foreach-action-fn)
Packages up a Clojure fn in a kstream ForeachAction.
Packages up a Clojure fn in a kstream ForeachAction.
(initializer initializer-fn)
Packages up a Clojure fn in a kstream Initializer.
Packages up a Clojure fn in a kstream Initializer.
(key-value [key value])
A key-value pair defined for a single Kafka Streams record.
A key-value pair defined for a single Kafka Streams record.
(key-value-flatmapper key-value-flatmapper-fn)
Packages up a Clojure fn in a kstream key value mapper for use with .flatMap.
key-value-flatmapper-fn
should be a function that takes a [key value]
as a
single parameter, and returns a list of [key value]
.
Packages up a Clojure fn in a kstream key value mapper for use with .flatMap. `key-value-flatmapper-fn` should be a function that takes a `[key value]` as a single parameter, and returns a list of `[key value]`.
(key-value-mapper key-value-mapper-fn)
Packages up a Clojure fn in a kstream key value mapper.
Packages up a Clojure fn in a kstream key value mapper.
(merger merger-fn)
Packages up a Clojure fn in a kstream merger (merges together two SessionWindows aggregate values).
Packages up a Clojure fn in a kstream merger (merges together two SessionWindows aggregate values).
(predicate predicate-fn)
Packages up a Clojure fn in a kstream predicate.
Packages up a Clojure fn in a kstream predicate.
(processor processor-fn)
Packages up a Clojure fn as a kstream processor.
Packages up a Clojure fn as a kstream processor.
(processor-supplier processor-fn)
Packages up a Clojure fn in a kstream processor supplier.
Packages up a Clojure fn in a kstream processor supplier.
(reducer reducer-fn)
Packages up a Clojure fn in a kstream reducer.
Packages up a Clojure fn in a kstream reducer.
(select-key-value-mapper select-key-value-mapper-fn)
Packages up a Clojure fn in a kstream key value mapper for use with
select-key
.
Packages up a Clojure fn in a kstream key value mapper for use with `select-key`.
(stream-partitioner stream-partitioner-fn)
Packages up a Clojure fn in a kstream partitioner.
Packages up a Clojure fn in a kstream partitioner.
(transformer-supplier transformer-supplier-fn)
Packages up a Clojure fn in a kstream transformer supplier.
Packages up a Clojure fn in a kstream transformer supplier.
(transformer-with-ctx xfm-fn)
Helper to create a Transformer for use inside the jackdaw transform wrapper. Passed function should take three args - the context, key and value for the stream. The processor context allows access to stream internals such as state stores. Result is returned from the transform. E.g.
(-> builder
(k/stream topic)
(k/transform
(kl/transformer-with-ctx
(fn [ctx k v]
...))))
Helper to create a Transformer for use inside the jackdaw transform wrapper. Passed function should take three args - the context, key and value for the stream. The processor context allows access to stream internals such as state stores. Result is returned from the transform. E.g. ``` (-> builder (k/stream topic) (k/transform (kl/transformer-with-ctx (fn [ctx k v] ...)))) ```
(value-joiner value-joiner-fn)
Packages up a Clojure fn in a kstream value joiner.
Packages up a Clojure fn in a kstream value joiner.
(value-mapper value-mapper-fn)
Packages up a Clojure fn in a kstream value mapper.
Packages up a Clojure fn in a kstream value mapper.
(value-transformer-supplier value-transformer-supplier-fn)
Packages up a Clojure fn in a kstream value transformer supplier.
Packages up a Clojure fn in a kstream value transformer supplier.
(value-transformer-with-ctx xfm-fn)
Helper to create a ValueTransformer for use inside the jackdaw transform-values wrapper. Passed function should take two args - the context and value for the stream. The processor context allows access to stream internals such as state stores. Result is returned from the transform-values. E.g.
(-> builder
(k/stream topic)
(k/transform-values
(kl/value-transformer-with-ctx
(fn [ctx v]
...))))
Helper to create a ValueTransformer for use inside the jackdaw transform-values wrapper. Passed function should take two args - the context and value for the stream. The processor context allows access to stream internals such as state stores. Result is returned from the transform-values. E.g. ``` (-> builder (k/stream topic) (k/transform-values (kl/value-transformer-with-ctx (fn [ctx v] ...)))) ```
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close