def write_arrow()

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

• 3 lines of code
• 2 McCabe index (conditional complexity)

    def write_arrow(self, table):
        for record_batch in table.to_reader():
            # TODO: can we use a reusable stream in #_write_arrow_batch ?
            self._write_arrow_batch(record_batch)