Skip to content

Upgrade to DataFusion 52.0.0#142

Merged
alxmrs merged 4 commits intomainfrom
df-52
Mar 7, 2026
Merged

Upgrade to DataFusion 52.0.0#142
alxmrs merged 4 commits intomainfrom
df-52

Conversation

@alxmrs
Copy link
Owner

@alxmrs alxmrs commented Mar 7, 2026

Fixes #107.

alxmrs and others added 3 commits March 6, 2026 21:43
- Fix FFI_TableProvider::new() → new_with_ffi_codec(): DataFusion 52 changed
  the table provider FFI signature to require a LogicalExtensionCodec. The
  SessionContext now passes itself as a `session` arg to
  __datafusion_table_provider__; we extract the codec via
  __datafusion_logical_extension_codec__() following the official
  datafusion-python v52 FFI example.
- Add ffi_logical_codec_from_pycapsule() helper (mirrors
  examples/datafusion-ffi-example/src/utils.rs).
- Remove FFI workaround notes and TODO(#107): the collect() bug in DataFusion
  v51 is fixed in v52. Update test_aggregation_with_many_batches to use
  collect() directly to verify correctness of parallel aggregation.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
@alxmrs alxmrs marked this pull request as ready for review March 7, 2026 06:02
@alxmrs alxmrs merged commit 4d63eff into main Mar 7, 2026
12 checks passed
@alxmrs alxmrs deleted the df-52 branch March 7, 2026 06:18
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Upgrade to datafusion-python 52.

1 participant