Skip to content

Commit b6909a5

Browse files
committed
Remove deprecated to_record_batch_stream method; use execute_stream instead
1 parent 7553b32 commit b6909a5

File tree

2 files changed

+24
-12
lines changed

2 files changed

+24
-12
lines changed

dev/changelog/50.0.0.md

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
<!--
2+
Licensed to the Apache Software Foundation (ASF) under one
3+
or more contributor license agreements. See the NOTICE file
4+
distributed with this work for additional information
5+
regarding copyright ownership. The ASF licenses this file
6+
to you under the Apache License, Version 2.0 (the
7+
"License"); you may not use this file except in compliance
8+
with the License. You may obtain a copy of the License at
9+
10+
http://www.apache.org/licenses/LICENSE-2.0
11+
12+
Unless required by applicable law or agreed to in writing,
13+
software distributed under the License is distributed on an
14+
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
KIND, either express or implied. See the License for the
16+
specific language governing permissions and limitations
17+
under the License.
18+
-->
19+
20+
# Apache DataFusion Python 50.0.0 Changelog
21+
22+
**Other:**
23+
24+
- remove deprecated `DataFrame.to_record_batch_stream`; use `execute_stream` instead.

python/datafusion/dataframe.py

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1047,18 +1047,6 @@ def execute_stream_partitioned(self) -> list[RecordBatchStream]:
10471047
streams = self.df.execute_stream_partitioned()
10481048
return [RecordBatchStream(rbs) for rbs in streams]
10491049

1050-
@deprecated("Use execute_stream() instead")
1051-
def to_record_batch_stream(self) -> RecordBatchStream:
1052-
"""Return a :py:class:`RecordBatchStream` over this DataFrame's results.
1053-
1054-
This method is deprecated. Use :py:meth:`execute_stream` instead.
1055-
1056-
Returns:
1057-
A ``RecordBatchStream`` representing the lazily generated record
1058-
batches for this DataFrame.
1059-
"""
1060-
return self.execute_stream()
1061-
10621050
def to_pandas(self) -> pd.DataFrame:
10631051
"""Execute the :py:class:`DataFrame` and convert it into a Pandas DataFrame.
10641052

0 commit comments

Comments
 (0)