Class TestProcessor

java.lang.Object

org.opensearch.ingest.TestProcessor

All Implemented Interfaces:

org.opensearch.ingest.Processor

public class TestProcessor
extends Object
implements org.opensearch.ingest.Processor

Processor used for testing, keeps track of how many times it is invoked and accepts a Consumer of IngestDocument to be called when executed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestProcessor.Factory

Nested classes/interfaces inherited from interface org.opensearch.ingest.Processor

org.opensearch.ingest.Processor.Parameters

Constructor Summary

Constructors

Constructor	Description
TestProcessor(RuntimeException e)
TestProcessor(String tag, String type, String description, RuntimeException e)
TestProcessor(String tag, String type, String description, Consumer<org.opensearch.ingest.IngestDocument> ingestDocumentConsumer)
TestProcessor(String tag, String type, String description, Function<org.opensearch.ingest.IngestDocument, org.opensearch.ingest.IngestDocument> ingestDocumentMapper)
TestProcessor(Consumer<org.opensearch.ingest.IngestDocument> ingestDocumentConsumer)

Method Summary

Modifier and Type	Method	Description
org.opensearch.ingest.IngestDocument	execute(org.opensearch.ingest.IngestDocument ingestDocument)
String	getDescription()
int	getInvokedCounter()
String	getTag()
String	getType()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opensearch.ingest.Processor

batchExecute, execute, isSystemGenerated

Constructor Details

TestProcessor

public TestProcessor(Consumer<org.opensearch.ingest.IngestDocument> ingestDocumentConsumer)

TestProcessor

public TestProcessor(RuntimeException e)

TestProcessor

public TestProcessor(String tag,
 String type,
 String description,
 RuntimeException e)

TestProcessor

public TestProcessor(String tag,
 String type,
 String description,
 Consumer<org.opensearch.ingest.IngestDocument> ingestDocumentConsumer)

TestProcessor

public TestProcessor(String tag,
 String type,
 String description,
 Function<org.opensearch.ingest.IngestDocument, org.opensearch.ingest.IngestDocument> ingestDocumentMapper)

Method Details

execute

public org.opensearch.ingest.IngestDocument execute(org.opensearch.ingest.IngestDocument ingestDocument)
                                             throws Exception

Specified by:

execute in interface org.opensearch.ingest.Processor

Throws:

Exception

getType

public String getType()

Specified by:

getType in interface org.opensearch.ingest.Processor

getTag

public String getTag()

Specified by:

getTag in interface org.opensearch.ingest.Processor

getDescription

public String getDescription()

Specified by:

getDescription in interface org.opensearch.ingest.Processor

getInvokedCounter

public int getInvokedCounter()