kotr.pipeline.gen.macro-expand-join — clj-ksql 0.0.22

create-intermediate-stream-names clj

(create-intermediate-stream-names mapping-coll)

create-join-fields clj

(create-join-fields fields)

debug clj

(debug m)

get-entity-name-list clj

(get-entity-name-list transformation-fn)

get-join-entity-name clj

(get-join-entity-name n-mapping)

join-expand clj

(join-expand mapping)

join-name-set clj

join-transoformation? clj

(join-transoformation? field)

map-join-fields clj

(map-join-fields field-coll-coll)

partition-join clj

(partition-join mapping)

replace-name-space clj

(replace-name-space next-mapping previous-field-set f-step)

(replace-name-space current-mapping next-mapping previous-field-set f-step)