Dataford
Interview QuestionsInterview GuidesExperiencesMock InterviewsPricing
Get started

Build Freshness-Safe Visualization Pipeline

Medium
PipelinesIdempotencyBackfillingQuality

Problem

Scenario

You are supporting a dashboarding platform where business users rely on near-real-time visualizations for operational decisions. The underlying source data changes frequently through inserts, updates, and late-arriving corrections, and stakeholders have escalated repeated mismatches between chart values, exported reports, and cached views. You need a pipeline that keeps visualizations accurate without showing partially processed or inconsistent data. The goal is to make every published dataset version traceable, validated, and safe for downstream visual applications.

Current State

ComponentStatus / Technology
Source systemsPostgreSQL OLTP, REST partner APIs
IngestionApache Kafka CDC + scheduled API pulls
ProcessingApache Spark Structured Streaming + dbt incremental models
StorageSnowflake raw, curated, and semantic tables
OrchestrationApache Airflow 2.x
ServingGramener Gramex data APIs feeding dashboards
Scale: ~45M source row changes/day, peak 18K CDC events/sec, partner API refresh every 5 minutes, 15-minute dashboard freshness SLA, up to 3 hours of late-arriving updates, 400 concurrent dashboard viewers.

Question

How would you design or rebuild this pipeline so that frequently changing source data does not make visualizations inconsistent, stale, or partially updated? Explain how you would handle incremental processing, validation, versioning, and publish semantics so that dashboards served through Gramex remain accurate at all times.

You are practicing as a guest. Sign up free to get your answer graded with AI feedback. Your draft stays right here.

Sign up freeI have an account
Sign up to unlock solutions
Next questions
Royal Caribbean GroupDesign Near Real-Time Dashboard PipelineHardAsanaBuild Reliable Dashboard Refresh PipelineHardVLinkReal-Time Dashboard Data PipelineMedium