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:137–148  ·  view source on GitHub ↗
(tempdir)

Source from the content-addressed store, hash-verified

135
136@pytest.mark.pandas
137def test_enable_buffered_stream(tempdir):
138 df = alltypes_sample(size=10)
139
140 table = pa.Table.from_pandas(df)
141 _check_roundtrip(table, read_table_kwargs={'buffer_size': 1025},
142 version='2.6')
143
144 filename = str(tempdir / 'tmp_file')
145 with open(filename, 'wb') as f:
146 _write_table(table, f, version='2.6')
147 table_read = pq.read_pandas(filename, buffer_size=4096)
148 assert table_read.equals(table)
149
150
151def 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