44 articles tagged with "Etl"

Keys, windows, watermarks, triggers, and checkpoints for robust stateful stream aggregations in Spark and similar engines.

Serialize DAG runs with max_active_runs and throttle shared-resource tasks with pools, using both for correctness and capacity.

Branch, test, review, merge, and deploy dbt changes with focused commits, CI validation, protected branches, and rollback plans.

Compare Flink, Kafka Streams, Spark, and Beam; test correctness, latency, recovery, and cost before choosing a streaming framework.

Explains how IoT Core ingests, filters, and routes device events, plus guidance on scaling, replay, and reliability.

Design Airflow DAGs for safe retries and idempotent publishing: task boundaries, sensors, schedules, timeouts, and testing.

Checklist for secure data migration: planning, encryption, access controls, logging, testing, cleanup, and post-move governance.

Guide to ClickHouse architecture: columnar storage, MergeTree parts, partitions, shards, replicas, Distributed tables, and query flow.

Low-latency AI streams: use Kafka to ingest, Flink to build features and score, with replay, lateness handling, and exactly-once delivery.

Seven practical signals that reveal when your Python data pipeline needs profiling to find code, orchestration, or infrastructure bottlenecks.

Match serverless settings to each workload's tightest limit: latency for inference, throughput for ETL, dbt warehouse, joins for features.

Checklist of Spark exam essentials: DataFrames/SQL, joins, partitions, performance, streaming, and testing for hands-on prep.