Closed gangliao closed 2 years ago
ctx.feed_data_sources(&input_partitions).await?;
let output = ctx.execute().await?;
ctx.clean_data_sources().await?;
Hmm... Why did I set the reference of input_partitions
? I should give ownership to the context directly, otherwise, it will make a copy.
Now, we can add the last feature for this project ...
This PR is too complicated. It should be merged shortly.
Which issue does this PR close?
Closes #.
Rationale for this change
What changes are included in this PR?
Are there any user-facing changes?
By submitting this pull request