MCPcopy Create free account
hub / github.com/apache/arrow / test_enable_buffered_stream

Function test_enable_buffered_stream

python/pyarrow/tests/parquet/test_basic.py:154–165  ·  view source on GitHub ↗
(tempdir)

Source from the content-addressed store, hash-verified

152
153@pytest.mark.pandas
154def test_enable_buffered_stream(tempdir):
155 df = alltypes_sample(size=10)
156
157 table = pa.Table.from_pandas(df)
158 _check_roundtrip(table, read_table_kwargs={'buffer_size': 1025},
159 version='2.6')
160
161 filename = str(tempdir / 'tmp_file')
162 with open(filename, 'wb') as f:
163 _write_table(table, f, version='2.6')
164 table_read = pq.read_pandas(filename, buffer_size=4096)
165 assert table_read.equals(table)
166
167
168def test_special_chars_filename(tempdir):

Callers

nothing calls this directly

Calls 5

alltypes_sampleFunction · 0.90
_check_roundtripFunction · 0.90
_write_tableFunction · 0.90
equalsMethod · 0.80
read_pandasMethod · 0.45

Tested by

no test coverage detected