No vars found in this namespace.

• as-insert-statement
• as-insert-statement-batch
• load-csv-file
• load-csv-to-kafka

No vars found in this namespace.

• as-json-response
• consume
• consume-state-atom
• convert-stream-to-avro-schema
• count-topic-row
• delete-topics
• get-keyvals
• get-records
• init-context
• invoke
• ksql
• ksql-batch
• list-topics
• print-topic-async
• publish
• query
• query-async
• stop-query
• topic-config-for-data
• topic-config-for-metadata
• topic-exists?
• topic-formater
• topic-formatter-impl
• validate-stream-name
• validate-topic-name

• get-connector-url

No vars found in this namespace.

No vars found in this namespace.

• format-header
• format-header2
• format-row
• format-row2
• processor-m
• start-data-loading
• stop-data-loading

• get-kafka-schema

• as-dataflow-req
• as-entity-name
• context
• count-topic-row
• create-dataflow
• create-dataflow-req
• create-sink-connector
• create-source-connector
• delete-dataflow
• delete-dataflow-with-data
• delete-source-connector
• export-ksql-to-file
• get-context
• get-error
• get-schema
• import-ksql-from-file
• init-context
• invoke
• ksql
• load-app-config
• pause-source-connector
• print-stream
• print-table
• print-topic
• print-topic-as-table
• push-stardog
• query-async
• resume-source-connector
• rtry!
• stop-query
• topic-as-json
• update-dataflow
• update-dataflow-with-data

• apply-rekey?
• assoc-field-schema
• convert-schema-to-rekey-schema
• create-sink-connector
• create-source-connector-req
• find-delta-connection
• get-source-connector-names
• update-sink-connector-mapping

• as-struct-key-schema
• as-struct-value-schema

• as-sink-connector-schema
• as-source-connector-schema
• format-input

• create-dataflow-req
• delete-dataflow-req
• delete-dataflow-req-with-data
• get-delete-queries
• get-delta-ksql-statement

• add-source-type-batch
• do-compile-batch
• do-compile-one
• do-m-sort
• do-post-valiedataion
• expand-macro-impl
• expand-this-macro
• get-key
• get-source-name-from-fields
• log
• merge-schema
• process-one
• rekey-source-one
• remove-duplicate-schema
• replace-this-macro

• emit-ksql-batch
• emit-ksql-for-drop

• as-create-fields
• as-select-fields
• create-stream-statement
• current-context
• do-fields-transformation
• do-fields-transformation-batch
• get-partition-key
• get-ref-source-name
• get-sink-key
• make-with-clause
• make-with-clause-with-partitions
• stream-rekey

• add-string-quote
• breadth-first-search
• case-transfer-fn
• field-transformation
• is-constant?
• join-transformation
• make-join-type
• map-constant
• replace-forward-slap
• where-transformation

• csv-data->maps
• get-csv-header
• get-file-list
• get-file-list-by-prefix
• persist-data-flow
• read-csv-file
• save-arvo-model
• save-connector
• save-ksql
• save-ksql-as-rest-req
• save-ksql-to-run-sh
• save-mapping-as-csv
• save-to-run-sh
• write-to-file

No vars found in this namespace.

• create-intermediate-stream-names
• create-join-fields
• debug
• get-entity-name-list
• get-join-entity-name
• join-expand
• join-name-set
• join-transoformation?
• map-join-fields
• partition-join
• replace-name-space

• as-constant
• as-quote-string
• as-referance
• ConstantValue
• emit-connector
• expand-macro
• expand-macro-order
• gen-ksql
• gen-ksql-rekey-stream-from-mapping
• gen-ksql-stream
• gen-ksql-stream-from-mapping
• gen-ksql-stream-from-stream
• gen-ksql-stream-from-topic
• gen-ksql-stream-insert-from-mapping
• gen-ksql-table-from-stream
• gen-ksql-table-from-stream-after-rekey
• get-value
• GetValue
• log-v
• msg
• QuoteStringValue
• RefValue
• transfer-fn

• gen-schema-from-entity-one
• get-file-name
• load-template
• read-csv-header
• read-header

• convert-quoute-to-string
• format-mapping
• format-transormation-fn
• is-digit?
• read-mapping-file
• read-req

• add-logical-type
• arvo-p-type
• arvo-type-map
• as-mapping-schema
• as-vector
• process-fields

• get-source-entity-name-from-sink-schema
• get-source-name-from-fields
• get-source-name-from-join
• get-source-name2
• is-namespace?
• is-process-string?