We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a9b6ac1 commit ba4711fCopy full SHA for ba4711f
python/tests/test_dataframe.py
@@ -45,6 +45,7 @@
45
reset_formatter,
46
)
47
from datafusion.expr import Window
48
+from datafusion.record_batch import RecordBatch as DataFusionRecordBatch
49
from pyarrow.csv import write_csv
50
51
pa_cffi = pytest.importorskip("pyarrow.cffi")
@@ -398,6 +399,11 @@ def test_iter_batches(df):
398
399
assert pa_batch.column(2).to_pylist() == [8, 5, 8]
400
401
402
+def test_iter_returns_datafusion_recordbatch(df):
403
+ for batch in df:
404
+ assert isinstance(batch, DataFusionRecordBatch)
405
+
406
407
def test_to_record_batch_stream(df):
408
stream = df.to_record_batch_stream()
409
batches = list(stream)
0 commit comments