Struct StreamingProject 

pub struct StreamingProject { /* private fields */ }

Keep only the specified fields in each record. Fields not present in the input record are silently omitted from the output.

Example

use scirs2_io::streaming::relational::{StreamingProject, StreamingOp};
use serde_json::json;

let mut p = StreamingProject::new(vec!["name".into(), "age".into()]);
let out = p.process(vec![json!({"name": "Alice", "age": 30, "extra": "X"})]);
assert!(!out[0].as_object().unwrap().contains_key("extra"));

Implementations

impl StreamingProject

pub fn new(fields: Vec<String>) -> Self

Create a projection keeping fields.

Trait Implementations

impl StreamingOp for StreamingProject

fn process(&mut self, records: Vec<Value>) -> Vec<Value>

Transform a chunk of records. Stateful operators (like Deduplicate) may carry state across multiple calls.

fn reset(&mut self)

Reset operator state (useful when reusing across multiple inputs).