Feladat #2 Írjon olyan lekérdezést, amely minden osztályban a TOP-3 alkalmazottat mutatja a fizetés szerint. Mutassa az osztály nevét, az alkalmazott nevét és fizetését. employee tábla: | id | name | salary | dept_id | |----|-------|--------|---------| | 10 | John | 1000 | 2 | | 20 | Tom | 5000 | 3 | | 30 | Bill | 3000 | 2 | department tábla: | id | name | |----|-----------| | 1 | Marketing | | 2 | IT | | 3 | Pénzügy | Kimenet: department_name, num, employee_name, salary cte-ként: 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
Mi a különbség az ACID és a CAP-tétel között?
Végső eredmény: | 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
Mi a shuffle veszélye a Spark-ben?
Mi az az Adaptív Lekérdezés Végrehajtás (AQE)?
Milyen szakaszokból áll egy tranzakció?
Dolgozott már Python dekorátorokkal? Mi azok és hol alkalmazzák őket?
Milyen helyzetben romolhat a szótár szerinti keresés a legrosszabb esetre?
Beszéljen a Python változtatható és változtathatatlan adattípusairól, és adjon példákat.
Hogyan kezelte általában a hibákat és figyelmeztetéseket a pipeline-okban?
Hogyan kerülhető el, hogy körülbelül 700 DAG futás egyidejűleg induljon a catchup/backfill során az Airflow-ban?
Milyen adatminőségi kockázatok vannak?
Dolgozott már olyan paraméterekkel és hint-ekkel, amelyek meghatározzák a Broadcast Join használatát?
Magyarázd el a lustán és azonnali számításokat a Sparkban.
Mesélj részletesebben a hálózatról: mi az és miért fontos?
Kérdés #1 Hány rekordot ad vissza a lekérdezés az inner, left, right, full join segítségével két tábla összekapcsolásakor az id attribútum szerint? t1 t2 | id | | id | |-----| |-----| | 1 | | 1 | | 2 | | 1 | | 3 | | 3 | | 0 | | 5 | | NULL| | NULL| | NULL| inner: left: right: full outer:
Hogyan különbözteted meg a technikai és üzleti adatellenőrzéseket, és ki kellene meghatároznia az elvárásokat ezekhez?
Milyen fizikai stratégiákat ismer a join végrehajtásához?
Mi a különbség a repartition és a coalesce között a Spark-ben?
Mit tudsz a serializálásról és deserializálásról a Spark/UDF kontextusában?