-
Notifications
You must be signed in to change notification settings - Fork 197
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Update DataFusion to 43 #1125
base: main
Are you sure you want to change the base?
Update DataFusion to 43 #1125
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @Dandandan
I can succesfully run the tpc-h queries, let's wait until build is green. |
I have mixed feelings about keeping that test which involves ballista python, should we remove it and risk breaking python from time to time? wdyt @Dandandan @andygrove |
PoV: Shouldn't the Python code be in its own repo? Ballista is being
redesigned as a library, and Python is an application of the library...
…On Wed, Nov 20, 2024 at 4:05 PM Marko Milenković ***@***.***> wrote:
I have mixed feelings about keeping that test which involves ballista
python, should we remove it and risk breaking python from time to time?
wdyt @Dandandan <https://github.com/Dandandan> @andygrove
<https://github.com/andygrove>
—
Reply to this email directly, view it on GitHub
<#1125 (comment)>,
or unsubscribe
<https://github.com/notifications/unsubscribe-auth/ACNEIPJOQLOCMX5DNZEFQGL2BT2P7AVCNFSM6AAAAABSFBQZ3GVHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHMZDIOBZGUZTSMRTGI>
.
You are receiving this because you are subscribed to this thread.Message
ID: ***@***.***>
|
once we merge this patch, ballista will read deltalake (custom codecs needed) let config = SessionConfig::new_with_ballista()
.with_target_partitions(1)
.with_ballista_standalone_parallelism(2)
.with_ballista_logical_extension_codec(Arc::new(BallistaDeltaLogicalCodec::default()))
.with_ballista_physical_extension_codec(Arc::new(BallistaDeltaPhysicalCodec::default()));
let state = SessionStateBuilder::new()
.with_config(config)
.with_default_features()
.build();
let table = deltalake::open_table("/Users/ballissta/TMP/delta_table/")
.await
.unwrap();
let ctx = SessionContext::standalone_with_state(state).await?;
ctx.register_table("demo", Arc::new(table)).unwrap();
let df = ctx.sql("select * from demo").await?;
df.show().await?; relates to #457 |
We could split it into its own repo, but right now it seems like it is just Marko, Andy, Daniel, and I that have been making updates. If Ballista Python gets more support than me there could be an argument for it, but at this time it is better to manage it all in one place. |
pyballista will be changing to ballista |
With (py)ballista issues outlined in #1142 would it make sense to release this version without it? That would give us some time to figure out python support? Wdyt @andygrove ? |
Which issue does this PR close?
Closes #1124
Rationale for this change
What changes are included in this PR?
Are there any user-facing changes?