Skip to content

[SPARK-52428] Add DataFrame::checkpoint() and local_checkpoint()#33

Open
rafafrdz wants to merge 1 commit intoapache:masterfrom
rafafrdz:add-dataframe-checkpoint
Open

[SPARK-52428] Add DataFrame::checkpoint() and local_checkpoint()#33
rafafrdz wants to merge 1 commit intoapache:masterfrom
rafafrdz:add-dataframe-checkpoint

Conversation

@rafafrdz
Copy link
Copy Markdown

Summary

  • Add DataFrame::checkpoint(eager) — persists with MemoryAndDiskDeser storage level, optionally triggers immediate computation
  • Add DataFrame::local_checkpoint(eager) — persists with MemoryAndDisk (no replication), optionally triggers immediate computation
  • Truncates the logical plan, essential for iterative algorithms

Test plan

  • cargo build passes
  • cargo fmt -- --check passes

@rafafrdz rafafrdz force-pushed the add-dataframe-checkpoint branch from 247ef3d to d512855 Compare March 29, 2026 08:08
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.

1 participant