jackdaw.streams.lambdas
Wrappers for the Java 'lambda' functions.
aggregator
(aggregator aggregator-fn)
Packages up a Clojure fn in a kstream aggregator.
foreach-action
(foreach-action foreach-action-fn)
Packages up a Clojure fn in a kstream ForeachAction.
initializer
(initializer initializer-fn)
Packages up a Clojure fn in a kstream Initializer.
key-value
(key-value [key value])
A key-value pair defined for a single Kafka Streams record.
key-value-flatmapper
(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]`.
key-value-mapper
(key-value-mapper key-value-mapper-fn)
Packages up a Clojure fn in a kstream key value mapper.
predicate
(predicate predicate-fn)
Packages up a Clojure fn in a kstream predicate.
processor
(processor processor-fn)
processor-supplier
(processor-supplier processor-fn)
Packages up a Clojure fn in a kstream processor supplier.
reducer
(reducer reducer-fn)
Packages up a Clojure fn in a kstream reducer.
select-key-value-mapper
(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`.
stream-partitioner
(stream-partitioner stream-partitioner-fn)
Packages up a Clojure fn in a kstream partitioner.
value-joiner
(value-joiner value-joiner-fn)
Packages up a Clojure fn in a kstream value joiner.
value-mapper
(value-mapper value-mapper-fn)
Packages up a Clojure fn in a kstream value mapper.