-
Notifications
You must be signed in to change notification settings - Fork 198
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
CLI uses ballista context instead of datafusion context in local mode #252
CLI uses ballista context instead of datafusion context in local mode #252
Conversation
- add concurrent_tasks parameter for ballista local mode, default to all available cores - use `BallistaContext` instead of `SessionContext` - use `BallistaError` instead of `DataFusionError`
ballista-cli/src/context.rs
Outdated
Context::Local(ballista) => ballista | ||
.sql(sql) | ||
.await | ||
.map_err(BallistaError::DataFusionError), | ||
Context::Remote(ballista) => ballista | ||
.sql(sql) | ||
.await | ||
.map_err(BallistaError::DataFusionError), |
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.
We have the same code in both cases. I think we can remove the Context
abstraction in the CLI now and just use the Ballista context directly.
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 for the feedback, I will fix it again.
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.
I submit a new commit for this.
This is looking good. Thanks @r4ntix. I left some feedback. |
This is looking good @r4ntix. Did you need any help with the CI failures?
|
@r4ntix I took the liberty of merging latest from master and fixing merge conflicts |
Thank you very much for helping to fix the remaining issues, I will keep learning and contributing to ballista :) |
Which issue does this PR close?
Closes #219
Rationale for this change
See #219
What changes are included in this PR?
BallistaContext
instead ofSessionContext
BallistaError
instead ofDataFusionError
Are there any user-facing changes?
add concurrent_tasks parameter for ballista local mode, default to all available cores