oxirs-arq 0.2.4

Jena-style SPARQL algebra with extension points and query optimization
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

//! # StreamingSelection - Trait Implementations
//!
//! This module contains trait implementations for `StreamingSelection`.
//!
//! ## Implemented Traits
//!
//! - `DataStream`
//!
//! 🤖 Generated with [SplitRS](https://github.com/cool-japan/splitrs)

use crate::algebra::Solution;
use anyhow::Result;

use super::functions::DataStream;
use super::types::{StreamStats, StreamingSelection};

impl DataStream for StreamingSelection {
    fn next_batch(&mut self) -> Result<Option<Vec<Solution>>> {
        if let Some(batch) = self.input.next_batch()? {
            let filtered: Vec<Solution> = batch
                .into_iter()
                .filter(|solution| self.evaluate_condition(solution).unwrap_or(false))
                .collect();
            if filtered.is_empty() && self.input.has_more() {
                self.next_batch()
            } else {
                Ok(Some(filtered))
            }
        } else {
            Ok(None)
        }
    }
    fn has_more(&self) -> bool {
        self.input.has_more()
    }
    fn estimated_size(&self) -> Option<usize> {
        self.input.estimated_size()
    }
    fn reset(&mut self) -> Result<()> {
        self.input.reset()
    }
    fn get_stats(&self) -> StreamStats {
        self.input.get_stats()
    }
}