1. You would like to set up an alerting policy to catch whether the processed data is still fresh in a streaming pipeline. Which metrics can be used to monitor whether the processed data is still fresh?job/system_lagjob/is_failedjob/data_watermark_agejob/per_stage_data_watermark_age✅ Correct metrics for monitoring data freshness✔ job/data_watermark_age✔ job/per_stage_data_watermark_ageWhy … Continue Reading…
19. Is it possible to mix elements in sSchema PCollections inside a single Beam pipeline? (Select the two correct answers.)Not possible within the same PCollectionYes, but only across different PCollectionsNot at allYes, in all scenariosCorrect answers (select TWO): ✅✔ Yes, but only across different PCollections✔ … Continue Reading…
1. What is the Beam portability framework?A set of protocols for executing pipelinesA set of cross-language transformsA language-agnostic way to represent pipelinesA hermetic worker environment✅ Correct answer (only these apply):✔ A set of protocols for executing pipelines✔ A language-agnostic way to represent pipelines❌ These do … Continue Reading…
1. What is the difference between AI and ML?- AI concentrates on algorithms while ML is about theory- AI is ML but without mathematics- AI is a discipline while ML is a toolset- AI and ML are the sameCorrect answer: ✅ AI is a discipline … Continue Reading…
1. Google Cloud Pub/Sub provides native support for exactly-once message processing without requiring additional idempotent logic in the subscriber application.- True- FalseCorrect answer: ❌ FalseExplanation (PDE exam–accurate)Google Cloud Pub/Sub does not provide native end-to-end exactly-once message processing for subscribers.Pub/Sub guarantees at-least-once deliveryA message can be … Continue Reading…
1. Your teammate suggests using a custom Python User-Defined Function (UDF) in a Spark batch job to validate data. Why is this pattern strongly warned against?Python UDFs only work in streaming pipelines, not batch pipelines.Python UDFs are very slow because they force Spark to move … Continue Reading…
1. A company’s daily data volume triples during peak sales events, causing the existing pipeline with fixed resource allocations to fail. What is the primary batch data pipeline challenge that this company is facing?- Data Volume and Scalability- Complexity and Maintainability- Reliability and Observability- Data … Continue Reading…
1. To comply with data privacy regulations, Cymbal E-commerce uses Sensitive Data Protection to manage PII. What are the three core functions of this process?- Ingestion, Transformation, and Loading.- Auditing, Alerting, and Reporting.- Discovery, Classification, and Protection.- Authentication, Authorization, and Accounting.✅ Correct AnswerDiscovery, Classification, and … Continue Reading…
1. Which Google Cloud service is recommended as the primary, cost-effective object storage for a data lakehouse, capable of handling structured, semi-structured, and unstructured data?- Apache Iceberg- Cloud Storage- BigQuery- AlloyDB✅ Correct Answer: Cloud Storage🧠 Why this is the exam-correct answerCloud Storage is the primary … Continue Reading…
1. Which Google Cloud service is best suited for building complex data pipelines with a visual, drag-and-drop interface?- Dataprep- Dataflow- Data Fusion- Dataproc✅ Correct Answer: Data Fusion🧠 Why this is the exam-correct answerCloud Data Fusion is the only Google Cloud service in this list that … Continue Reading…