Accelerated shuffle reads and writes for aggregation workloads, bringing TPC-DS 10 TB runtime down to 2,247 seconds, plus Spark 4.1 support, accelerated Iceberg compaction and MERGE with deletion vectors and VARIANT, and native Hudi merge-on-read through hudi-rs.
Features
-
Iceberg on Spark 4.1. Accelerated compaction and
MERGE INTOnow support deletion vectors and VARIANT columns, with 4–5× faster compaction and merges compared with the open-source baseline. The operator automatically matches jobs that specify Spark 4.x to the Spark 4.1 image. -
Accelerated compaction for VARIANT data. Quanton compacts VARIANT columns with its columnar approach, avoiding unnecessary decoding and re-encoding.
-
Native Hudi reads with hudi-rs. Hudi 1.x images now accelerate merge-on-read snapshot queries alongside copy-on-write queries. The Rust reader combines base files with updates from delta logs, bringing native execution to tables with log files.
-
Read documents as Spark tables. The bundled
quanton_unstructureddata source extracts text and chunks from PDF, HTML, Office, EPUB, text and Markdown files. Each row includes file metadata and parse status, so a document that fails to parse does not stop the job. -
Export fine-tuning datasets. The bundled
training_datasetwriter validates and exports curated DataFrames for Together, Fireworks or Baseten, with a manifest and provider-specific loading instructions. It prepares the dataset in object storage; you control when to upload it and start training. -
Comet 1.0.0 on Spark 4.1. The operator adds a separate Spark 4.1 image for Apache DataFusion Comet, alongside its existing Spark 3.5 accelerator images.
Improvements
- Improved HashShuffleWriter performance for aggregation workloads by reducing per-row serialization overhead during shuffle writes and deserialization overhead during shuffle reads.
- Aligned shuffle size tracking with skew-join detection to identify and split oversized partitions.
- Runtime images now include
boto3,numpy,pandas, and operational CLI tools.