Sobes.tech

Data Engineer

Задача #2 Напишете заявка, която показва TOP-3 служители по заплата във всеки отдел. Показване на името на отдела, името на служителя и неговата заплата. таблица employee: | id | name | salary | dept_id | |----|-------|--------|---------| | 10 | John | 1000 | 2 | | 20 | Tom | 5000 | 3 | | 30 | Bill | 3000 | 2 | tаблица department: | id | name | |----|-----------| | 1 | Marketing | | 2 | IT | | 3 | Финанси | Изход: department_name, num, employee_name, salary с cte като( select d.name as department_name, e.name as employee_name, e.salary, dense_rank от employee e присъединете към department d на e.id = d.id

225

Какво е Адаптивно изпълнение на заявки (AQE)?

191

Каква е разликата между ACID и CAP теоремата?

190

От кои етапи се състои транзакцията?

182

Краен резултат: | customer_id | gap_days | |-------------|----------| | 1 | 123 | | 2 | 120 | с cte като( изберете order_id, customer_id, order_dt, lag(order_dt) върху(разделяне по customer_id поред по order_dt) като prev_order_ft, datediff(ден, prev_order_ft, order_dt) като gap_days от Orders ) изберете customer_id, max(gap_days) като gap_days от cte където gap_days > 60 grupo по customer_id

182

Каква е опасността от shuffle в Spark?

181

Работили ли сте някога с декоратори в Python? Какво представляват и къде се използват?

179

В коя ситуация търсенето в речник може да се влоши до най-лошия случай?

179

Разкажете за променяемите и непроменяемите типове данни в Python и дадете примери.

175

Работили ли сте с параметри и hints, които определят използването на Broadcast Join?

174

Разкажи повече за мрежата: какво е и защо е важна?

166

Обикновено как обработвахте грешки и предупреждения в пайплайните?

165

Обяснете ленивите и немедлените изчисления в Spark.

164

Въпрос #1 Колко записа ще върне заявката с inner, left, right, full join на две таблици при свързването им по атрибута id t1 t2 | id | | id | |-----| |-----| | 1 | | 1 | | 2 | | 1 | | 3 | | 3 | | 0 | | 5 | | NULL| | NULL| | NULL| inner: left: right: full outer:

163

Какви са рисковете за качеството на данните?

161

Как да избегнете едновременния старт на около 700 DAG изпълнения при catchup/backfill в Airflow?

161

Какво знаеш за сериализацията и десериализацията в контекста на Spark/UDF?

154

Как различаваш техническите и бизнес проверките на данните, и кой трябва да поставя изискванията към тях?

153

Кои физически стратегии за изпълнение на join знаете?

152
/2