Как я могу использовать существующую функцию ниже Hive Query - PullRequest
Новая
       31

Как я могу использовать существующую функцию ниже Hive Query

0 голосов
/ 28 мая 2019

Я знаком с SQl, но не с Hive, и мне нужно изменить существующий раздел кода ниже.

df_tic = hiveContext.sql("""select distinct oe.*, o.*, so.*
from 
BOE oe join MSO o on oe.ms_order_id = o.ms_order_id
join SUBO so on so.ms_order_id = o.ms_order_id
join JOB j on j.entity_id = so.ms_sub_order_id
join TASK t on  t.wf_job_id = j.wf_job_id
and  o.order_type = 900 
and o.entered_date between  date_sub(current_date(),3) 
and date_sub(current_date(),2)
and j.entity_type = 5 
and exists -- failure 
( select 'X' 
from  TASK  t 
and ((t.name like '%Error%') or (t.name like '%Correct%') or (t.name = '%Create%')) 
on t.wf_job_id = j.wf_job_id ) 
order by o.USRP
""")

Я получаю сообщение об ошибке в существующем разделе (как и ожидалось).Кто-нибудь может мне помочь обновить существующий раздел, чтобы он работал?

...