Liking cljdoc? Tell your friends :D
Clojure only.
org.purefn.river.flush
Experimental.
Higher order functions used to compose an auto-flushing processing function.
Experimental. Higher order functions used to compose an auto-flushing processing function.
accumulateclj
(accumulate processor)Accumulate records into state, and increments a count.
Accumulate records into state, and increments a count.
flushclj
(flush flush-fn)Wrap the flush fn, which must be 2-arity - [deps records]
Wrap the flush fn, which must be 2-arity - [deps records]
max-recordsclj
(max-records processor n)Identifies a maximum record count flush condition.
Identifies a maximum record count flush condition.
seenclj
(seen processor n)Identifies a maximum seen count as a flush condition. Useful when a filtering transducer has been applied.
:count must be zero, and :seen > n
Identifies a maximum seen count as a flush condition. Useful when a filtering transducer has been applied. `:count` must be zero, and `:seen` > `n`
timedclj
(timed processor ms)Identifies buffer age as a condition for flushing. The timer starts when state has at least one record.
Identifies buffer age as a condition for flushing. The timer starts when state has at least one record.
transformclj
(transform processor xform)Applies a transducer to the records batch. Updates :seen key in state,
adding the number of records processed.
Use before accumulate for filtering or other preprocessing.
Applies a transducer to the records batch. Updates `:seen` key in state, adding the number of records processed. Use before accumulate for filtering or other preprocessing.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close