kotr.pipeline.connector — clj-ksql 0.0.22

apply-rekey? clj

(apply-rekey? schema-m sink-schema-m)

assoc-field-schema clj

(assoc-field-schema e)

convert-schema-to-rekey-schema clj

(convert-schema-to-rekey-schema topic-schema sink-schema)

create-sink-connector clj

(create-sink-connector context base-dir sink-connector-mapping)

create-source-connector-req clj

(create-source-connector-req base-dir connector-mapping)

find-delta-connection clj

(find-delta-connection context connector-coll)

get-source-connector-names clj

(get-source-connector-names base-dir connector-mapping)

update-sink-connector-mapping clj

(update-sink-connector-mapping context connector-mapping-coll)