paimon
paimon copied to clipboard
[spark] Support cross partition write
Purpose
spark support Cross Partitions Upsert Dynamic Bucket Mode
Tests
API and Format
Documentation
How is this PR going?
@waywtdcc cross partition write needs to be refactored, will rebase after refactoring
Now, How is this PR going?
@waywtdcc sorry for delay, we choose to closed it, The current implementation is friendly to streaming scenarios, but the batch cost is too high. We need to find a more efficient implementation in batch scenarios.
Doesn't flink batch also support it? The logic of the two should be the same, right?