jackdaw.streams.xform — fundingcircle/jackdaw 0.6.9-transducers-SNAPSHOT

Helper functions for working with transducers.

add-state-store! clj

(add-state-store! builder)

fake-kv-store clj

(fake-kv-store init)

Creates an instance of org.apache.kafka.streams.state.KeyValueStore with overrides for get and put.

kv-store-swap-fn clj

(kv-store-swap-fn store f m)

Takes an instance of KeyValueStore, a function f, and map m, and updates the store in a manner similar to clojure.core/swap!.

transduce-kstream clj

(transduce-kstream kstream xf)

value-transformer clj

(value-transformer xf)

Creates an instance of org.apache.kafka.streams.kstream.ValueTransformer with overrides for init, transform, and close.