def _batch_generator()

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

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

    def _batch_generator(self) -> Iterator[pa.RecordBatch]:
        while True:
            next_bytes = self._j_bytes_reader.next()
            if next_bytes is None:
                break
            else:
                stream_reader = pa.RecordBatchStreamReader(pa.BufferReader(next_bytes))
                yield from stream_reader