DbDataReader
Namespace: Polars.FSharp
Instance Methods
ReadDatabaseBatchesAsync
Asynchronously streams database cursor records into chunks of native Polars DataFrames.
fsharp
member ReadDatabaseBatchesAsync(?batchSize: int, ?cancellationToken: CancellationToken) : IAsyncEnumerable<DataFrame>Parameters
| Name | Type | Description |
|---|---|---|
batchSize | int (optional) | Maximum number of rows per Arrow/DataFrame batch. |
cancellationToken | CancellationToken (optional) | Optional cooperative cancellation token. |
Returns: An asynchronous stream of materialized DataFrame chunks.
Module Functions
DbDataReader.readDatabaseBatchesAsync
Asynchronously streams database cursor records into chunks of native Polars DataFrames.
fsharp
DbDataReader.readDatabaseBatchesAsync : batchSize: int -> reader: DbDataReader -> IAsyncEnumerable<DataFrame>Parameters
| Name | Type | Description |
|---|---|---|
batchSize | int | - |
reader | DbDataReader | - |