映射数据流中的筛选转换

适用于：Azure 数据工厂 Azure Synapse Analytics

数据流在 Azure 数据工厂和 Azure Synapse 管道中均可用。 本文适用于映射数据流。 如果不熟悉转换，请参阅介绍性文章使用映射数据流转换数据。

筛选转换允许根据条件对行进行筛选。 输出流包括与筛选条件匹配的所有行。 筛选转换类似于 SQL 中的 WHERE 子句。

Configuration

使用数据流表达式生成器为筛选条件输入表达式。 若要打开表达式生成器，请单击蓝色框。 筛选条件必须为布尔型。 有关如何创建表达式的详细信息，请参阅表达式生成器文档。

数据流脚本

语法

<incomingStream>
    filter(
        <conditionalExpression>
    ) ~> <filterTransformationName>

示例

下面的示例是一个名为 FilterBefore1960 的筛选转换，它接收传入流 CleanData。 筛选条件是 year <= 1960 表达式。

在 UI 中，此转换如下图所示：

此转换的数据流脚本位于下面的代码片段中：

CleanData
    filter(
        year <= 1960
    ) ~> FilterBefore1960

相关内容

使用选择转换筛选掉列