Eventual-Inc/Daft - CodSpeed

Daft

Blog Docs Changelog

Performance History

Latest Results

feat:Support PostgreSQL as a structured data source via Gravitino ## Changes Made Implement GravitinoPostgresTable to handle PostgreSQL-specific logic. Parse relevant connection parameters from Gravitino (e.g., host, port, database, table). Use the extracted parameters to construct PostgreSQL-compatible read and write operations. This enables Daft to read from and write to PostgreSQL tables through the existing Gravitino interface, extending beyond the current Iceberg/Parquet-only support.

qingfeng-occ:gravitino_postgres

1 hour ago

euan/nearest-asof

2 hours ago

refactor: preserve original comments and error messages Restore wording I changed unnecessarily during the previous refactor — docstring, protocol-consistency error message, s3a/s3n and gvfs comments, and the per-protocol section headers all return to their pre-refactor form. The structural change (split into _build_filesystem / _resolve_path) is unchanged. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

fix/write-trailing-slash

3 hours ago

feat: configurable flight shuffle compression (#6979) ## Changes Made Adds a new `flight_shuffle_compression` knob to `DaftExecutionConfig`, letting users opt into Arrow IPC compression for flight-shuffle spill files: ```python daft.context.set_execution_config( shuffle_algorithm="flight_shuffle", flight_shuffle_dirs=["/mnt/ssd"], flight_shuffle_compression="zstd", # "lz4" | "zstd" | "none" (default) ) ``` ## Related Issues n/a Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

main

4 hours ago

slade/general-io-usage

4 hours ago

docs(checkpoint): add user guide and connector cross-references Adds user-facing documentation for the checkpoint feature (`df.write_iceberg(checkpoint=...)` and `df.write_deltalake(checkpoint=...)`, plus `CheckpointStore`, `CheckpointConfig`, `IdempotentCommit`). * `docs/use-case/checkpointing.md` — canonical guide covering two guarantees, mental model (with diagram), scope, limitations, and recovery chronology. * `docs/connectors/iceberg.md` + `docs/connectors/delta_lake.md` — new `## Checkpointing` sections with end-to-end examples, marker inspection, sink-specific constraints, idempotence-key contract, and recovery semantics. * `docs/ai-functions/overview.md` — See Also link. * `daft/dataframe/dataframe.py` — `write_iceberg` and `write_deltalake` docstrings forward-reference the guide. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

rohit/df-2049-checkpoint-user-guide

4 hours ago

fix(io): use checked_shl and saturating_mul in retry jitter calculation (#6949) fix(io): use saturating_shl to prevent overflow in retry jitter calculation

main

5 hours ago

test(inline-agg): cover BoolOr partial-nulls path Addresses Greptile's P2 on #6984: BoolAnd has test_inline_bool_and_with_nulls_matches_fallback exercising the null-handling branch, but BoolOr only had an all-null test (test_inline_all_null_bool_or_matches_fallback). The BoolOrAccum::update_batch null branch is a verbatim copy with `||` substituted for `&&`, so a one-line regression there would go undetected. Adds test_inline_bool_or_with_nulls_matches_fallback, mirroring the BoolAnd-with-nulls test, reusing the existing make_bool_val_with_nulls_test_batch helper. 38 inline_agg tests pass (37 prior + 1 new).

BABTUNA:perf/inline-agg-bool

5 hours ago

Latest Branches

0%

feat:support PostgreSQL as a structured data source via Gravitino#6989

2 hours ago

efedf5d

qingfeng-occ:gravitino_postgres

0%

feat: nearest asof joins#6953

2 hours ago

2c8b915

euan/nearest-asof

0%

fix: strip trailing slash from resolved write/read paths#6987

3 hours ago

4984568

fix/write-trailing-slash

© 2026 CodSpeed Technology

Home Terms Privacy Docs