riak1.php

foreach ($keys as $key) {
    if ($query) {
        $query->add($this->getBucketName(), $key);
    } else {
        $query = $this->riak->add($this->getBucketName(), $key);
    }
}
$results = $query->map(('function(riakObject){return [{"key":riakObject.key, "document":riakObject.values}];}'))->run();