Liking cljdoc? Tell your friends :D
Clojure only.

rp.jackdaw.streams-extras

add-state-storeclj

(add-state-store builder state-store-builder)
source

gracecljmultimethod

source

IKStreamProcessorcljprotocol

processorclj

(processor kstream processor-supplier-fn)
(processor kstream processor-supplier-fn state-store-names)

Creates a KStream with the processor supplied by processor-supplier-fn attached to the topology. The processor-supplier-fn should reify the org.apache.kafka.streams.processor.Processor IFace.

Creates a KStream with the processor supplied by processor-supplier-fn attached to the topology.
The processor-supplier-fn should reify the org.apache.kafka.streams.processor.Processor IFace.
source

processor-supplierclj

(processor-supplier processor-supplier-fn)

Packages up a Clojure fn in a kstream processor supplier.

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

session-windowsclj

(session-windows inactivity-duration)
source

suppresscljmultimethod

source

suppressed-until-window-closesclj

(suppressed-until-window-closes)
source

time-windowsclj

(time-windows window-duration)
(time-windows window-duration advance-by-duration)
source

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

Keyboard shortcutsReport a problemcljdoc on GitHub
× close