Создайте codistributed массив из распределенных данных
D = codistributed.build(L,codist)
D = codistributed.build(L,codist,'noCommunication')
D = codistributed.build(L,codist) формирует codistributed массив с getLocalPart(D) = L. codistributed массив D создается, как будто вы объединили все копии локального массива L. Схема распределения задана codist. Глобальная проверка ошибок гарантирует, что локальные части соответствуют заданной схеме распределения. Для получения информации о построении codistributor объекты, смотрите страницы с описанием для codistributor1d и codistributor2dbc.
D = codistributed.build(L,codist,'noCommunication') создает codistributed массив, не выполняя коммуникаций межрабочего для проверки ошибок.
codist должно быть завершено, который можно проверить вызов codist.isComplete(). Требования к размеру и структуре локальной части L зависьте от класса codist. Для 1D и 2D циклического блоком codistributors, L должен иметь тот же класс и разреженность на всех рабочих. Кроме того, локальная часть L должна представлять область, описанную globalIndices метод на codist.
Создайте codistributed массив размера, 1001 1001 таким образом что столбец ii содержит значение ii.
spmd N = 1001; globalSize = [N,N]; % Distribute the matrix over the second dimension (columns), % and let the codistributor derive the partition from the % global size. codistr = codistributor1d(2, ... codistributor1d.unsetPartition,globalSize) % On 4 workers, codistr.Partition equals [251,250,250,250]. % Allocate storage for the local part. localSize = [N, codistr.Partition(labindex)]; L = zeros(localSize); % Use globalIndices to map the indices of the columns % of the local part into the global column indices. globalInd = codistr.globalIndices(2); % On 4 workers, globalInd has the values: % 1:251 on worker 1 % 252:501 on worker 2 % 502:751 on worker 3 % 752:1001 on worker 4 % Initialize the columns of the local part to % the correct value. for localCol = 1:length(globalInd) globalCol = globalInd(localCol); L(:,localCol) = globalCol; end D = codistributed.build(L,codistr) end
codistributor1d | codistributor2dbc | gather | globalIndices | getLocalPart | redistribute | subsasgn | subsref