kotr.pipeline.gen.emitter.ksql.core — clj-ksql 0.0.22

as-create-fields clj

(as-create-fields fields)

as-select-fields clj

(as-select-fields coll)

create-stream-statement clj

(create-stream-statement sink-name fields source-name)

(create-stream-statement sink-name fields source-name sink-key)

current-context clj

do-fields-transformation clj

(do-fields-transformation f)

do-fields-transformation-batch clj

(do-fields-transformation-batch fields)

get-partition-key clj

(get-partition-key mapping-schema)

get-ref-source-name clj

(get-ref-source-name m)

get-sink-key clj

(get-sink-key e-key-m sink-m)

make-with-clause clj

(make-with-clause topic-name)

(make-with-clause topic-name key)

make-with-clause-with-partitions clj

(make-with-clause-with-partitions topic-name)

(make-with-clause-with-partitions topic-name key)

stream-rekey clj

(stream-rekey {:keys [topic key fields from-topic type]})