reader = pyarrow.ipc.RecordBatchStreamReader(istream). try: while True: batch = reader.read_next_batch(). batch_count += 1. row_count += batch.num_rows.
確定! 回上一頁