Package org.elasticsearch.ingest
Class ConditionalProcessor
- java.lang.Object
-
- org.elasticsearch.ingest.AbstractProcessor
-
- org.elasticsearch.ingest.ConditionalProcessor
-
- All Implemented Interfaces:
Processor
,WrappingProcessor
public class ConditionalProcessor extends AbstractProcessor implements WrappingProcessor
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.elasticsearch.ingest.Processor
Processor.Factory, Processor.Parameters
-
-
Field Summary
-
Fields inherited from class org.elasticsearch.ingest.AbstractProcessor
tag
-
-
Method Summary
Modifier and Type Method Description IngestDocument
execute(IngestDocument ingestDocument)
Introspect and potentially modify the incoming data.void
execute(IngestDocument ingestDocument, java.util.function.BiConsumer<IngestDocument,java.lang.Exception> handler)
Introspect and potentially modify the incoming data.Processor
getInnerProcessor()
Method for retrieving the inner processor from a wrapped processor.java.lang.String
getType()
Gets the type of a processor-
Methods inherited from class org.elasticsearch.ingest.AbstractProcessor
getTag
-
-
-
-
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 overwriteProcessor.execute(IngestDocument)
.
-
execute
public IngestDocument execute(IngestDocument ingestDocument) throws java.lang.Exception
Description copied from interface:Processor
Introspect and potentially modify the incoming data.
-
getInnerProcessor
public Processor getInnerProcessor()
Description copied from interface:WrappingProcessor
Method for retrieving the inner processor from a wrapped processor.- Specified by:
getInnerProcessor
in interfaceWrappingProcessor
- Returns:
- the inner processor
-
-