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

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

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

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

_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

[]

[]