Struct ag::pipeline::Pipeline [−][src]
pub struct Pipeline { /* fields omitted */ }Methods
impl Pipeline[src]
impl Pipelinepub fn new(pipeline: &str) -> Result<Self, Error>[src]
pub fn new(pipeline: &str) -> Result<Self, Error>pub fn process<T: BufRead>(self, buf: T)[src]
pub fn process<T: BufRead>(self, buf: T)pub fn run_agg_pipeline(
head: &Box<AggregateOperator>,
rest: &mut [Box<AggregateOperator>]
) -> Row[src]
pub fn run_agg_pipeline(
head: &Box<AggregateOperator>,
rest: &mut [Box<AggregateOperator>]
) -> Row