Quick Answer
The answer is Cloud Dataflow because it uniquely combines exactly-once processing semantics with unified batch and streaming capabilities essential for historical backtesting. Dataflow achieves exactly-once processing through its distributed snapshot mechanism, rooted in Google’s MillWheel research, which ensures that every event is processed precisely once even during failures or replays. For backtesting, the same pipeline code can run in batch mode over historical data, guaranteeing consistency between real-time and reprocessed results. On the Google Professional Data Engineer exam, this question tests your understanding of Dataflow’s core differentiator: its ability to handle both streaming and batch under one model, unlike services like Pub/Sub (at-least-once) or BigQuery (primarily analytical). A common trap is choosing Cloud Pub/Sub for exactly-once, but Pub/Sub only guarantees at-least-once delivery; Dataflow’s snapshots enforce the exactly-once contract. Memory tip: think “Dataflow does it once—in real time and in the past.”
This PDE practice question tests your understanding of designing data processing systems. Read the scenario carefully and evaluate each option against the stated constraints before committing to an answer. After answering, compare your reasoning against the explanation and wrong-answer breakdown below. Once you have made your selection, read the full explanation to reinforce the concept and understand why each distractor is designed to mislead on exam day.
A financial company processes transactions in real-time and requires exactly-once processing semantics. They also need to reprocess historical data for backtesting. Which Google Cloud service should they use?
Cloud Pub/Sub
Why wrong: No processing capability.
Cloud Functions
Why wrong: Not for large-scale streaming.
Cloud Dataproc
Why wrong: Not designed for exactly-once streaming.
Cloud Dataflow
Supports exactly-once and batch/streaming.
Answer choices
Answer the question above first, then reveal the full breakdown to understand why each option is right or wrong.
Correct answer & explanation
Cloud Dataflow
Cloud Dataflow (D) is correct because it provides exactly-once processing semantics via its distributed snapshot mechanism (based on the MillWheel paper) and supports both real-time streaming and batch processing for historical backtesting under a unified programming model. This allows the company to reprocess historical data using the same pipeline code, ensuring consistency across real-time and batch modes.
Key principle: Answer the scenario, not the keyword: identify the specific constraint before choosing the most familiar-sounding option.
Answer analysis
For each option: why learners choose it and why it is or isn't the right answer here.
Cloud Pub/Sub
Why it's wrong here
No processing capability.
Cloud Functions
Why it's wrong here
Not for large-scale streaming.
Cloud Dataproc
Why it's wrong here
Not designed for exactly-once streaming.
Cloud Dataflow
Why this is correct
Supports exactly-once and batch/streaming.
Related concept
Read the scenario before looking for a memorised answer.
Common exam traps
Google Cloud often tests the misconception that Cloud Pub/Sub (A) provides exactly-once delivery, but in reality it offers at-least-once delivery, and candidates overlook Dataflow's unified batch/streaming model for reprocessing historical data.
Detailed technical explanation
Under the hood, Cloud Dataflow uses a consistent snapshot algorithm (similar to Chandy-Lamport) to capture pipeline state and progress, enabling exactly-once processing even in the presence of failures. For backtesting, Dataflow can read from bounded sources (e.g., Cloud Storage) using the same windowing and triggering logic as streaming, allowing seamless reprocessing of historical data without code changes. A real-world scenario is a financial firm using Dataflow to aggregate stock trades in real-time and then rerun the same pipeline over last year's data for model validation.
Key takeaway
Answer the scenario, not the keyword: identify the specific constraint before choosing the most familiar-sounding option.
Real-world example
A cloud solutions architect for a retail company is evaluating services for a new workload. The correct answer here reflects best practice for the specific scenario described — not a general cloud recommendation. Answer the scenario, not the keyword: identify the specific constraint before choosing the most familiar-sounding option. Cloud exam questions reward reading the constraint carefully: the same technology can be right or wrong depending on the use case.
What to study next
Identify which exam domain this question belongs to, review the core concept, then practise similar questions from the same domain.
Designing data processing systems — study guide chapter
Learn the concepts, then practise the questions
Designing data processing systems practice questions
Targeted practice on this topic area only
All PDE questions
499 questions across all exam domains
Google Professional Data Engineer study guide
Full concept coverage aligned to exam objectives
PDE practice test guide
How to use practice tests most effectively before exam day
Related practice questions
Use these pages to review the topic behind this question. This is how one missed question becomes focused revision.
Practise PDE questions linked to Designing data processing systems.
Practise PDE questions linked to Building and operationalizing data processing systems.
Practise PDE questions linked to Operationalizing machine learning models.
Practise PDE questions linked to Ensuring solution quality.
Practise PDE questions linked to PDE fundamentals.
Practise PDE questions linked to PDE scenario.
Practise PDE questions linked to PDE troubleshooting.
Practice this exam
Short sessions build daily habit. Longer sessions build exam-day stamina. Try a timed session to simulate real conditions.
FAQ
Designing data processing systems — This question tests Designing data processing systems — Read the scenario before looking for a memorised answer..
The correct answer is: Cloud Dataflow — Cloud Dataflow (D) is correct because it provides exactly-once processing semantics via its distributed snapshot mechanism (based on the MillWheel paper) and supports both real-time streaming and batch processing for historical backtesting under a unified programming model. This allows the company to reprocess historical data using the same pipeline code, ensuring consistency across real-time and batch modes.
Identify which exam domain this question belongs to, review the core concept, then practise similar questions from the same domain.
Read the scenario before looking for a memorised answer.
About these practice questions
Courseiva creates original exam-style practice questions with explanations and wrong-answer analysis. It does not publish real exam questions, exam dumps, or protected exam content. Learn why practice questions differ from exam dumps →
Last reviewed: Jun 30, 2026
This PDE practice question is part of Courseiva's free Google Cloud certification practice question bank. Courseiva provides original exam-style practice questions with explanations, topic-based practice, mock exams, readiness tracking, and study analytics to help learners prepare for the PDE exam.
Question Discussion
Share a tip, memory trick, or ask about the reasoning behind this question. Do not post real exam questions, leaked content, braindumps, or copyrighted exam material. Comments are moderated and may be removed without notice.
Sign in to join the discussion.