qbits.alia.manifold — cc.qbits/alia-manifold 4.3.7-beta1

execute clj

(execute session query)

(execute session
         query
         {:keys [success error executor consistency serial-consistency
                 routing-key result-set-fn row-generator codec retry-policy
                 tracing? idempotent? fetch-size timestamp values paging-state
                 read-timeout]})

Same as execute, but returns a promise and accepts :success and :error handlers via options, you can also pass :executor via the option map for the ResultFuture, it defaults to a cachedThreadPool if you don't.

For other options refer to qbits.alia/execute doc

execute-buffered clj

(execute-buffered session query)

(execute-buffered session
                  query
                  {:keys [executor consistency serial-consistency routing-key
                          retry-policy result-set-fn row-generator codec
                          tracing? idempotent? fetch-size buffer-size stream
                          values timestamp paging-state read-timeout]})

Allows to execute a query and have rows returned in a manifold stream. Every value in the stream is a single row. By default the query :fetch-size inherits from the cluster setting, unless you specify a different :fetch-size at query level and the stream inherits fetch size, unless you pass your own :stream with its own properties. If you close the stream the streaming process ends. Exceptions are sent to the stream as a value, it's your responsability to handle these how you deem appropriate. For options refer to qbits.alia/execute doc