Миграция SQL функции в Spark- SQL - PullRequest
Новая
       169

Миграция SQL функции в Spark- SQL

0 голосов
/ 06 августа 2020

У меня есть SQL Функция [workspace].[my_function] (param_a, param_b), которая принимает 2 параметра, выполняет SQL -Query на основе этих параметров и возвращает таблицу. Возвращенная таблица затем используется, как показано ниже. Как мне решить эту проблему в Spark- SQL? UDF не будет работать, поскольку я не могу выполнить SQL -Query в UDF ... 

create FUNCTION [workspace].[my_function]
  ( @param_a varchar(18), @param_b varchar(18))

RETURNS 
@A_Table TABLE (column varchar(4))

INSERT INTO @A_Table (column)
SELECT x,y
FROM z
JOIN w
ON w.col = z.col
...
;
RETURN

SELECT
    a,
    b,
    c,
    [workspace].[my_function](a, b) AS function_result
FROM xyz
JOIN ...
...