jackdaw.streams.lambdas — com.nomistech/jackdaw 0.8.0-with-stream-table-inner-join

Wrappers for the Java 'lambda' functions.

aggregator clj

(aggregator aggregator-fn)

Packages up a Clojure fn in a kstream aggregator.

foreach-action clj

(foreach-action foreach-action-fn)

Packages up a Clojure fn in a kstream ForeachAction.

initializer clj

(initializer initializer-fn)

Packages up a Clojure fn in a kstream Initializer.

key-value clj

(key-value [key value])

A key-value pair defined for a single Kafka Streams record.

key-value-flatmapper clj

(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 clj

(key-value-mapper key-value-mapper-fn)

Packages up a Clojure fn in a kstream key value mapper.

merger clj

(merger merger-fn)

Packages up a Clojure fn in a kstream merger (merges together two SessionWindows aggregate values).

predicate clj

(predicate predicate-fn)

Packages up a Clojure fn in a kstream predicate.

processor clj

(processor processor-fn)

Packages up a Clojure fn as a kstream processor.

processor-supplier clj

(processor-supplier processor-fn)

Packages up a Clojure fn in a kstream processor supplier.

reducer clj

(reducer reducer-fn)

Packages up a Clojure fn in a kstream reducer.

select-key-value-mapper clj

(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 clj

(stream-partitioner stream-partitioner-fn)

Packages up a Clojure fn in a kstream partitioner.

transformer-supplier clj

(transformer-supplier transformer-supplier-fn)

Packages up a Clojure fn in a kstream transformer supplier.

value-joiner clj

(value-joiner value-joiner-fn)

Packages up a Clojure fn in a kstream value joiner.

value-mapper clj

(value-mapper value-mapper-fn)

Packages up a Clojure fn in a kstream value mapper.

value-transformer-supplier clj

(value-transformer-supplier value-transformer-supplier-fn)

Packages up a Clojure fn in a kstream value transformer supplier.