Параметризация Spark SQL с датами - PullRequest
Новая
       11

Параметризация Spark SQL с датами

0 голосов
/ 11 июля 2019

Я хотел бы динамически параметризовать запросы SQL с текущей датой и минус 90 дней назад, чтобы получить самые последние данные. 

select current_date();

возвращает 2019-07-11 текущую дату, однако: 

SET start_date as select current_date();

возвращает неопределенное значение или строковый литерал 'select current_date ()'

Я надеюсь настроить запрос следующим образом: 

%sql
SET training_window = 90
SET end_date as select date_format(current_date(), 'yyyy-M-d');
SET start_date = date_format(date_sub(start_date, training_window), 'yyyy-M-d');

select count(*)
from my_table
where submitted_dt BETWEEN ${start_date} AND ${end_date_date};
...