-
Notifications
You must be signed in to change notification settings - Fork 164
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
Chore: Cleanup how datafusion session config is created #289
Conversation
core/src/execution/jni_api.rs
Outdated
// Get Datafusion configuration from Spark Execution context | ||
// can be configured in Comet Spark JVM using Spark --conf parameters | ||
// e.g: spark-shell --conf spark.datafusion.sql_parser.parse_float_as_decimal=true |
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.
Could you keep this comment? It doesn't related to how the configs are read into session config but a general description what they come from.
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.
Okay, will add them back
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.
added them in commit dd573e2
Thanks for this PR. I have one comment about keeping original code comment. |
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 @psvri
Which issue does this PR close?
Rationale for this change
Rather than cloning the strings, inserting into map and creating session config from it. The current approach just sets these values manually. This way we avoid creating a few temporary strings and data structures.
What changes are included in this PR?
Reworked the way datafusion session config is created.
How are these changes tested?
Ensured github ci passes in my forked repo.