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.
sourceraw 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.
sourceraw docstring

initializerclj

(initializer initializer-fn)

Packages up a Clojure fn in a kstream Initializer.

Packages up a Clojure fn in a kstream Initializer.
sourceraw 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.
sourceraw 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]`.
sourceraw 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.
sourceraw 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).
sourceraw docstring

predicateclj

(predicate predicate-fn)

Packages up a Clojure fn in a kstream predicate.

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

processorclj

(processor processor-fn)

Packages up a Clojure fn as a kstream processor.

Packages up a Clojure fn as a kstream processor.
sourceraw 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.
sourceraw docstring

reducerclj

(reducer reducer-fn)

Packages up a Clojure fn in a kstream reducer.

Packages up a Clojure fn in a kstream reducer.
sourceraw 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`.
sourceraw 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.
sourceraw 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.
sourceraw docstring

transformer-with-ctxclj

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

value-transformer-with-ctxclj

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

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

× close