def _write_arrow_batch()

in pypaimon/py4j/java_implementation.py [0:0]

• 6 lines of code
• 1 McCabe index (conditional complexity)

    def _write_arrow_batch(self, record_batch):
        stream = pa.BufferOutputStream()
        with pa.RecordBatchStreamWriter(stream, record_batch.schema) as writer:
            writer.write(record_batch)
        arrow_bytes = stream.getvalue().to_pybytes()
        self._j_bytes_writer.write(arrow_bytes)