Exponenta Banner
exponenta event banner

getNumPartitions

Класс: matlab.compiler.mlspark.RDD
Пакет: matlab.compiler.mlspark

Возвращает количество разделов в RDD

развернуть все на странице

Синтаксис

numPartitions = getNumPartitions(obj)

Описание

numPartitions = getNumPartitions(obj) возвращает количество разделов в obj.

Входные аргументы

развернуть все

Входной RDD, указанный как RDD объект.

Выходные аргументы

развернуть все

Число разделов во входном RDD, возвращаемое как скалярное значение.

Примеры

развернуть все

Используйте getNumPartitions для возврата количества разделов в RDD.

%% Connect to Spark
sparkProp = containers.Map({'spark.executor.cores'}, {'1'});
conf = matlab.compiler.mlspark.SparkConf('AppName','myApp', ...
                        'Master','local[1]','SparkProperties',sparkProp);
sc = matlab.compiler.mlspark.SparkContext(conf);

%% getNumPartitions
inputRDD = sc.parallelize({'A','B','C','A','B'},2);
redRDD= inputRDD.map(@(x)({x,1})).reduceByKey(@(x,y)(x+y),3);
coaRDD = redRDD.coalesce(2); % {{{'B',2}},{{'C',1},{'A',2}}}*
disp(['Number of Partitions: ' num2str(coaRDD.getNumPartitions())]);

См. также

| | |

Представлен в R2016b

Документация по компилятору MATLAB

Поддержка