professional-cloud-data-engineer
Prepare and test your skills
Prepare and test your skills
A process flow showing an analyst's standard SQL query executed by the BigQuery Omni engine inside AWS or Azure over BigLake tables on Amazon S3 or Azure Blob Storage, branching into three query patterns — cross-cloud joins, cross-cloud materialized views, and cross-cloud transfer — with results delivered into BigQuery without raw-data egress.
Apache Beam on Cloud Dataflow operates as a serverless runner for unified batch and streaming pipelines, allowing transformation code to run on alternative engines such as Apache Flink or Apache Spark without refactoring. Apache Spark on Cloud Dataproc provides managed cluster infrastructure that runs batch and distributed processing workloads written in Python, Scala, Java, or R to lift existing on-premises jobs into Google Cloud.
BigQuery Omni runs the BigQuery query engine directly inside external cloud environments to execute queries over BigLake tables mapped to Amazon S3 or Azure Blob Storage. It authenticates using the native identity and access management (IAM) mechanisms of the host cloud and processes queries in place, avoiding raw file transfers across network boundaries.
The resource locations organization policy constraint allows administrators to define allowed or denied Google Cloud regions across all supported services in a resource hierarchy. This prevents cloud resources from being deployed in unauthorized geographic locations, though it does not automatically relocate existing infrastructure.
BigQuery Omni provides cross-cloud joins for ad-hoc federated queries between Google Cloud and external clouds, cross-cloud materialized views for incrementally replicating pre-aggregated results to local dashboards, and cross-cloud transfer for executing queries remotely and writing the full dataset permanently into BigQuery storage.
Data residency requires organizations to store, process, and encrypt personally identifiable information (PII) within designated geographic boundaries to comply with local laws. Administrators configure physical placement by selecting specific regions when creating managed database instances such as Cloud SQL, AlloyDB, Cloud Spanner, Cloud Bigtable, and Cloud Firestore. For analytical workloads, BigQuery supports both regional and multi-region dataset configurations to keep stored data strictly within authorized boundaries. In Cloud SQL, cross-region read replicas allow teams to distribute read access to designated target regions while satisfying strict regional locality rules.
Customer-Managed Encryption Keys (CMEK) managed through Cloud Key Management Service (Cloud KMS) enforce data sovereignty by giving organizations full control over where cryptographic keys are generated and stored. Regional service endpoints ensure that both data-at-rest and data-in-transit remain restricted to a defined physical location during client-to-service communication. Selecting explicit regions for storage services guarantees that Google stores customer data at rest only within those chosen boundaries according to service-specific terms.
Exam tip: Resource locations organization policy constraints restrict the physical regions where users can create new supported resources, but they do not automatically relocate existing infrastructure.
Organization policy constraints provide centralized control to prevent cloud resources from being deployed in unauthorized geographic locations. The resource locations constraint allows administrators to define allowed or denied Google Cloud regions across all supported services in a resource hierarchy. Beyond resource deployment rules, administrators enforce data residency by managing the network locations authorized to access data and auditing administrator access. Google Cloud platforms also maintain compliance with major international standards, including ISO/IEC 27001, ISO/IEC 27017, ISO/IEC 27018, SOC 1, FISC (Japan), and FedRAMP.
Open-source data processing frameworks separate data transformation logic from the underlying execution infrastructure to eliminate vendor lock-in. Apache Beam provides an open-source standard for defining unified batch and streaming data processing pipelines using software development kits (SDKs). Running Apache Beam pipelines on Cloud Dataflow provides a fully managed, serverless execution platform that scales resources automatically. Because Apache Beam pipelines decouple code from the underlying engine, the same transformation code can run on alternative runners such as Apache Flink or Apache Spark across hybrid or multi-cloud environments without code refactoring.
Cloud Dataflow integrates with storage and analytical services through built-in Beam I/O connectors. Pipelines ingest raw data from Cloud Storage buckets, execute parallel processing operations in memory, and write output records directly to BigQuery tables. This architecture allows organizations to build portable processing logic while pinning the underlying storage systems to specific geographic locations to satisfy data residency requirements.
Cloud Dataproc provides a managed environment for running open-source Apache Spark and Apache Hadoop clusters on Google Cloud infrastructure. Data engineers write transformation pipelines in Python, Scala, Java, or R, allowing existing on-premises processing jobs to move into the cloud without rewriting code. Cloud Dataproc uses specialized open-source connectors to bridge open processing engines with managed Google Cloud storage layers:
The table below highlights how Apache Beam on Cloud Dataflow and Apache Spark on Cloud Dataproc differ across key operational and portability dimensions:
| Framework and Service | Execution Model | Supported Languages | Portability Target |
|---|---|---|---|
| Apache Beam on Cloud Dataflow | Serverless runner for unified batch and streaming pipelines | Beam SDKs (e.g., Python, Java) | Apache Flink, Apache Spark, and Cloud Dataflow runners |
| Apache Spark on Cloud Dataproc | Managed cluster infrastructure for batch and distributed processing | Python, Scala, Java, and R | On-premises Hadoop/Spark clusters, Dataproc, and multi-cloud Spark runtimes |
Multi-cloud data processing allows organizations to analyze datasets stored across different cloud providers without moving the raw files across network boundaries. BigQuery Omni extends the BigQuery query engine to run directly inside Amazon Web Services (AWS) and Microsoft Azure environments. By defining a BigLake table over external data stored in Amazon S3 or Azure Blob Storage, analysts execute standard SQL queries on external data as if it were local to Google Cloud. BigQuery Omni authenticates using the native identity and access management (IAM) mechanisms of the host cloud, avoiding stored access keys while eliminating costly outbound data transfer (egress) charges.
To support varying analytical requirements, BigQuery Omni provides three distinct mechanisms for querying and replicating external data across cloud environments:
Comprehensive multi-cloud pipelines use Cloud Pub/Sub or Cloud Storage as handoff points for cross-cloud data ingestion. Workflows orchestrate extraction and transformation tasks using Cloud Data Fusion or Cloud Dataflow to move processed data into destination warehouses. When private, high-capacity hybrid connectivity is required, Cross-Cloud Interconnect provides dedicated physical links between Google Cloud and other cloud providers, with optional Media Access Control Security (MACsec) encryption protecting data in transit. Engineers use the Cloud Location Finder API to verify regional cloud footprints and confirm that external and internal storage locations satisfy organizational data residency policies.
A global enterprise is designing an event-driven data processing pipeline to ingest high-throughput telemetry streams from Apache Kafka, apply windowed aggregations, and perform machine learning inference before sinking the results into analytical storage.
The enterprise has strict data portability and multi-cloud governance policies requiring that:
Which framework and architecture should the organization implement?