Класс MapReduce

__construct()source public

__construct( Traversable $data , callable $mapper , callable $reducer = null )

Конструктор

Пример:

Разделить все уникальные нечётные и чётные числа в массиве

$data = new \ArrayObject([1, 2, 3, 4, 5, 3]);
 $mapper = function ($value, $key, $mr) {
     $type = ($value % 2 === 0) ? 'even' : 'odd';
     $mr->emitIntermediate($value, $type);
 };

 $reducer = function ($numbers, $type, $mr) {
     $mr->emit(array_unique($numbers), $type);
 };
 $results = new MapReduce($data, $mapper, $reducer);

Предыдущий пример сгенерирует следующий результат:

['odd' => [1, 3, 5], 'even' => [2, 4]]

Параметры

Traversable $data

исходные данные для обработки

callable $mapper

обработчик mapper. Эта функция будет принимать 3 аргумента. Первый — текущее значение, второй — текущий ключ результата, а третий — экземпляр этого класса, так что вы можете вызывать эмиттеры результата.

callable $reducer необязательно null

обработчик reducer. Эта функция будет принимать 3 аргумента. Первый — список значений внутри пакета, второй — имя пакета, созданного на этапе отображения, а третий — экземпляр этого класса.

_execute()source protected

_execute( )

Выполняет фактический алгоритм Map-Reduce. Перебирает исходные данные и вызывает функцию mapper для каждого элемента, затем для каждого промежуточного букета, созданного на этапе Map, вызывает функцию reduce.

Исключения

LogicException

если emitIntermediate был вызван, но функция reducer не была предоставлена

emit()source public

emit( mixed $val , string|null $key = null )

Добавляет новую запись в окончательный список результатов и необязательно присваивает ей ключ.

Параметры

mixed $val

Значение, которое будет добавлено в окончательный список результатов

string|null $key необязательно null

необязательный ключ для присвоения значению

emitIntermediate()source public

emitIntermediate( mixed $val , string $bucket )

Добавляет новую запись в пакет с меткой $key, обычно в результате отображения одной записи из исходных данных.

Параметры

mixed $val

Сама запись для хранения в пакете

string $bucket

имя пакета, куда поместить запись

getIterator()source public

getIterator( )

Возвращает итератор с конечным результатом выполнения этапов Map и Reduce над исходными данными

Возвращаемое значение

ArrayIterator

Реализация

IteratorAggregate::getIterator()

false

[]

[]