numpartitions

데이터저장소 파티션 개수

구문

n = numpartitions(ds)

n = numpartitions(ds,pool)

설명

n = numpartitions(ds)는 데이터저장소 ds에 대한 디폴트 파티션 개수를 반환합니다.

n = numpartitions(ds,pool)은 pool로 지정된 병렬 풀에서 데이터저장소 액세스를 병렬 처리할 파티션 개수를 반환합니다. 데이터저장소 액세스를 병렬 처리하려면 Parallel Computing Toolbox™가 설치되어 있어야 합니다.

예제

파티션 개수

샘플 파일 mapredout.mat에서 데이터저장소를 만듭니다. 이 파일은 mapreduce 함수의 출력 파일입니다.

ds = datastore('mapredout.mat');

디폴트 파티션 개수를 가져옵니다.

n = numpartitions(ds)

n = 1

기본적으로 ds에는 하나의 작은 파일만 포함되므로 하나의 파티션만 있습니다.

데이터저장소를 파티셔닝하고 첫 번째 파트에 대응하는 데이터저장소를 반환합니다.

subds = partition(ds,n,1);

subds에서 데이터를 읽습니다.

while hasdata(subds)
    data = read(subds);
end

병렬 데이터저장소 액세스를 위한 파티션 개수

현재 병렬 풀에서 데이터저장소 액세스를 병렬 처리할 파티션 개수를 가져옵니다. Parallel Computing Toolbox가 설치되어 있어야 합니다.

샘플 파일 mapredout.mat에서 데이터저장소를 만듭니다. 이 파일은 mapreduce 함수의 출력 파일입니다.

ds = datastore('mapredout.mat');

현재 병렬 풀에서 데이터저장소 액세스를 병렬 처리할 파티션 개수를 가져옵니다.

n = numpartitions(ds, gcp);

데이터저장소를 파티셔닝하고 각 파트에서 데이터를 읽습니다.

parfor ii=1:n
    subds = partition(ds,n,ii);
    while hasdata(subds)
        data = read(subds);
    end
end

입력 인수

ds — 입력 데이터저장소

데이터저장소

입력 데이터저장소입니다. datastore 함수를 사용하여 데이터에서 datastore 객체를 만들 수 있습니다.

pool — 병렬 풀

병렬 풀 객체

병렬 풀 객체입니다.

예: gcp

참고 항목

datastore | partition

도움말 항목

• Partition a Datastore in Parallel (Parallel Computing Toolbox)

R2015a에 개발됨

×

Open Example (ko_KR)

A modified version of this example exists on your system. Do you want to open this version instead? (ko_KR)

No, overwrite the modified version (ko_KR) Yes (ko_KR)