pipeline::etl::processor

Trait 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§