John Darrington
07/16/2023, 6:44 PMDeltaWriter
- write, then close it to get the Add
actions which I then have to commit myself?Robert
07/16/2023, 8:57 PMoperations::writer::DeltaWriter
as well. Its been on my todo list for a while re consolidate those. This is an artifact from introducing conflict resolution without breaking downstream applications.Will Jones
07/16/2023, 9:07 PMJohn Darrington
07/16/2023, 10:53 PMWill Jones
07/16/2023, 11:01 PMJohn Darrington
07/16/2023, 11:02 PMWill Jones
07/16/2023, 11:02 PMMatthew Powers
07/17/2023, 2:38 PMJohn Darrington
07/17/2023, 4:30 PMRobert
07/17/2023, 8:41 PMrtyler
07/17/2023, 8:42 PMRobert
07/17/2023, 8:45 PMI'd add that we probably have two different write use cases: one is users who have streams of rows (like the kafka ingest project) and the other who have columnar batches (from polars or datafusion or elsewhere). So we should be able to guide each user type to the right interface.Fully agree. I think Kafka ingest only uses the JSON writer (right @rtyler?), Right now its still not quite a streaming API for writing the json batches. AFAIK, tyler recently moved to the new json decoder APIs already, which can quite readily be made to process streams - just did something similar in kernel π.