Vəzifə #2 Hər bir şöbədə ən yüksək maaş alan TOP-3 işçini göstərən sorğu yazın. Şöbə adını, işçinin adını və onun maaşını göstərin. employee cədvəli: | id | name | salary | dept_id | |----|-------|--------|---------| | 10 | John | 1000 | 2 | | 20 | Tom | 5000 | 3 | | 30 | Bill | 3000 | 2 | department cədvəli: | id | name | |----|-----------| | 1 | Marketing | | 2 | IT | | 3 | Maliyyə | Nəticə: department_name, num, employee_name, salary cte kimi: select d.name as department_name, e.name as employee_name, e.salary, dense_rank from employee e join department d on e.id = d.id
Data Engineer
Uyğunlaşdırılmış Sorğu İcrası (AQE) nədir?
ACID və CAP nəzəriyyəsi arasındakı fərq nədir?
Nəticə: | customer_id | gap_days | |-------------|----------| | 1 | 123 | | 2 | 120 | with cte as( select order_id, customer_id, order_dt, lag(order_dt) over(partition by customer_id order by order_dt) as prev_order_ft, datediff(day, prev_order_ft, order_dt) as gap_days from Orders ) select customer_id, max(gap_days) as gap_days from cte where gap_days > 60 group by customer_id
Əməliyyat hansı mərhələlərdən ibarətdir?
Spark-də shuffle-in təhlükəsi nədir?
Hansı vəziyyətdə lüğətə axtarış ən pis halına qədər pisləşə bilər?
Python-da dekoratorlarla işlədinizmi? Bunlar nədir və harada tətbiq olunur?
Python-da dəyişdirilə bilən və dəyişdirilə bilməyən məlumat tipləri haqqında danışın və nümunələr göstərin.
Broadcast Join istifadəni müəyyən edən parametrlər və ipuçları ilə işlədinizmi?
Şəbəkə haqqında daha ətraflı danış: bu nədir və niyə vacibdir?
Ənənəvi olaraq, pipeline-lərdə səhvlər və xəbərdarlıqları necə idarə edirdiniz?
Spark-də tənbəl və dərhal hesablamaları izah edin.
Sual #1 İki cədvəli id atributu üzrə birləşdirərkən inner, left, right, full join ilə neçə qeyd qaytarılacaq? t1 t2 | id | | id | |-----| |-----| | 1 | | 1 | | 2 | | 1 | | 3 | | 3 | | 0 | | 5 | | NULL| | NULL| | NULL| inner: left: right: full outer:
Airflow-da catchup/backfill zamanı təxminən 700 DAG icrasının eyni vaxtda başlamasının qarşısını almaq üçün necə?
Məlumatların keyfiyyətinə dair risklər hansılardır?
Niyə bool([""]) True qaytarır?
Spark/UDF kontekstində seriyalaşdırma və deserializasiya haqqında nə bilirsiniz?
Spark-də repartition və coalesce arasındakı fərq nədir?
Join icra etmək üçün hansı fiziki strategiyaları bilirsiniz?