Struct ZSetBatchIterator 

pub struct ZSetBatchIterator { /* private fields */ }

Iterator for scanning Redis sorted sets in batches as Arrow RecordBatches.

This iterator fetches sorted set keys matching a pattern and retrieves their members with scores, converting them to Arrow RecordBatches for use with Polars. Each member becomes a row in the output.

Example

use polars_redis::{ZSetBatchIterator, ZSetSchema, BatchConfig};

let schema = ZSetSchema::new().with_key(true).with_rank(true);
let config = BatchConfig::new("leaderboard:*").with_batch_size(1000);

let mut iterator = ZSetBatchIterator::new(url, schema, config)?;

while let Some(batch) = iterator.next_batch()? {
    println!("Got {} members", batch.num_rows());
}

Output Schema

• _key (optional): The Redis key
• member: The sorted set member value (Utf8)
• score: The member’s score (Float64)
• rank (optional): The member’s rank in the sorted set (Int64)

Implementations

impl ZSetBatchIterator

pub fn new(url: &str, schema: ZSetSchema, config: BatchConfig) -> Result<Self>

Create a new ZSetBatchIterator.

pub fn next_batch(&mut self) -> Result<Option<RecordBatch>>

Get the next batch of data as a RecordBatch.

pub fn is_done(&self) -> bool

Check if iteration is complete.

pub fn rows_yielded(&self) -> usize

Get the number of rows (members) yielded so far.