(as-create-fields fields)
(as-select-fields coll)
(create-stream-statement sink-name fields source-name)
(create-stream-statement sink-name fields source-name sink-key)
(do-fields-transformation f)
(do-fields-transformation-batch fields)
(get-partition-key mapping-schema)
(get-ref-source-name m)
(get-sink-key e-key-m sink-m)
(make-with-clause topic-name)
(make-with-clause topic-name key)
(make-with-clause topic-name key with-partitions?)
(stream-rekey {:keys [topic key fields from-topic type]})
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close