Класс 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

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

_execute()source protected

_execute( )

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

Исключения

LogicException

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

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

[]

[]