Cohort 4Register

Free · Interview Prep

DE 100: data engineering interview questions

110 questions from interviews at MAANG and top product-based companies, in 8 categories. Each one has a line or two on how to approach it. Interview Prep has the full answers: a PrepNPlaced model answer for each of the 75 theory and design questions, and a STAR outline for each of the 10 behavioural ones. 25 of the coding questions are ready to solve in Coding Practice.

A company is shown where the sheet names one. 42 rows say Multiple Companies on the sheet, so they name no single company. The answers are PrepNPlaced's own, not any company's.

  1. Q1

    Write a SQL query to find the time period when the most people were online, measured in seconds.

    MediumCodingAmazon

    Turn each session into a +1 event at login and a -1 event at logout, take a running SUM over the events in time order, and report the second or interval where that running count peaks.

    Solve it in Coding Practice: When the most people were online

  2. Q2

    Given a large table with 3 columns (datetime, employee, customer_response), find the top 10 employees with the most phone numbers found in the customer_response column.

    HardCodingAmazon

    Pull the phone numbers out of the free text with a regular expression, count the matches per employee, and keep the top 10 with ORDER BY and LIMIT, stating how ties break.

    Solve it in Coding Practice: Employees whose call notes hold the most phone numbers

  3. Q3

    Calculate first day retention rate - players who log in the 2nd day immediately after first login.

    MediumCodingAmazon

    Find each player's first login date with MIN, join the logins on the day right after it, and divide the players who came back that day by all players.

    Solve it in Coding Practice: First-day retention of new players

  4. Q4

    Write a SQL query to get total revenue generated by each subscriber in the year 2014.

    MediumCodingAmazon

    Filter the orders to 2014 with a date range on the raw column, join them to the subscribers, and SUM the revenue per subscriber with GROUP BY.

    Solve it in Coding Practice: Revenue per subscriber in 2014

  5. Q5

    Calculate the median number of searches a person made last year using summary table.

    HardCodingGoogle

    The summary table pairs each search count with how many people made it, so take a running SUM of those people and pick the count where the running share crosses one half.

    Solve it in Coding Practice: Median searches per person from a summary table

  6. Q6

    Calculate the sum of odd-numbered and even-numbered measurements separately for a particular day.

    MediumCodingGoogle

    Number the day's measurements in time order with ROW_NUMBER, then SUM with CASE WHEN on whether the row number is odd or even, both totals in one pass.

    Solve it in Coding Practice: Odd and even measurement sums per day

  7. Q7

    Write a SQL query that returns the 2nd-highest salary in the engineering department.

    EasyCodingNetflix

    Rank the department's salaries with DENSE_RANK in descending order and keep rank 2, so a tie at the top does not hide the answer; return NULL when there is no second salary.

    Solve it in Coding Practice: Second-highest salary in Engineering

  8. Q8

    Write a query to find customers who placed more than three orders in the past year.

    MediumCodingMicrosoft

    Filter the orders to the last twelve months, GROUP BY customer, and keep the groups with HAVING COUNT(*) > 3.

    Solve it in Coding Practice: Customers with more than three orders in the past year

  9. Q9

    Write SQL query to find ranks of employee salaries, ordered by department.

    MediumCodingMicrosoft

    Use RANK or DENSE_RANK OVER (PARTITION BY department ORDER BY salary DESC), and say which one you chose and how it treats ties.

    Solve it in Coding Practice: Salary ranks within each department

  10. Q10

    Write a query to return all neighborhoods that have 0 users (LEFT JOIN with IS NULL).

    MediumCodingMicrosoft

    LEFT JOIN neighborhoods to users and keep the rows where the user key IS NULL; NOT EXISTS expresses the same anti join.

    Solve it in Coding Practice: Territories with no employees

  11. Q11

    Calculate average vacant days across AirBnbs in 2021 for active properties only.

    HardCodingAirbnb

    For each active listing, count the days of 2021 not covered by a booking, clipping bookings to the year, then average those days across the listings.

    Solve it in Coding Practice: Average vacant days in 2021 for active listings

  12. Q12

    Get average rating of each Airbnb property listing per month.

    MediumCodingAirbnb

    Truncate the review date to its month, then AVG the rating grouped by listing and month.

    Solve it in Coding Practice: Average rating per listing per month

  13. Q13

    Find top 10 listings with most bookings by joining hosts and bookings tables.

    MediumCodingAirbnb

    Join bookings to listings and hosts, COUNT the bookings per listing, ORDER BY that count descending and LIMIT 10, with a rule for ties.

    Solve it in Coding Practice: Top 10 listings by bookings, with their host

  14. Q14

    Write a query to get list of customers with their last purchase details.

    MediumCodingGoogle

    Number each customer's purchases with ROW_NUMBER OVER (PARTITION BY customer ORDER BY purchase time DESC) and keep row 1, which returns the whole purchase row.

    Solve it in Coding Practice: Each customer's last purchase

  15. Q15

    How do you optimize a slow SQL query? Explain query tuning process.

    HardTheoryGoogle

    Measure first: read the execution plan to find the costliest step, then read less data, help the engine find rows, fix joins and statistics, and check the result is unchanged.

  1. Q16

    Write a function to find non duplicate numbers preserving order: [1,1,3,2,5,6,5] → [1,3,2,5,6]

    MediumCodingAmazon

    Walk the list once with a set of values already seen and keep each value the first time it appears; list(dict.fromkeys(items)) does the same in one line.

    Solve it in Coding Practice: Remove duplicates, keep the order

  2. Q17

    Given a json object with nested objects, write a function that flattens all objects to single key-value dictionary.

    HardCodingAmazon

    Recurse through the object, joining parent and child keys with a separator such as a dot, and decide up front how lists are handled.

    Solve it in Coding Practice: Flatten a nested JSON object

  3. Q18

    Write code to find maximum combinations of infinite coins {1,2,5} that add up to 20 rupees.

    HardCodingAmazon

    Count with dynamic programming: ways[0] = 1, then for each coin add ways[amount - coin] to ways[amount] up to the target; looping over the coins first counts combinations, not orderings.

    Solve it in Coding Practice: Ways to make an amount from coins

  4. Q19

    Extract unique values from a dictionary where values occur only once.

    MediumCodingUber

    Count the values with collections.Counter and keep those whose count is 1, in the order they first appear.

    Solve it in Coding Practice: Dictionary values that occur only once

  5. Q20

    What's the difference between list, tuple, and set in Python for data pipelines?

    EasyTheory

    A list for ordered batches you append to, a tuple for fixed records and composite keys, a set for fast membership checks and de-duplication; at millions of rows, move to pandas, Arrow or Spark.

  6. Q21

    Explain Python modules used in data engineering: Pandas, NumPy, Requests, SQLAlchemy.

    EasyTheoryGoogle

    NumPy for fast arrays, pandas for tabular cleaning and joins, Requests for API calls with timeouts and retries, SQLAlchemy for pooled, parameterized database access; show how they combine in one small pipeline.

  7. Q22

    How would you optimize a data pipeline written in Python using vectorized operations?

    MediumTheory

    Profile to find the slow loop, replace row logic with column operations such as np.where, .str, .dt, merge and groupby().transform, use compact types, and check the output is unchanged.

  8. Q23

    Write Python code to rank hosts based on number of beds using pandas groupby.

    MediumCodingAirbnb

    Total the beds per host with groupby("host_id")["beds"].sum(), then rank with rank(method="dense", ascending=False) or a sort, and state how ties rank.

    Solve it in Coding Practice: Rank hosts by their number of beds

  9. Q24

    What are generators in Python and how are they useful in large data processing?

    MediumTheoryNetflix

    A generator yields one value at a time, so memory stays flat however large the input; chain generators into lazy pipelines, and remember each can be consumed only once.

  10. Q25

    How do you handle large CSV files that don't fit in memory using Python?

    MediumTheorySpotify

    Never load it whole: stream the rows, read with chunksize, load only the columns and types you need, convert it once to Parquet, or use DuckDB, Polars or Spark.

  11. Q26

    Explain the Global Interpreter Lock (GIL) and its impact on data processing.

    HardTheory

    The GIL lets one thread run Python bytecode at a time, so threads help I/O-bound work but not CPU-bound Python; use processes, vectorized libraries or Spark for heavy computation.

  12. Q27

    Write a Python class for a data pipeline with error handling and logging.

    HardCodingStripe

    Give the class extract, transform and load methods and a run method that calls them in order, log each step, catch specific exceptions with context, and re-raise failures so the caller sees them.

    Solve it in Coding Practice: A pipeline class with error handling and logging

  13. Q28

    How do you implement multithreading vs multiprocessing for data processing in Python?

    HardTheoryUber

    Threads for I/O-bound work, processes for CPU-bound Python, both through concurrent.futures; send small inputs to processes, bound the workers and handle failures per task.

  14. Q29

    Write code to detect longest patterns in song plays from user listening data.

    HardCodingSpotify

    Sort each user's plays by time and walk them, counting consecutive plays of the same song and keeping the longest run; in SQL it is the gaps and islands pattern.

    Solve it in Coding Practice: Longest repeat streak in song plays

  15. Q30

    How do you handle missing data and data cleaning in pandas efficiently?

    MediumTheoryMeta

    Measure the missing values per column and agree what missing means, then drop, fill or flag column by column; coerce types explicitly, remove duplicates and validate before writing.

  1. Q31

    Design a relational database schema for a ride-sharing app like Uber.

    HardDesignAmazon

    Model riders, drivers, vehicles, rides, ride events, payments and ratings, treat the ride status as a state machine, keep location pings out of the core tables, and analyse a warehouse copy.

  2. Q32

    Design a database schema for an e-commerce platform with products, orders, and customers.

    MediumDesignAmazon

    Normalize customers, addresses, products, prices, orders, order lines, payments and shipments; copy the unit price onto each order line, store money as DECIMAL, and build a star schema for analytics.

  3. Q33

    Present a design of a gaming company database with players, games, and achievements.

    MediumDesignMeta

    Players, games and achievements, with link tables from players to games and from players to achievements; derive leaderboards, partition sessions by date, and model facts for sessions and unlocks.

  4. Q34

    Design a fact table for retail sales database with appropriate measures and dimensions.

    MediumDesign

    Fix the grain first, one row per transaction line, then add the dimension keys, the degenerate keys and additive measures; store the parts of a ratio, not the ratio, and partition by date.

  5. Q35

    Explain difference between Star Schema and Snowflake Schema with examples.

    MediumTheory

    Both put a fact table in the centre; a star keeps each dimension as one denormalized table, a snowflake normalizes dimensions into related tables, trading fewer joins against less redundancy.

  6. Q36

    Design a dimension table for customer entity with at least five attributes.

    EasyDesign

    A surrogate key, the natural key, descriptive and geographic attributes, SCD Type 2 columns for history, audit columns, and an unknown member so no fact is dropped.

  7. Q37

    How do you handle slowly changing dimensions (SCDs) Type 1, 2, and 3?

    HardTheoryMicrosoft

    Type 1 overwrites, Type 2 adds a row with validity dates and a new surrogate key, Type 3 adds a column for the previous value; choose per attribute and test late and same-day changes.

  8. Q38

    Design a schema to keep track of customer address changes over time.

    MediumDesignAmazon

    Keep an address history table with valid_from and valid_to, one current row per customer and address type, no overlapping periods, and orders that copy the address they used.

  9. Q39

    What are factless fact tables and when would you use them?

    MediumTheory

    A fact table with dimension keys and no measures, counted rather than summed: event tables for attendance or logins, coverage tables for finding what did not happen.

  10. Q40

    Explain normalization vs denormalization trade-offs in data modeling.

    MediumTheoryGoogle

    Normalization stores each fact once for safe, fast writes in OLTP; denormalization repeats data for simple, fast reads in analytics, built from the normalized source.

  11. Q41

    Design a data model for tracking user behavior on a streaming platform like Netflix.

    HardDesignNetflix

    Land raw client events, build playback session, impression, search and rating facts with profile, content and device dimensions, and handle late events, retries and privacy.

  12. Q42

    How do you model many-to-many relationships in dimensional modeling?

    MediumTheory

    Put a bridge table between the fact and the dimension, with a weighting factor or group keys, so totals are not counted twice.

  13. Q43

    Design ERD for a social media platform with users, posts, and interactions.

    HardDesignMeta

    Users, follows, posts, media, likes, comments, hashtags, mentions and notifications, with keys that block duplicates, soft deletes, counters updated in the background and a precomputed feed.

  14. Q44

    What is dimensional modeling according to Ralph Kimball methodology?

    MediumTheory

    Choose the business process, declare the grain, identify the dimensions, then identify the facts; around them sit conformed dimensions, the bus matrix, surrogate keys and SCDs.

  15. Q45

    Design a data model for IoT sensor data with time-series considerations.

    HardDesign

    Separate device and sensor reference data from narrow, append-only readings partitioned by time; store event time and ingest time, downsample, compress, and flag gaps instead of inventing values.

  1. Q46

    Design an end-to-end ETL pipeline that ingests payment data into analytics warehouse.

    HardDesignStripe

    Change data capture and settlement files into an immutable raw zone, staged and modelled payment facts, reconciliation with the provider, idempotent MERGE loads, quality gates and tight security.

  2. Q47

    How would you design a data pipeline for ingesting data with increasing volume?

    MediumDesignAmazon

    Buffer the ingestion, partition on an even key, process incrementally and idempotently, use scalable table formats and elastic compute, and alert on growth before it hits a limit.

  3. Q48

    Design data pipeline for hourly user analytics with batch and streaming options.

    HardDesignUber

    Land the events once, then offer an hourly batch job that overwrites its partition and a streaming job with event-time windows and watermarks; in a hybrid, batch corrects the stream.

  4. Q49

    How do you handle data quality issues and validation in data pipelines?

    MediumTheoryNetflix

    Test completeness, uniqueness, validity, consistency and timeliness at ingestion, after transforms and before publishing; quarantine bad records, block bad publishes and fix causes upstream.

  5. Q50

    How would you manage incremental data loads in a data warehouse?

    MediumTheory

    Detect changes with CDC, a watermark or an increasing id, advance the watermark only after the commit, MERGE idempotently, expect late data and validate every run.

  6. Q51

    When should you consider streaming over batch processing?

    MediumTheoryNetflix

    Stream when data loses its value within seconds and something will act on it, as in fraud checks or alerts; batch is simpler and cheaper for hourly or daily consumers.

  7. Q52

    Explain the key stages in ETL process: Extract, Transform, Load.

    EasyTheory

    Extract with little load on the source, transform by cleaning, validating, conforming and modelling, load idempotently with bulk operations, and check counts and totals.

  8. Q53

    How do you implement error handling and recovery mechanisms in ETL processes?

    MediumTheory

    Classify errors: retry the transient ones, quarantine bad records, stop on fatal ones; make steps idempotent, checkpoint progress, keep the raw data and write runbooks.

  9. Q54

    What are the differences between ETL and ELT approaches?

    MediumTheory

    ETL transforms on a separate engine before loading; ELT loads raw data first and transforms it inside the warehouse; compare compute, flexibility, privacy and cost.

  10. Q55

    How do you handle schema changes in source systems during ETL?

    MediumTheoryMicrosoft

    Check the schema on every run, handle each kind of change (new, removed, renamed, retyped, changed meaning) on its own terms, and keep a raw layer and explicit column lists.

  11. Q56

    Design a real-time data pipeline to process payment transactions and update accounts.

    HardDesignStripe

    An idempotent payment write with an outbox to Kafka partitioned by account, a double-entry ledger that skips redelivered events, dead letter handling and daily reconciliation.

  12. Q57

    How do you optimize slow-running ETL jobs for better performance?

    MediumTheoryAmazon

    Find the bottleneck first, then process less data, use columnar formats, push work to the data, fix joins and parallelism, and replace row-by-row logic.

  13. Q58

    How do you implement data lineage tracking in ETL pipelines?

    HardTheory

    Capture lineage at run time with OpenLineage, from SQL with dbt or a parser, and from the platform; record datasets, jobs and versions, and use lineage in change reviews and alerts.

  14. Q59

    Design ETL process to collect and process tickets in real-time manner.

    HardDesignAmazon

    Collect ticket events into a stream, process them with validation, enrichment, routing and service level timers, then serve agent dashboards, alerts and warehouse facts.

  15. Q60

    How do you handle late-arriving data in streaming ETL pipelines?

    HardTheoryNetflix

    Process by event time with watermarks, choose the lateness bound from measured delays, emit updated results, capture events that are too late, and let batch correct the numbers.

  1. Q61

    Design a scalable data processing system for Netflix's recommendation engine.

    HardDesignNetflix

    An offline layer trains candidate and ranking models from the lake, a feature store keeps features the same in training and serving, and an online service ranks precomputed candidates with fresh context.

  2. Q62

    Design a system similar to BookMyShow handling concurrency and fault tolerance.

    HardDesignUber

    Hold seats with one atomic conditional update and an expiry, take payment with an idempotency key, confirm in one transaction, and reconcile payments with bookings when something fails.

  3. Q63

    Design a data warehouse to capture and analyze sales data.

    MediumDesignAmazon

    Gather the business questions, land the sources incrementally, build a Kimball star schema on conformed dimensions, add tests and metric definitions, and start with one business process.

  4. Q64

    Design a real-time analytics platform for a ride-sharing company like Uber.

    HardDesignUber

    Stream ride and location events through Kafka into per-zone, per-minute windows, serve them from a real-time OLAP store, and keep every event in the lake for batch correction.

  5. Q65

    Design distributed storage system for petabyte-scale data.

    HardDesignGoogle

    Split files into large blocks, replicate or erasure-code them across racks, run a replicated metadata service, place data with consistent hashing, and add a table format for ACID tables.

  6. Q66

    Design monitoring and alerting system for data pipelines.

    MediumDesign

    Monitor job health, freshness, data quality, streaming lag and cost, and route each alert with its impact, links and a runbook to the owning team, without alert fatigue.

  7. Q67

    Design data lake architecture for storing multi-structured data.

    HardDesignAmazon

    Raw, cleaned and curated zones on object storage with a table format, a catalogue entry for every unstructured file, and governance, compute and operations across the zones.

  8. Q68

    Design API for high-frequency trading data with low latency requirements.

    HardDesign

    Two paths: a push-based binary feed with sequence numbers and in-memory order books for trading systems, and a historical query API over a time-series store for analysts.

  9. Q69

    Design caching strategy for frequently accessed data in distributed system.

    MediumDesign

    Cache data that is read often and changes rarely, usually cache-aside with TTLs; invalidate on writes, and plan for stampedes, missing keys, hot keys and cache outages.

  10. Q70

    Design backup and disaster recovery strategy for critical data systems.

    MediumDesign

    Agree RPO and RTO per system, follow the 3-2-1 backup rule with point-in-time recovery, choose a recovery architecture by cost, and test restores regularly.

  11. Q71

    Design A/B testing platform for data-driven product decisions.

    HardDesignMeta

    Configure experiments, assign users by deterministic hashing, log exposures, compute metrics in one shared pipeline, and use sound statistics with guardrails and a sample ratio check.

  12. Q72

    Design real-time fraud detection system for payment processing.

    HardDesignStripe

    Score each payment synchronously from real-time and batch features, combine rules with a model and thresholds, learn from chargebacks, and fall back to rules on a timeout.

  13. Q73

    Design data platform for processing IoT sensor data at scale.

    HardDesign

    Devices publish over MQTT to a gateway and a stream, stream processing validates and alerts, and storage splits hot time-series data from the lake and long-term rollups.

  14. Q74

    Design search and recommendation system for e-commerce platform.

    HardDesignAmazon

    Search retrieves keyword and vector candidates and ranks them with learning to rank; recommendations precompute candidates in batch and rank them at request time.

  15. Q75

    Design data governance framework for enterprise data management.

    MediumDesign

    Set out roles, policies, processes, tools and measures, start with the most critical domains, and make data easier to find and trust, not only harder to reach.

  1. Q76

    What is PySpark and how does it differ from Apache Spark?

    EasyTheory

    Spark is the distributed engine on the JVM and PySpark is its Python API, so keep heavy work in DataFrame operations and built-in functions that run inside the engine.

  2. Q77

    Explain concept of RDD in PySpark and how to create one.

    MediumTheory

    An RDD is an immutable, partitioned collection that rebuilds lost partitions from its lineage; create one with parallelize, textFile or df.rdd, and prefer DataFrames today.

  3. Q78

    What is SparkSession and how do you create one in PySpark?

    EasyTheory

    SparkSession is the single entry point since Spark 2.0: build it with SparkSession.builder and getOrCreate(), and let spark-submit set the master on a cluster.

  4. Q79

    Explain concept of lazy evaluation in PySpark with examples.

    MediumTheory

    Transformations only build a plan and actions run it, which lets Catalyst optimize the whole plan; cache a DataFrame that several actions reuse.

  5. Q80

    What are broadcast variables in PySpark and when to use them?

    MediumTheory

    A broadcast variable ships a read-only value to each executor once; a broadcast join applies the same idea to a small table, as long as it fits in memory.

  6. Q81

    How do you optimize PySpark jobs for better performance?

    HardTheoryNetflix

    Start from the Spark UI and the plan, then read less, prefer built-in functions to Python UDFs, optimize joins and shuffles, handle skew and right-size the resources.

  7. Q82

    What is role of Catalyst optimizer in PySpark?

    MediumTheory

    Catalyst resolves the plan, rewrites it with rules such as predicate pushdown and column pruning, picks a physical plan using size and cost, and generates code; adaptive execution re-plans at run time.

  8. Q83

    Write PySpark code to perform groupBy operation and calculate average of column.

    MediumCoding

    Group and aggregate with df.groupBy("key").agg(F.avg("value")), using built-in functions so the work stays inside the engine.

    Solve it in Coding Practice: Average track length per genre

  9. Q84

    What are UDFs in PySpark? Write example and demonstrate usage.

    MediumCoding

    A UDF wraps a Python function so Spark can apply it to a column: declare it with F.udf and a return type, use it in withColumn, and prefer a built-in or a pandas UDF when one exists.

    Solve it in Coding Practice: A UDF that formats track length

  10. Q85

    Explain difference between DataFrame and RDD in PySpark.

    MediumTheory

    An RDD holds opaque objects transformed by your functions; a DataFrame has a schema that Catalyst and Tungsten optimize, so it is usually much faster in PySpark.

  11. Q86

    Write PySpark code to join two DataFrames and explain different join types.

    MediumCoding

    Call df1.join(df2, on="key", how=...), and explain inner, left, right, full outer, left semi and left anti joins, with a broadcast when one side is small.

    Solve it in Coding Practice: Join artists to albums, keeping every artist

  12. Q87

    What is PySpark Streaming and how to stream data using TCP/IP protocol?

    HardTheory

    Structured Streaming treats a stream as an unbounded table; the socket source is for learning only because it cannot replay data, so production reads from Kafka or files.

  13. Q88

    Explain the architecture of Hadoop and its core components (HDFS, MapReduce, YARN).

    MediumTheoryNetflix

    HDFS stores replicated blocks under a NameNode, YARN allocates the cluster's resources, and MapReduce processes data in map, shuffle and reduce phases.

  14. Q89

    How do you handle data skew in Spark applications?

    HardTheoryUber

    Find the hot keys, then rely on adaptive skew handling, broadcast the small side, separate null keys, salt the hot keys or process them on their own path.

  15. Q90

    Write PySpark code to perform window functions for calculating running totals.

    HardCoding

    Define a window partitioned by customer, ordered by date, with a ROWS frame from unbounded preceding to the current row, and take F.sum("amount").over(window).

    Solve it in Coding Practice: Running total of each customer's spend

  1. Q91

    What are OLTP vs OLAP systems and their impact on database design?

    MediumTheory

    OLTP runs many small, consistent transactions on normalized row stores; OLAP runs large scans on denormalized, columnar models; keep them apart and move data with ETL or ELT.

  2. Q92

    What is materialized view in BigQuery and when to use it?

    MediumTheoryGoogle

    A stored query result that BigQuery refreshes automatically and incrementally; use it for repeated aggregations that must stay fresh, after checking its SQL limits.

  3. Q93

    Explain concept of data lake vs data warehouse differences.

    MediumTheory

    A warehouse holds modelled data with schema on write for BI; a lake holds raw data of any type with schema on read; a lakehouse adds table formats to the lake.

  4. Q94

    What are components of data warehouse architecture (staging, integration, access)?

    MediumTheory

    Staging lands raw copies, integration cleans, conforms and keeps history as the single source of truth, and access shapes marts and metric definitions for the people who use them.

  5. Q95

    How do you handle schema evolution in data warehouse environment?

    MediumTheoryMicrosoft

    Prefer additive changes, stage breaking ones through a deprecation period, version and review schema changes, agree contracts with sources, and keep raw data for backfills.

  6. Q96

    What are best practices for data warehouse performance optimization?

    MediumTheory

    Model for the queries, read less data through partitioning, clustering and column pruning, write efficient SQL, load incrementally, and tune the slowest queries first.

  7. Q97

    Explain concept of data mart vs data warehouse and when to use each.

    EasyTheory

    A warehouse integrates data for the whole organization; a mart serves one subject or team, best built from the warehouse on conformed dimensions.

  8. Q98

    What are different types of indexes in data warehouse and their use cases?

    MediumTheory

    B-tree indexes for selective lookups, bitmap indexes for low-cardinality columns, sort keys and zone maps for skipping blocks, and Bloom filters for point lookups.

  9. Q99

    How do you implement data retention policies in warehouse environment?

    MediumTheory

    Set retention per class of data with legal and the business, partition by date so expiry drops partitions, automate the enforcement, archive where required and cover every copy.

  10. Q100

    What are partitioning strategies for large tables in data warehouse?

    HardTheory

    Range partitioning by date is the usual choice, with list, hash and composite options when queries need them; avoid very high-cardinality keys and cluster on them instead.

  1. Q101

    Tell me about the most challenging data engineering project you worked on.

    MediumBehavioralAmazon

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: the size and difficulty of the problem, your own part in it, the technical decisions you made, and what you learned.

  2. Q102

    Describe a time you had to optimize a data pipeline for performance. What was your approach?

    MediumBehavioralNetflix

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: a method (measure, find the cause, fix, verify) rather than a lucky guess.

  3. Q103

    How do you prioritize multiple competing data engineering tasks and deadlines?

    MediumBehavioralAmazon

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: judgment about impact and urgency, and clear communication when something has to wait.

  4. Q104

    Tell me about a time you applied judgment to a data decision when complete data was not available.

    MediumBehavioralAmazon

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: sound reasoning under uncertainty, assumptions stated out loud, and a plan to check them.

  5. Q105

    How would you convey complex data insights to non-technical stakeholders?

    MediumBehavioralUber

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: that you lead with the answer, choose plain words and one clear visual, and connect the insight to a decision.

  6. Q106

    Describe a situation where you had to collaborate with cross-functional teams on a data project.

    MediumBehavioralMeta

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: how you align different goals, agree definitions and handle disagreement.

  7. Q107

    Tell me about a time you made a mistake in a data project and how you handled it.

    MediumBehavioralAmazon

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: ownership, speed and honesty in fixing it, and prevention afterwards.

  8. Q108

    How do you stay updated with the latest data engineering technologies and trends?

    EasyBehavioral

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: a real, sustainable habit, and evidence that learning turns into better work.

  9. Q109

    Describe a time you had to learn a new technology quickly for a project.

    MediumBehavioralSpotify

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: a learning plan under time pressure, and delivery.

  10. Q110

    How do you ensure data quality and reliability in your engineering projects?

    MediumBehavioralStripe

    Answer with a STAR story: situation, task, action, result. What the interviewer listens for: concrete practices (tests, monitoring, ownership) shown on a real project.