Data Engineering & Infrastructure

Data pipelines, orchestration, quality engineering, streaming, storage, and analytics infrastructure.

Concepts

Apache Arrow / Parquet (1) Apache Flink (1) Apache Iceberg (1) Apache Kafka (1) Batch Processing (2) Change Data Capture (2) Dagster Orchestrator (4) Data Contracts (4) Data Governance (2) Data Lake (2) Data Mesh (4) Data Observability (1) Data Pipeline Architecture (5) Data Quality (4) Data Security & Access Control (2)
Research

Relaxing Faithfulness with Intervention-Only Causal Discovery

Causal discovery algorithms learn a network that describes the causal dependencies among random variables. A common workflow involves first utilizing conditional independence properties on observation

Research

MemExchange: Cloud-Scale Memory Trading

To handle unpredictable workloads, cloud providers typically over-provision memory to meet peak demand, resulting in substantial underutilization across datacenter clusters. At the same time, memory-c

Research

Time Is Money: Incentivized Causal Transaction Ordering

Front-running is a subtle and persistent problem for blockchains. A blockchain is a stateful virtual machine executing instructions called transactions. Users earn rewards by publishing functional tra

Research

Who Needs DRAM? We Have Fiber

The rising pressure on DRAM availability and contract pricing reflects generative AI's massive high-performance memory requirements. This pressure is heavily compounded by hyperscale data center expan

Research

Parallel QEC Decoding Applied to Distributed Quantum Computing

A novel parallel approach is proposed for QEC decoding based on Belief Propagation with Ordered Statistics Decoding. The main idea is to pre-process the error vectors obtained from Belief Propagation

Research

Rust is in TIOBE Index top 10

HackerNews discussion (18 points) about Rust is in TIOBE Index top 10.

Research

Parallel $\mathcal O(\sqrt n)$ Overhead LSD Radix Sort

We present Radsort, a variant of LSD radix sort, sorting data with $\mathcal O(\sqrt n)$ additional space. Radsort is stable, admits a simple implementation and is easy to parallelise. For arrays exce

Research

Adaptive Inference Batching using Policy Gradients

Inference serving systems must balance throughput and latency under bursty, heterogeneous workloads, yet the industry standard remains static batching policies that require manual tuning and cannot ad

Research

Geometric Causal Models

Scientists often seek to draw causal inferences from structured data that is not independently and identically distributed, such as spatial data, network data, or molecular data. We develop geometric

Research

Data Contracts: Schema as API for the Analytics Team

Implementing data contracts with dbt-expectations, Soda, and Great Expectations. Covers schema evolution, contract versioning, producer/consumer ownership patterns, and breaking change detection in production pipelines.

Research

Airflow vs Prefect vs Dagster: Choosing the Right Orchestrator in 2026

Comprehensive comparison of the three leading Python orchestrators: execution model, DAG vs asset paradigm, scaling characteristics, monitoring, and community ecosystem. Decision framework for greenfield and migration scenarios.

Research

Schema Registry Patterns: Avro, Protobuf, and JSON Schema in Production

Schema Registry Patterns: Avro, Protobuf, and JSON Schema in Production Schema registry architectures enable versioned, contract-enforced data serialization across distributed pipelines. This document provides a comprehensive reference for implementing schema evolution with backward, forward, and full compatibility contracts in production data engineering environments. Overview Schema registry architectures with Confluent Schema Registry and Apicurio provide centralized schema management

Research

Data Products: Designing APIs for the Internal Data Platform

Data product design patterns: API contracts, SLAs, versioning, discovery, and access control. Implementation with dbt (data products as models), Dagster (software-defined assets), and DataHub for cataloging.

Research

Kubernetes for Data Engineering: Running Data Pipelines on K8s

Running data workloads on Kubernetes: Airflow Executor types (Celery vs Kubernetes), Dagster on K8s, Spark on Kubernetes with the Spark Operator, and stateful workloads (Kafka, Flink) on K8s. Resource management and cost optimization.