主要内容

本页采用了机器翻译。点击此处可查看最新英文版本。

keyLimit

类: matlab.compiler.mlspark.RDD
命名空间: matlab.compiler.mlspark

返回在溢出到磁盘之前可以存储的唯一键的阈值

语法

result = keyLimit(obj)

说明

result = keyLimit(obj) 返回 obj 中在溢出到磁盘之前可以存储在内存中的唯一键的阈值。

输入参数

全部展开

输入 RDD,指定为 RDD 对象。

输出参量

全部展开

在溢出到磁盘之前可以存储的唯一键的阈值,以标量值的形式返回。

示例

全部展开

使用 keyLimit 方法返回可存储在指定 Spark™ 属性的 containers.Map 对象中的唯一键的阈值。超出阈值的密钥将溢出到磁盘。

%% Connect to Spark
% Change number of keys from a default threshold of 10,000 to 500
sparkProp = containers.Map( ...
    {'spark.executor.cores',...
    'spark.executor.memory',...
    'spark.executor.instances',...
    'spark.matlab.worker.numOfKeys', ...
    }, ...
    {'1',...
    '2g',...
    '1', ...
    '500'});
conf = matlab.compiler.mlspark.SparkConf('AppName','myApp', ...
                        'Master','local[1]','SparkProperties',sparkProp);
sc = matlab.compiler.mlspark.SparkContext(conf);

%% keyLimit
x = sc.parallelize({1,2,3});
x.keyLimit % ans: 500

版本历史记录

在 R2016b 中推出

另请参阅