Užduotis #2 Parašykite užklausą, kuri rodo TOP-3 darbuotojus pagal atlyginimą kiekviename skyriuje. Rodyti skyriaus pavadinimą, darbuotojo vardą ir jo atlyginimą. employee lentelė: | id | name | salary | dept_id | |----|-------|--------|---------| | 10 | John | 1000 | 2 | | 20 | Tom | 5000 | 3 | | 30 | Bill | 3000 | 2 | department lentelė: | id | name | |----|-----------| | 1 | Marketing | | 2 | IT | | 3 | Finansai | Išvestis: department_name, num, employee_name, salary su cte kaip( select d.name as department_name, e.name as employee_name, e.salary, dense_rank iš employee e jungtis su department d on e.id = d.id
Data Engineer
Kas yra Adaptatyvus Užklausų Vykdymas (AQE)?
Kuo skiriasi ACID ir CAP teorema?
Kokiose etapose yra sudaryta operacija?
Galutinis rezultatas: | customer_id | gap_days | |-------------|----------| | 1 | 123 | | 2 | 120 | su cte kaip( pasirinkite order_id, customer_id, order_dt, lag(order_dt) per(partition by customer_id order by order_dt) kaip prev_order_ft, datediff(day, prev_order_ft, order_dt) kaip gap_days iš Orders ) pasirinkite customer_id, max(gap_days) kaip gap_days iš cte kur gap_days > 60 grupuoti pagal customer_id
Kokia yra shuffle pavojus Spark'e?
Kokiu atveju žodyno paieška gali nusileisti iki blogiausio atvejo?
Ar kada nors dirbote su dekoratoriais Python? Kas jie yra ir kur jie taikomi?
Papaskinkite apie mutabilius ir nemutabilius duomenų tipus Python ir pateikite pavyzdžių.
Ar dirbote su parametrais ir hints, kurie nustato Broadcast Join naudojimą?
Kaip įprastai tvarkydavote klaidas ir įspėjimus pipeline'ose?
Papasakok daugiau apie tinklą: kas tai ir kodėl tai svarbu?
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:
Kaip išvengti maždaug 700 DAG vykdymo vienu metu catchup/backfill metu Airflow?
Paaiškinkite tinginius ir nedelinius skaičiavimus Spark.
Kokie yra duomenų kokybės rizikos?
Ką žinote apie serializaciją ir deserializaciją Spark/UDF kontekste?
Kaip skiri techninius ir verslo duomenų patikrinimus, ir kas turėtų nustatyti jų reikalavimus?
Kodėl bool([""]) grąžina True?
Kokias fizines jungimo vykdymo strategijas žinote?