We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 806b07d commit 4b92bd2Copy full SHA for 4b92bd2
python/tests/test_io.py
@@ -125,19 +125,6 @@ def test_arrow_c_stream_large_dataset(ctx):
125
assert current_rss - start_rss < 50 * 1024 * 1024
126
127
128
-def test_table_from_batches_stream(ctx, fail_collect):
129
- df = range_table(ctx, 0, 10)
130
-
131
- table = pa.Table.from_batches(df)
132
- expected = pa.Table.from_arrays([pa.array(range(10))], names=["value"])
133
134
- assert table.equals(expected)
135
136
- for batch in df:
137
- assert isinstance(batch, pa.RecordBatch)
138
-import pyarrow as pa
139
140
141
def test_table_from_batches_stream():
142
schema = pa.schema([pa.field("value", pa.int64(), nullable=False)])
143
batch = pa.RecordBatch.from_arrays([pa.array(range(10))], schema=schema)
0 commit comments