(self)
| 1522 | assert table.to_pydict() == expected.to_pydict() |
| 1523 | |
| 1524 | def test_stress_block_sizes(self): |
| 1525 | # Test a number of small block sizes to stress block stitching |
| 1526 | csv_base, expected = make_random_csv(num_cols=2, num_rows=500) |
| 1527 | block_sizes = [11, 12, 13, 17, 37, 111] |
| 1528 | csvs = [csv_base, csv_base.rstrip(b'\r\n')] |
| 1529 | for csv in csvs: |
| 1530 | for block_size in block_sizes: |
| 1531 | read_options = ReadOptions(block_size=block_size) |
| 1532 | table = self.read_bytes(csv, read_options=read_options) |
| 1533 | assert table.schema == expected.schema |
| 1534 | if not table.equals(expected): |
| 1535 | # Better error output |
| 1536 | assert table.to_pydict() == expected.to_pydict() |
| 1537 | |
| 1538 | def test_stress_convert_options_blowup(self): |
| 1539 | # ARROW-6481: A convert_options with a very large number of columns |
nothing calls this directly
no test coverage detected