1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
<?php
namespace Basho\Tests;
use Basho\Riak;
use Basho\Riak\Command;
/**
* Functional tests related to Counter CRDTs
*
* @author Christopher Mancini <cmancini at basho d0t com>
*/
class MapReduceOperationsTest extends TestCase
{
protected static $mr_content = [
'p0' => "Alice was beginning to get very tired of sitting by her sister on the bank, and of having nothing to do: once or twice she had peeped into the book her sister was reading, but it had no pictures or conversations in it, 'and what is the use of a book,' thought Alice 'without pictures or conversation?'",
'p1' => "So she was considering in her own mind (as well as she could, for the hot day made her feel very sleepy and stupid), whether the pleasure of making a daisy-chain would be worth the trouble of getting up and picking the daisies, when suddenly a White Rabbit with pink eyes ran close by her.",
'p2' => "The rabbit-hole went straight on like a tunnel for some way, and then dipped suddenly down, so suddenly that Alice had not a moment to think about stopping herself before she found herself falling down a very deep well."
];
public static function setUpBeforeClass()
{
parent::setUpBeforeClass();
foreach (static::$mr_content as $key => $value) {
$command = (new Command\Builder\StoreObject(static::$riak))
->buildObject($value)
->buildLocation($key, 'phptest_mr')
->build();
$command->execute();
}
}
public static function tearDownAfterClass()
{
foreach (static::$mr_content as $key => $object) {
$command = (new Command\Builder\DeleteObject(static::$riak))
->buildLocation($key, 'phptest_mr')
->build();
$command->execute();
}
parent::tearDownAfterClass();
}
public function testFetch()
{
$command = (new Command\Builder\MapReduce\FetchObjects(static::$riak))
->addBucketInput(new Riak\Bucket('phptest_mr'))
->buildMapPhase('', '',
"function(v) {var m = v.values[0].data.toLowerCase().match(/[A-Za-z]*/g); var r = []; for(var i in m) {if(m[i] != '') {var o = {};o[m[i]] = 1;r.push(o);}}return r;}")
->buildReducePhase('', '',
"function(v) {var r = {};for(var i in v) {for(var w in v[i]) {if(w in r) r[w] += v[i][w]; else r[w] = v[i][w];}}return [r];}")
->build();
$response = $command->execute();
$this->assertEquals('200', $response->getCode(), $response->getMessage());
$results = $response->getResults();
$this->assertEquals(8, $results[0]->the);
}
}
|
