qbits.alia.manifold
execute
(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]})(execute session query)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
(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]})(execute-buffered session query)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