Skip to content

Commit

Permalink
Update ingest jdocs that a null return value will drop the current do…
Browse files Browse the repository at this point in the history
…cument. (elastic#40359)
  • Loading branch information
martijnvg committed Mar 29, 2019
1 parent c106c78 commit 963c9b8
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 0 deletions.
3 changes: 3 additions & 0 deletions server/src/main/java/org/elasticsearch/ingest/Pipeline.java
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,9 @@ public static Pipeline create(String id, Map<String, Object> config,

/**
* Modifies the data of a document to be indexed based on the processor this pipeline holds
*
* If <code>null</code> is returned then this document will be dropped and not indexed, otherwise
* this document will be kept and indexed.
*/
public IngestDocument execute(IngestDocument ingestDocument) throws Exception {
long startTimeInNanos = relativeTimeProvider.getAsLong();
Expand Down
3 changes: 3 additions & 0 deletions server/src/main/java/org/elasticsearch/ingest/Processor.java
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,9 @@ public interface Processor {

/**
* Introspect and potentially modify the incoming data.
*
* @return If <code>null</code> is returned then the current document will be dropped and not be indexed,
* otherwise this document will be kept and indexed
*/
IngestDocument execute(IngestDocument ingestDocument) throws Exception;

Expand Down

0 comments on commit 963c9b8

Please sign in to comment.