Commit ac1dfbd
committed
[adapters]: parallel delta output encoder
Use SplitCursor to split the batch and distribute it across tasks,
each task retries encoding and writing to delta lake and then returns
Add actions which main task retries to commit to delta lake
Signed-off-by: Swanand Mulay <73115739+swanandx@users.noreply.github.com>1 parent 91c6514 commit ac1dfbd
4 files changed
Lines changed: 913 additions & 338 deletions
File tree
- crates
- adapters/src/integrated/delta_table
- feldera-types/src/transport
- docs.feldera.com/docs/connectors/sinks
0 commit comments