ROW FILTER 子句

适用于：已选择“是” Databricks SQL 已选择“是” Databricks Runtime 12.2 LTS 及更高版本 仅适用于 Unity Catalog

指定一个函数，当从关系中提取行时，该函数作为过滤器应用。

可以在以下情况中添加行筛选器：

重要

从数据源提取行后，将立即应用行筛选器。

有关如何使用行筛选器的详细信息，请参阅 行筛选器和列掩码。

所需权限

若要分配向表添加行筛选器的函数，您必须对函数、EXECUTE架构和USE SCHEMA父目录具有USE CATALOG权限。

如果在 创建新 表时添加行筛选器，则必须对架构具有 CREATE TABLE 特权。

如果要在 现有 表上添加或删除行筛选器，则必须是表所有者，或者同时具有 MANAGE 表的和 SELECT 权限。

如果同一语句也会更改表架构，则还需要 MODIFY 对表拥有权限。

语法

ROW FILTER func_name ON ( [ column_name | constant_literal [, ...] ] ) [...]

参数

  • func_name

    标量 SQL UDF。

    函数的返回类型必须为 BOOLEAN。 如果函数返回 FALSE 或 NULL，行会被筛选掉。

  • column_name

    指定要传递给 func_name 的主题关系列。 每个 column_name 必须可强制转换为相应的 func_name。 必须提供函数签名所需的任意数量的列。 此功能支持传递零个输入列，在这种情况下，SQL UDF 必须接受零个参数，并返回一个布尔结果，而与输入行的值无关。

    重要

    如果列的数据类型与相应的函数参数类型不完全匹配，则隐式转换列值。 禁用后 ANSI_MODE ，无法强制转换的值会以无提示方式转换为 NULL，从而产生意外的筛选结果。 UDF 参数类型必须与传递给它们的列的数据类型匹配。 请参阅 数据类型不匹配行为。

  • constant_literal

    指定一个常量参数，其类型与函数参数的类型匹配。 支持以下类型：STRING、数字（INTEGER、FLOAT,、DOUBLE、DECIMAL ...）BOOLEAN、INTERVAL、NULL。

示例

可以在 行筛选器和列掩码中找到更多示例。

-- Create a table with a row filter column
> CREATE FUNCTION filter_emps(dept STRING) RETURN is_account_group_member(dept);
> CREATE TABLE employees(emp_name STRING, dept STRING) WITH ROW FILTER filter_emps ON (dept);
> INSERT INTO employees VALUES ('Jones', 'Engineering'), ('Smith', 'Sales');

-- As a member of engineering
> SELECT * FROM employees;
  Jones Engineering

-- As a member of sales
> SELECT * FROM employees;
  Smith Sales
  • Last updated on