Class TrackingResultProcessor

  • All Implemented Interfaces:
    Processor

    public final class TrackingResultProcessor
    extends java.lang.Object
    implements Processor
    Processor to be used within Simulate API to keep track of processors executed in pipeline.
    • Method Detail

      • execute

        public void execute​(IngestDocument ingestDocument,
                            java.util.function.BiConsumer<IngestDocument,​java.lang.Exception> handler)
        Description copied from interface: Processor
        Introspect and potentially modify the incoming data. Expert method: only override this method if a processor implementation needs to make an asynchronous call, otherwise just overwrite Processor.execute(IngestDocument).
        Specified by:
        execute in interface Processor
      • execute

        public IngestDocument execute​(IngestDocument ingestDocument)
                               throws java.lang.Exception
        Description copied from interface: Processor
        Introspect and potentially modify the incoming data.
        Specified by:
        execute in interface Processor
        Returns:
        If null is returned then the current document will be dropped and not be indexed, otherwise this document will be kept and indexed
        Throws:
        java.lang.Exception
      • getType

        public java.lang.String getType()
        Description copied from interface: Processor
        Gets the type of a processor
        Specified by:
        getType in interface Processor
      • getTag

        public java.lang.String getTag()
        Description copied from interface: Processor
        Gets the tag of a processor.
        Specified by:
        getTag in interface Processor