Add data source sinks for Polars LazyFrame (#791)#1416
Open
Chowdhury-Anik wants to merge 2 commits intoapache:mainfrom
Open
Add data source sinks for Polars LazyFrame (#791)#1416Chowdhury-Anik wants to merge 2 commits intoapache:mainfrom
Chowdhury-Anik wants to merge 2 commits intoapache:mainfrom
Conversation
Contributor
elijahbenizzy
left a comment
There was a problem hiding this comment.
Looks good -- maybe add a test?
skrawcz
requested changes
Nov 10, 2025
Contributor
skrawcz
left a comment
There was a problem hiding this comment.
Just need some tests please
Contributor
|
@Chowdhury-Anik just bumping this PR :) would love some tests please. |
This commit adds four data sink methods for Polars LazyFrame: - sink_parquet: Write LazyFrame to Parquet format - sink_csv: Write LazyFrame to CSV format - sink_ipc: Write LazyFrame to IPC/Feather format - sink_ndjson: Write LazyFrame to NDJSON format These sinks allow users to write LazyFrames directly without needing to call .collect() first, improving performance for large datasets. Fixes apache#791
a38a271 to
93a56f0
Compare
Contributor
|
once #1429 is merged we can rebase this and this should be good to go. |
Contributor
|
@Chowdhury-Anik mind rebasing? |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
This commit adds four data sink methods for Polars LazyFrame:
These sinks allow users to write LazyFrames directly without needing to call .collect() first, improving performance for large datasets.
Fixes #791
Changes
How I tested this
Notes
Checklist