snowflake.snowpark.DataFrame.toLocalIterator¶
- DataFrame.toLocalIterator(*, statement_params: Dict[str, str] | None = None, block: bool = True) Iterator[Row] | AsyncJob [source]¶
Executes the query representing this DataFrame and returns an iterator of
Row
objects that you can use to retrieve the results.Unlike
collect()
, this method does not load all data into memory at once.Example:
>>> df = session.table("prices") >>> for row in df.to_local_iterator(): ... print(row) Row(PRODUCT_ID='id1', AMOUNT=Decimal('10.00')) Row(PRODUCT_ID='id2', AMOUNT=Decimal('20.00'))
- Parameters:
statement_params – Dictionary of statement level parameters to be set while executing this action.
block – A bool value indicating whether this function will wait until the result is available. When it is
False
, this function executes the underlying queries of the dataframe asynchronously and returns anAsyncJob
.