Skip to main content

ReduceFunction

oxigdal_streaming::transformations

Trait ReduceFunction 

Source 
pub trait ReduceFunction: Send + Sync {
    // Required method
    fn reduce(&self, value1: Vec<u8>, value2: Vec<u8>) -> Vec<u8> ⓘ;
}
Expand description

Function for reducing elements.

Required Methods§

Source

fn reduce(&self, value1: Vec<u8>, value2: Vec<u8>) -> Vec<u8> ⓘ

Reduce two values into one.

Implementors§