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

filter

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

返回仅包含满足谓词函数的元素的新 RDD

全页展开

语法

result = filter(obj,func,varargin)

说明

result = filter(obj,func,varargin) 将谓词函数 func 应用于 obj 中的每个元素。满足谓词函数设置的标准的元素将被保留，其他元素将被丢弃。谓词函数是在给定的逻辑函数中返回 true 函数。

输入参数

全部展开

要过滤的输入 RDD，指定为 RDD 对象。

谓词函数，指定为函数句柄。谓词函数在给定的逻辑函数中返回 true。

数据类型: function_handle

表示谓词函数输入的可变长度输入参量列表。

输出参量

全部展开

输出 RDD，以 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);

%% filter
rdd = sc.parallelize({1, 2, 3, 4, 5});
res = rdd.filter(@(x) mod(x,2) == 0).collect();

版本历史记录

在 R2016b 中推出

另请参阅

| | |