jackdaw.streams.lambdas — fundingcircle/jackdaw 0.9.11

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.

transformer-with-ctx clj

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

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.

value-transformer-with-ctx clj

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