Skip to content

Commit 16a249c

Browse files
committed
Fix documentation to reference datafusion.RecordBatch instead of pyarrow.RecordBatch
1 parent d0ee865 commit 16a249c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/datafusion/dataframe.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ class DataFrame:
292292
"""Two dimensional table representation of data.
293293
294294
DataFrame objects are iterable; iterating over a DataFrame yields
295-
:class:`pyarrow.RecordBatch` instances lazily.
295+
:class:`datafusion.RecordBatch` instances lazily.
296296
297297
See :ref:`user_guide_concepts` in the online documentation for more information.
298298
"""
@@ -1044,7 +1044,7 @@ def execute_stream_partitioned(self) -> list[RecordBatchStream]:
10441044
streams = self.df.execute_stream_partitioned()
10451045
return [RecordBatchStream(rbs) for rbs in streams]
10461046

1047-
def to_record_batch_stream(self) -> RecordBatchStream:
1047+
def to_record_batch_stream(self) -> RecordBatchStream: # noqa: F811
10481048
"""Return a :py:class:`RecordBatchStream` over this DataFrame's results.
10491049
10501050
Returns:

0 commit comments

Comments
 (0)