Interface Processor.Factory

All Known Implementing Classes:
DropProcessor.Factory, PipelineProcessor.Factory
Enclosing interface:

public static interface Processor.Factory
A factory that knows how to construct a processor based on a map of maps.
  • Method Summary

    Modifier and Type Method Description
    Processor create​(java.util.Map<java.lang.String,​Processor.Factory> processorFactories, java.lang.String tag, java.util.Map<java.lang.String,​java.lang.Object> config)
    Creates a processor based on the specified map of maps config.
  • Method Details

    • create

      Processor create​(java.util.Map<java.lang.String,​Processor.Factory> processorFactories, java.lang.String tag, java.util.Map<java.lang.String,​java.lang.Object> config) throws java.lang.Exception
      Creates a processor based on the specified map of maps config.
      processorFactories - Other processors which may be created inside this processor
      tag - The tag for the processor
      config - The configuration for the processor Note: Implementations are responsible for removing the used configuration keys, so that after creating a pipeline ingest can verify if all configurations settings have been used.