Входное хранилище данных, указанное как объект хранилища данных. Используйте datastore для создания объекта хранилища данных из набора данных.

mapreduce работает только с детерминированными хранилищами данных. То есть, если вы используете read в хранилище данных, сбросьте хранилище данных с помощью resetзатем снова считывайте хранилище данных, а затем возвращаемые данные должны быть одинаковыми в обоих случаях. mapreduce вычисления с использованием хранилища данных, которое не является детерминированным, могут привести к непредсказуемым результатам. Дополнительные сведения см. в разделе Выбор хранилища данных для формата файла или приложения.

Дескриптор функции для отображения функции. mapfun принимает блоки из хранилища входных данных ds, а затем использует add и addmulti функции для добавления пар ключ-значение к промежуточному KeyValueStore объект. Количество вызовов функции отображения по mapreduce равно количеству блоков в datastore (количество блоков определяется ReadSize свойство хранилища данных).

Входные данные функции карты: data, info, и intermKVStore, который mapreduce автоматически создает и передает функции карты:

Пример шаблона для функции карты:

function myMapper(data, info, intermKVStore)
%do a calculation with the data block
add(intermKVStore, key, value)
end

Пример: @myMapper

Типы данных: function_handle

Дескриптор функции для уменьшения функции. mapreduce требования reducefun один раз для каждого уникального ключа, добавленного в промежуточный KeyValueStore функцией карты. В каждом вызове, mapreduce передает значения, связанные с активным ключом, reducefun в качестве ValueIterator объект. reducefun функция петлит по значениям для каждой клавиши, используя hasnext и getnext функции. Затем, после выполнения некоторых вычислений, он записывает пары ключ-значение в конечный вывод.

Входами для функции уменьшения являются intermKey, intermValIter, и outKVStore, который mapreduce автоматически создает и передает функции уменьшения:

Примером шаблона для функции сокращения является

function myReducer(intermKey, intermValIter, outKVStore)
while hasnext(intermValIter)
    X = getnext(intermValIter);
    %do a calculation with the current value, X
end
add(outKVStore, key, value)
end

Пример: @myReducer

Типы данных: function_handle

Среда выполнения, заданная как объект MapReducer. mr является результатом вызова mapreducer функция. Дефолт mr аргумент является вызовом gcmr, которая использует глобальную среду выполнения по умолчанию для mapreduce (в MATLAB по умолчанию mapreducer(0), который возвращает SerialMapReducer объект).