Введите datastore, заданный как объект datastore. Используйте функцию datastore, чтобы создать объект datastore из вашего набора данных.

mapreduce работает только с хранилищами данных, которые детерминированы. Таким образом, если вы используете read на datastore, сбрасываете datastore с reset, и затем читаете datastore снова, затем возвращенные данные должны быть тем же самым в обоих случаях. вычисления mapreduce, включающие datastore, который не детерминирован, могут привести к непредсказуемым результатам. Смотрите Выбирают Datastore for File Format или Application для получения дополнительной информации.

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

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

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

function myMapper(data, info, intermKVStore)
%do a calculation with the data chunk
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).