onyx.tasks.sql — org.onyxplatform/onyx-sql 0.13.2.0

partition-keys clj

(partition-keys task-name opts)

(partition-keys task-name
                classname
                subprotocol
                subname
                user
                password
                db-name
                table
                id
                task-opts)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword classname :- s/Str subprotocol :- s/Str subname :- s/Str user :- s/Str password :- s/Str db-name :- s/Str table :- s/Keyword id :- s/Keyword task-opts :- #:s{Any s/Any}])

partition-keys-by-uuid clj

(partition-keys-by-uuid task-name opts)

(partition-keys-by-uuid task-name
                        classname
                        subprotocol
                        subname
                        user
                        password
                        db-name
                        table
                        id
                        columns
                        rows-per-segment
                        task-opts)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword classname :- s/Str subprotocol :- s/Str subname :- s/Str user :- s/Str password :- s/Str db-name :- s/Str table :- s/Keyword id :- s/Keyword columns :- [s/Keyword] rows-per-segment :- s/Num task-opts :- #:s{Any s/Any}])

read-rows clj

(read-rows task-name opts)

(read-rows task-name
           classname
           subprotocol
           subname
           user
           password
           db-name
           table
           id
           task-opts)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword classname :- s/Str subprotocol :- s/Str subname :- s/Str user :- s/Str password :- s/Str db-name :- s/Str table :- s/Keyword id :- s/Keyword task-opts :- #:s{Any s/Any}])

SqlPartitionKeysTaskMap clj

SqlReaderTaskMap clj

SqlUpserterTaskMap clj

SqlWriterTaskMap clj

upsert-rows clj

(upsert-rows task-name opts)

(upsert-rows task-name
             classname
             subprotocol
             subname
             user
             password
             db-name
             table
             task-opts)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword classname :- s/Str subprotocol :- s/Str subname :- s/Str user :- s/Str password :- s/Str db-name :- s/Str table :- s/Keyword task-opts :- #:s{Any s/Any}])

write-rows clj

(write-rows task-name opts)

(write-rows task-name
            classname
            subprotocol
            subname
            user
            password
            db-name
            table
            copy?
            copy-columns
            task-opts)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword classname :- s/Str subprotocol :- s/Str subname :- s/Str user :- s/Str password :- s/Str db-name :- s/Str table :- s/Keyword copy? :- s/Bool copy-columns :- [s/Keyword] task-opts :- #:s{Any s/Any}])