Reset the writer for reuse.
(self)
| 469 | return pa.RecordBatch.from_arrays(columns, schema=self._schema) |
| 470 | |
| 471 | def reset(self): |
| 472 | """Reset the writer for reuse.""" |
| 473 | self._num_rows = 0 |
| 474 | for appender in self._column_appenders: |
| 475 | appender.reset() |