Liking cljdoc? Tell your friends :D

jackdaw.streams.lambdas

Wrappers for the Java 'lambda' functions.

Wrappers for the Java 'lambda' functions.
raw docstring

aggregatorclj

(aggregator aggregator-fn)

Packages up a Clojure fn in a kstream aggregator.

Packages up a Clojure fn in a kstream aggregator.
raw docstring

foreach-actionclj

(foreach-action foreach-action-fn)

Packages up a Clojure fn in a kstream ForeachAction.

Packages up a Clojure fn in a kstream ForeachAction.
raw docstring

initializerclj

(initializer initializer-fn)

Packages up a Clojure fn in a kstream Initializer.

Packages up a Clojure fn in a kstream Initializer.
raw docstring

key-valueclj

(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.
raw docstring

key-value-flatmapperclj

(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]`.
raw docstring

key-value-mapperclj

(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.
raw docstring

mergerclj

(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).
raw docstring

predicateclj

(predicate predicate-fn)

Packages up a Clojure fn in a kstream predicate.

Packages up a Clojure fn in a kstream predicate.
raw docstring

processorclj

(processor processor-fn)

Packages up a Clojure fn as a kstream processor.

Packages up a Clojure fn as a kstream processor.
raw docstring

processor-supplierclj

(processor-supplier processor-fn)

Packages up a Clojure fn in a kstream processor supplier.

Packages up a Clojure fn in a kstream processor supplier.
raw docstring

reducerclj

(reducer reducer-fn)

Packages up a Clojure fn in a kstream reducer.

Packages up a Clojure fn in a kstream reducer.
raw docstring

select-key-value-mapperclj

(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`.
raw docstring

stream-partitionerclj

(stream-partitioner stream-partitioner-fn)

Packages up a Clojure fn in a kstream partitioner.

Packages up a Clojure fn in a kstream partitioner.
raw docstring

transformer-supplierclj

(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.
raw docstring

value-joinerclj

(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.
raw docstring

value-mapperclj

(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.
raw docstring

value-transformer-supplierclj

(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.
raw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close