Trait pipeline::etl::processor::ProcessorBuilder

source · 
pub trait ProcessorBuilder: Debug + Send + Sync + 'static {
    // Required methods
    fn output_keys(&self) -> HashSet<&str>;
    fn input_keys(&self) -> HashSet<&str>;
    fn build(self, intermediate_keys: &[String]) -> Result<ProcessorKind>;
}
Expand description

ProcessorBuilder trait defines the interface for all processor builders A processor builder is used to create a processor

Required Methods§

source

fn output_keys(&self) -> HashSet<&str>

Get the processor’s output keys

source

fn input_keys(&self) -> HashSet<&str>

Get the processor’s input keys

source

fn build(self, intermediate_keys: &[String]) -> Result<ProcessorKind>

Build the processor

Implementors§