pipeline::etl::processor

Trait Processor

Source 
pub trait Processor:
    Debug
    + Send
    + Sync
    + 'static {
    // Required methods
    fn kind(&self) -> &str;
    fn ignore_missing(&self) -> bool;
    fn exec_mut(&self, val: &mut PipelineMap) -> Result<()>;
}
Expand description

Processor trait defines the interface for all processors.

A processor is a transformation that can be applied to a field in a document It can be used to extract, transform, or enrich data Now Processor only have one input field. In the future, we may support multiple input fields. The output of a processor is a map of key-value pairs that will be merged into the document when you use exec_map method.

Required Methods§

Source

fn kind(&self) -> &str

Get the processor’s kind

Source

fn ignore_missing(&self) -> bool

Whether to ignore missing

Source

fn exec_mut(&self, val: &mut PipelineMap) -> Result<()>

Execute the processor on a vector which be preprocessed by the pipeline

Implementors§