onyx.plugin.sql — org.onyxplatform/onyx-sql 0.13.3.0

create-pool clj

(create-pool spec)

partition-keys clj

(partition-keys {:keys [onyx.core/task-map] :as event})

partition-table clj

(partition-table {:keys [onyx.core/task-map onyx.core/slot-id] :as event}
                 table
                 id
                 colums
                 pool)

read-rows clj

(read-rows pool table id columns [low high])

task->pool clj

(task->pool task-map)

upsert-rows clj

(upsert-rows pipeline-data)

write-rows clj

(write-rows pipeline-data)