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 16a249c commit d91ecfaCopy full SHA for d91ecfa
python/datafusion/dataframe.py
@@ -1031,10 +1031,6 @@ def execute_stream(self) -> RecordBatchStream:
1031
"""
1032
return RecordBatchStream(self.df.execute_stream())
1033
1034
- def to_record_batch_stream(self) -> RecordBatchStream:
1035
- """Return a :class:`RecordBatchStream` executing this DataFrame."""
1036
- return self.execute_stream()
1037
-
1038
def execute_stream_partitioned(self) -> list[RecordBatchStream]:
1039
"""Executes this DataFrame and returns a stream for each partition.
1040
0 commit comments