jackdaw.streams.lambdas — fundingcircle/jackdaw 0.7.5-more_interop-SNAPSHOT

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)

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)

Packages a Clojure fn inside the structure required by the transformer supplier, and records the ProcessorContext for it - passing the captured context to the provided function.

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)

Packages a Clojure fn inside the structure required by the value transformer supplier, and records the ProcessorContext for it - passing the captured context to the provided function.

with-stores clj

(with-stores store-names xfm)

Decorates a call to a fn used in a transform with the named state stores from the Processor context. The named stores are passed in a map, keyed by the store name. The name may be a keyword or string. Primarily this is an aid to testing, as it allows the wrapped fn to access state stores without having to know about the ProcessorContext.