Appel de fonction table (TVF)

S’applique à : Databricks SQL Databricks Runtime

Appelle une fonction qui renvoie un groupe ou un ensemble de lignes sous la forme d’une référence de table.

Un TVF peut être un :

• Fonction de table SQL définie par l’utilisateur.

• La fonction table range.

• Toute fonction de générateur table, telle que l’explosion.

  S’applique à : Databricks SQL Databricks Runtime 12.2 LTS et versions ultérieures.

• Vue de métrique paramétrée.

  S’applique à : Databricks SQL Databricks Runtime 18.2 et versions ultérieures.

  Important

  Cette fonctionnalité est disponible en préversion publique.

Remarque

UDTF Hive ne peut pas être appelé comme référence de table, mais doit être appelé depuis SELECT ou en utilisant la LATERAL VIEWclause .

Syntaxe

function_name ( [ expression [, ...] ] ) [ table_alias ]

Paramètres

• function_name

  Fonction table. Si la fonction ne peut pas être résolue en tant que fonction table, Azure Databricks déclenche UNRESOLVABLE_TABLE_VALUED_FUNCTION.

• expression

  Combinaison d’un ou plusieurs opérateurs, valeurs et fonctions SQL qui produit une valeur.

• table_alias

  Étiquette facultative pour référencer le résultat de la fonction et ses colonnes.

Conditions d’erreur courantes

• NUM_TABLE_VALUE_ALIASES_MISMATCH
• UNRESOLVABLE_TABLE_VALUED_FUNCTION
• WRONG_NUM_ARGS. WITHOUT_SUGGESTION

Exemples

-- range call with end
> SELECT * FROM range(6 + cos(3));
   0
   1
   2
   3
   4

-- range call with start and end
> SELECT * FROM range(5, 10);
   5
   6
   7
   8
   9

-- range call with numPartitions
> SELECT * FROM range(0, 10, 2, 200);
   0
   2
   4
   6
   8

-- range call with a table alias
> SELECT * FROM range(5, 8) AS test;
   5
   6
   7

-- Create a SQL UDTF and invoke it
> CREATE OR REPLACE FUNCTION table_func(a INT) RETURNS TABLE
    RETURN SELECT a * c1 AS res FROM VALUES(1), (2), (3), (4) AS T(c1)

> SELECT * FROM table_func(5);
   5
  10
  15
  20

-- Using lateral correlation
>  SELECT table_func.res FROM VALUES(10), (20) AS S(c1), LATERAL table_func(c1);
  10
  20
  20
  40
  30
  60
  40
  80

-- Scalar functions are not allowed in the FROM clause
> SELECT * FROM trim('hello  ');
  Error: UNRESOLVABLE_TABLE_VALUED_FUNCTION

Sur Databricks SQL et Databricks Runtime 12.2 LTS et versions ultérieures :

> SELECT * FROM explode(array(10, 20));
  10
  20

> SELECT * FROM inline(array(struct(1, 'a'), struct(2, 'b')));
 col1 col2
 ---- ----
    1    a
    2    b

> SELECT * FROM posexplode(array(10,20));
 pos col
 --- ---
   0  10
   1  20

> SELECT * FROM stack(2, 1, 2, 3);
 col0 col1
 ---- ----
    1    2
    3 null

> SELECT * FROM json_tuple('{"a":1, "b":2}', 'a', 'b');
  c0  c1
 --- ---
   1   2

> SELECT * FROM parse_url('http://spark.apache.org/path?query=1', 'HOST');
  spark.apache.org

> SELECT * FROM VALUES(1), (2) AS t1(c1), LATERAL explode (ARRAY(3,4)) AS t2(c2);
 c1 c2
 -- --
  1  3
  1  4
  2  3
  2  4

Sur Databricks SQL et Databricks Runtime 18.2 et versions ultérieures, vous pouvez appeler une vue de métrique paramétrable en tant que fonction table. Transmettez chaque paramètre en tant qu’argument nommé ou omettez les arguments pour utiliser les valeurs par défaut lorsque chaque paramètre en a un. Pour une vue de métrique nommée discounted_sales_metrics qui définit un discount paramètre :

-- Pass a named argument
> SELECT order_priority, measure(discounted_revenue)
  FROM discounted_sales_metrics(discount => 0.15)
  GROUP BY ALL;

-- Omit the arguments to use the parameter defaults
> SELECT order_priority, measure(discounted_revenue)
  FROM discounted_sales_metrics
  GROUP BY ALL;

Articles connexes

• SELECT