(&mut self, batch: &RecordBatch)
| 53 | |
| 54 | impl FileWriter { |
| 55 | async fn write(&mut self, batch: &RecordBatch) -> Result<()> { |
| 56 | match self { |
| 57 | FileWriter::Append(w) => w.write(batch).await, |
| 58 | FileWriter::AppendBlob(w) => w.write(batch).await, |
| 59 | FileWriter::KeyValue(w) => w.write(batch).await, |
| 60 | FileWriter::Postpone(w) => w.write(batch).await, |
| 61 | } |
| 62 | } |
| 63 | |
| 64 | async fn prepare_commit(mut self) -> Result<Vec<DataFileMeta>> { |
| 65 | match self { |