janbraunsdorff commented on issue #1268:
URL:
https://github.com/apache/datafusion-ballista/issues/1268#issuecomment-2982066537
Hey @milenkovicm
Thanks for your help
in the best case, this is what i am looking for:
```rust
let table = open_table("s3://bucket/source").await?;
ctx.register_table("source", Arc::new(table))?;
let table = open_table("s3://bucket/target").await?;
ctx.register_table("target", Arc::new(table))?;
df = ctx.sql("select * from source").await?;
df.write_table("result", DataFrameWriteOptions::new()).await?;
```
I guess this is the executed code:
https://github.com/apache/datafusion/blob/main/datafusion/catalog/src/table.rs#L298
And delta-rs has no implementation for this interface according to this
source:
https://github.com/delta-io/delta-rs/blob/main/crates/core/src/delta_datafusion/mod.rs#L826
Did i miss something?
I have two questions:
1. is it enough to implement `insert_into` in delta-rs to get it work?
2. Should this executed in client / scheduler / executor (than a lockstore
is needed too).
Thanks for your help.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
