scaerospike
scaerospike copied to clipboard
Support Statements and Multiple Ops on a Record (Feature Request)
Provision to do Multiple Ops on a Record. http://www.aerospike.com/docs/client/java/usage/kvs/multiops.html Provision to execute statements on client. http://www.aerospike.com/docs/client/java/usage/query/query.html
I kinda did it in my own fork.
It looks like this
private[aerospike] def query[R](policy: QueryPolicy, stmt: Statement) = {
log.info(s"called for $stmt")
var results = Vector.empty[Map[String, R]]
val recordSet = underlying.query(policy, stmt)
while (recordSet.next()) {
results +:= extractMultiBin[R](recordSet.getRecord())
}
results
}
There are better ways, I'm sure :)