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)
(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.
(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.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close