Why does bool([""]) return True?
Data Engineer
What are the disadvantages of UDFs in Spark and what is their downside?
How to deal with data inconsistency?
Task #3 Find clients with a gap between their orders > 60 days. For these clients, output the maximum gap (gap_days). Orders table: | 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] | Final result: | customer_id | gap_days | |-------------|----------| | 1 | 123 | | 2 | 120 |
What is the difference between repartition and coalesce in Spark?
What do you know about spill in Spark?
How would you describe in code a check that a value significantly differs from a normal (expected) distribution?
Why can data be lost? Provide some reasons.
Have you worked with context managers in Python? What are they and what are they used for?
If incorrect data has been loaded into the showcase or intermediate table, how can you prevent it from entering higher pipelines?
What methods do you know for transferring data between Airflow tasks?
What does the depends_on_past parameter do in Airflow?
How do you monitor data quality?
If the DAG schedule is @daily, what time does it actually run?
Is a dictionary in Python a mutable or immutable type? What are the requirements for its keys and values?
Have you performed statistical checks?
How to run a second Airflow DAG immediately after the first one successfully completes?
What is the algorithmic complexity of searching in a dictionary in the worst case?