Skip to content

Commit c325857

Browse files
committed
Fix documentation to reference datafusion.RecordBatch instead of pyarrow.RecordBatch
1 parent a8f67b7 commit c325857

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

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)