-
Notifications
You must be signed in to change notification settings - Fork 196
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 to apache/arrow-datafusion#2578 #48
Conversation
let df = ctx.read_csv(table_name, options).await?; | ||
|
||
let uri = format!("file:///{}.csv", table_name); | ||
ctx.register_csv(table_name, &uri, options).await?; |
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.
Changing to using this method is necessary as otherwise it infers the ?table?
as the table name, which seems to result in an additional projection appearing, not entirely sure why though...
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.
CC @andygrove
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.
The changes make sense to me
@@ -39,8 +39,8 @@ arrow-flight = { version = "14.0.0" } | |||
async-trait = "0.1.41" | |||
chrono = { version = "0.4", default-features = false } | |||
clap = { version = "3", features = ["derive", "cargo"] } | |||
datafusion = { git = "https://github.com/apache/arrow-datafusion", rev = "b6fb0dd52c2abd0f8e134aa46cc1571cc6a0971b" } | |||
datafusion-proto = { git = "https://github.com/apache/arrow-datafusion", rev = "b6fb0dd52c2abd0f8e134aa46cc1571cc6a0971b" } | |||
datafusion = { git = "https://github.com/apache/arrow-datafusion", rev = "fdb8fecf0ab475ba07dc0d15f7b53e25ccf30ee7" } |
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.
@andygrove / @thinkharderdev -- what would you think about writing some script that automatically updates this pin rather than requiring datafusion developers manually make PRs?
We basically upgrade the DataFusion pin manually for IOx and while it takes times it seems to work for us -- for example https://github.com/influxdata/influxdb_iox/pull/4619
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.
Makes sense to me
let df = ctx.read_csv(table_name, options).await?; | ||
|
||
let uri = format!("file:///{}.csv", table_name); | ||
ctx.register_csv(table_name, &uri, options).await?; |
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.
CC @andygrove
I am going to merge this in because:
|
Which issue does this PR close?
Rationale for this change
apache/datafusion#2578 contains breaking changes (introduces ListingTableUri)
What changes are included in this PR?
Updates Ballista with breaking changes
Are there any user-facing changes?
There are breaking changes to DataFusion