BlogsNetflixCassandra Data Movement

Cassandra Data Movement

Cassandra Data Movement

1
posts
2026

Netflix has evolved its Cassandra data movement capabilities by replacing the monolithic Casspactor engine with a new layered architecture. This new system leverages a core S3 reading capability (Cassandra Analytics Wrapper) to produce standard Spark DataFrames, enabling a 'Connector Factory' model. This allows for purpose-built, data-model-aware connectors for various Cassandra data abstractions (Key Value, Time Series, etc.), improving efficiency, reducing intermediate storage bloat, enhancing reliability by reading metadata directly from S3, and enabling time travel capabilities. The new stack also handles skewed partitions more effectively and offers auto-sizing for jobs, leading to significant performance gains and cost savings.

2026

The Evolution of Cassandra Data Movement at Netflix

6/20/2026

This post details the evolution of Netflix's Cassandra data movement, moving from the monolithic Casspactor engine to a new layered architecture. Key technical contributions include: 1. Replacing fragile metadata dependencies with direct S3 reads as the single source of truth. 2. Introducing a 'Connector Factory' model built on Spark DataFrames, allowing data abstractions to create model-aware connectors. 3. Shifting mutation compaction and processing to Spark Executors to handle skewed partitions and avoid out-of-memory errors. 4. Eliminating intermediate Iceberg tables to reduce storage bloat. 5. Implementing robust time travel by processing schema, topology, and data as a cohesive unit. 6. Introducing auto-sizing capabilities for jobs. 7. Achieving significant performance and cost improvements.