Niyə bool([""]) True qaytarır?
Data Engineer
Spark-də repartition və coalesce arasındakı fərq nədir?
2024-cü ilin yanvarın 1-i tarixində start_date ilə DAG yaradılarsa nə baş verər?
Vəzifə #3 Müştəriləri tapmaq lazımdır ki, onların sifarişləri arasındakı fərq 60 gündən çoxdur. Bu müştərilər üçün ən böyük fərqi (gap_days) göstərin. Sifarişlər cədvəli: | order_id | customer_id | order_dt | |----------|-------------|------------| | 1 | 1 | [phone] | | 2 | 1 | [phone] | | 3 | 1 | [phone] | | 4 | 1 | [phone] | | 5 | 2 | [phone] | | 6 | 2 | [phone] | | 7 | 3 | [phone] | Nəticə: | customer_id | gap_days | |-------------|----------| | 1 | 123 | | 2 | 120 |
Məlumatların uyğunsuzluğu ilə necə mübarizə aparmaq olar?
Spark-də spill haqqında nə bilirsiniz?
Kodda normal (gözlənilən) paylanmadan əhəmiyyətli dərəcədə fərqlənən dəyəri necə təsvir edərdin?
Məlumatlar niyə itə bilər? Bir neçə səbəb ver.
Python-da kontekst menecerleri ilə işlədinizmi? Bunlar nədir və nə üçün lazımdır?
Əgər düzgün olmayan məlumatlar vitrinə və ya müvəqqəti cədvələ yüklənibsə, onları yuxarı pipeline-lərə necə daxil olmamaq olar?
Airflow-də depends_on_past parametrinin funksiyası nədir?
Airflow tapşırıqları arasında məlumatların ötürülməsi üçün hansı üsulları bilirsiniz?
Əgər DAG-in cədvəli @daily-disə, o həqiqətən nə vaxt başlayır?
Məlumatların keyfiyyətini necə izləyirdiniz?
Python'da sözlük dəyişdirilə bilən və ya dəyişdirilə bilməyən bir növdürmü? Onun açarları və dəyərləri üçün hansı tələblər var?
Statistik yoxlamalar etdinizmi?
Sözlükdə axtarışın ən pis halda algoritmik mürəkkəbliyi nədir?
Birinci DAG uğurla tamamlandıqdan dərhal sonra Airflow-un ikinci DAG-ını necə başlatmaq olar?