Data Engineer
Mely mezőkre osztottad az adatokat a Greenplum-ben?
Milyen adatminőség-ellenőrzéseket végeztek a Data Vault-ban?
Van tapasztalatod a Table Engine Join használatában a ClickHouse-ban?
Hogyan határozza meg a Spark, hogy egy táblázat elég 'kicsi' a broadcast joinhoz (felső határ)?
Milyen sorrendben hajtódnak végre az SQL fő műveletei: SELECT, FROM stb.?
Hogyan lehet adatokat átvinni a feladatok között az Airflow-ban?
Vannak-e olyan funkciók és lehetőségek a Greenplumban, amelyek nem találhatók meg a szokásos MySQL-ben és más dialektusokban?
Mondjon egy példát, amikor sikerült javítani a folyamatokat vagy eszközöket a csapat számára.
A képen látható táblastruktúra létrehozva. Szükséges végrehajtani a képen látható lekérdezést. Milyen típusú join-t kell használni a [...] helyén, hogy az eredményben type = 'table_aw' rekordok esetén a 'naming' oszlop kitöltve legyen, és type = 'table2' rekordok esetén a 'serial_number' oszlop? create table multirelation( type varchar not null, entity_id integer not null ); create table table_aw( id integer primary key, naming varchar not null ); create table table2( id integer primary key, serial_number varchar not null ); -- táblák szerkezete select m.type,m.entity_id, ta.naming, t2.serial_number from multirelation m [...] join table_aw ta on m.entity_id = ta.id and m.type='table_aw' [...] join table2 t2 on m.entity_id = t2.id and m.type='table2'; -- lekérdezés Hagyja üresen inner cross right left
Kik voltak az adatok fogyasztói, és hogyan épültek a vitrinek?
Mi történt és hogyan lehet visszaszerezni a munkát?
Témánk nagyon strukturált, fa-szerű, az adatok nyers — hogyan kezeljük őket?
Mi a különbség a Greenplum és a PostgreSQL között?
Mire számítasz fizetésként?
Logisztikai vállalat jelentése Ön egy logisztikai vállalat elemzője, aki a raktárak műveleteit nyilvántartja. Jelentést kell készítenie minden raktár hatékonyságáról. Minden raktár esetében számolja ki: • a műveletek összes száma (count_operations); • a raktárban feldolgozott termékek összes száma (sum_quantity); • az átlagos feldolgozási idő (avg_processing_time), csak a megadott idővel (nem NULL) rendelkező műveleteket figyelembe véve, a legközelebbi egész számra kerekítve; • a maximális és minimális termékszám, amit egy műveletben feldolgoztak (max_quantity, min_quantity); • az egyes típusú műveletek száma («beszállítás», «kiszállítás», «átvitel») külön oszlopokban: supply_operations, shipment_operations, transfer_operations. Szűrje ki azokat a raktárakat, ahol az összes művelet száma több mint 2, és az átlagos feldolgozási idő nem haladja meg a 60 percet. Rendezze az eredményt a raktár azonosítója szerint növekvő sorrendben. Bemeneti formátum operations tábla: • operation_id (int) — művelet azonosítója • warehouse_id (int) — raktár azonosítója • operation_type (text) — művelet típusa: «beszállítás», «kiszállítás», «átvitel» • quantity (int) — a műveletben lévő termékek száma • operation_date (timestamp) — a művelet dátuma és időpontja • processing_time (int) — a művelet feldolgozási ideje A processing_time oszlop NULL értékeket tartalmazhat. Kimeneti formátum A lekérdezésnek egy olyan táblát kell visszaadnia, amely a következő mezőket tartalmazza a megadott sorrendben: • warehouse_id (int) — raktár egyedi azonosítója • count_operations (int) — a raktárban végrehajtott összes művelet száma • sum_quantity (int) — a raktárban feldolgozott összes termék száma • avg_processing_time (numeric) — a művelet átlagos feldolgozási ideje (percben), csak a nem NULL idővel rendelkező műveleteket figyelembe véve, a legközelebbi egészre kerekítve • max_quantity (int) — egy műveletben feldolgozott maximális termékszám • min_quantity (int) — egy műveletben feldolgozott minimális termékszám • supply_operations (int) — «beszállítás» típusú műveletek száma • shipment_operations (int) — «kiszállítás» típusú műveletek száma • transfer_operations (int) — «átvitel» típusú műveletek száma
Mik a Set és List Pythonban? A teljesítményen kívül milyen más jellemzők vannak?
BALOLDALI CSATLAKOZÁS: 10 rekordot tartalmazó táblázat BALOLDALI CSATLAKOZÁS: 100 rekordot tartalmazó táblázat. Mekkora lehet a minimális és maximális sorok száma?
A megjelenített képernyőn két adatszerkezet van; melyikben lesz gyorsabb a 2 érték keresése és miért?
SELECT client_id, ФИО, SUM(suma) AS total_amount FROM clients JOIN transactions ON clients.client_id = transactions.client_id WHERE дата = '2025-05-01' GROUP BY client_id, ФИО;
Hogyan szervezed általában a feladatokon végzett munkádat, és hogyan követed nyomon a haladást?