You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by mattyb149 <gi...@git.apache.org> on 2018/10/15 15:43:39 UTC
[GitHub] nifi pull request #2861: NIFI-5248 Added new Elasticsearch json and record p...
Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2861#discussion_r225215710
--- Diff: nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ElasticSearchRestProcessor.java ---
@@ -75,6 +76,19 @@
.required(true)
.build();
+ Relationship REL_FAILURE = new Relationship.Builder()
+ .name("failure")
+ .description("All flowfiles that fail for reasons unrelated to server availability go to this relationship.")
+ .build();
+ Relationship REL_RETRY = new Relationship.Builder()
+ .name("retry")
+ .description("All flowfiles that fail due to server/cluster availability go to this relationship.")
+ .build();
+ Relationship REL_SUCCESS = new Relationship.Builder()
+ .name("success")
+ .description("All flowfiles that succeed in being indexed into ElasticSearch go here.")
--- End diff --
Maybe "transmitted to ElasticSearch"? Unless "indexed" is a generic enough term that users would know covers upserts, deletes, and any other supported operation.
---