java.lang.Object
org.elasticsearch.ingest.CompoundProcessor
- All Implemented Interfaces:
Processor
- Direct Known Subclasses:
OnFailureProcessor
A Processor that executes a list of other "processors". It executes a separate list of
"onFailureProcessors" when any of the processors throw an
Exception.-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.ingest.Processor
Processor.Factory, Processor.Parameters -
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionCompoundProcessor(boolean ignoreFailure, List<Processor> processors, List<Processor> onFailureProcessors) CompoundProcessor(Processor... processors) -
Method Summary
Modifier and TypeMethodDescriptionexecute(IngestDocument document) Introspect and potentially modify the incoming data.voidexecute(IngestDocument ingestDocument, BiConsumer<IngestDocument, Exception> handler) Introspect and potentially modify the incoming data.Gets the description of a processor.getTag()Gets the tag of a processor.getType()Gets the type of a processorbooleanisAsync()booleanMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.ingest.Processor
extraValidation
-
Field Details
-
ON_FAILURE_MESSAGE_FIELD
- See Also:
-
ON_FAILURE_PROCESSOR_TYPE_FIELD
- See Also:
-
ON_FAILURE_PROCESSOR_TAG_FIELD
- See Also:
-
ON_FAILURE_PIPELINE_FIELD
- See Also:
-
PROCESSOR_TYPE_EXCEPTION_HEADER
- See Also:
-
PROCESSOR_TAG_EXCEPTION_HEADER
- See Also:
-
PIPELINE_ORIGIN_EXCEPTION_HEADER
- See Also:
-
-
Constructor Details
-
CompoundProcessor
-
CompoundProcessor
-
-
Method Details
-
isIgnoreFailure
public boolean isIgnoreFailure() -
getOnFailureProcessors
-
getProcessors
-
flattenProcessors
-
getType
Description copied from interface:ProcessorGets the type of a processor -
getTag
Description copied from interface:ProcessorGets the tag of a processor. -
getDescription
Description copied from interface:ProcessorGets the description of a processor.- Specified by:
getDescriptionin interfaceProcessor
-
isAsync
public boolean isAsync() -
execute
Description copied from interface:ProcessorIntrospect and potentially modify the incoming data. -
execute
Description copied from interface:ProcessorIntrospect 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).
-