Method finish

python/pyfory/format/columnar.py:461–469

Finish writing and return the RecordBatch. Returns: An Arrow RecordBatch containing all written rows.

(self)

        self._num_rows += 1

    def finish(self):
        """
        Finish writing and return the RecordBatch.

        Returns:
            An Arrow RecordBatch containing all written rows.
        """
        columns = [appender.finish() for appender in self._column_appenders]
        return pa.RecordBatch.from_arrays(columns, schema=self._schema)

    def reset(self):
        """Reset the writer for reuse."""